
产品注册版本为「v5.0共创版」时,才能使用数据开发-实时任务:
1) 如需申请免费试用或增购功能点,请填写链接:实时任务意向使用申请表
2) 如需了解更多实时任务详细信息,可联系技术支持(技术支持联系方式:前往「服务」,选择「在线支持」、电话「400-811-8890」)。
1. 概述
1.1 版本
FineDataLink 版本 | 功能变动 |
---|---|
5.0.0.1 | - |
5.0.1.5 | 实时任务中若使用「WebSocket 输入」节点,不能再使用 分组汇总(实时任务)、Flink SQL、数据关联(多个实时数据源进行关联) |
1.2 应用场景
物联网数据是通过 WebSocket 协议开放的,希望实时任务读取 WebSocket 数据。
1.3 功能简介
数据开发-实时任务中,新增「WebSocket 输入」算子,支持读取 WebSocket 数据。如下图所示:
1.4 功能限制
5.0.1.5 及之后版本,实时任务中若使用「WebSocket 输入」节点,不能再使用 分组汇总(实时任务)、Flink SQL、数据关联(多个实时数据源进行关联)。
2. 功能说明
1)需要先配置 WebSocket数据连接
2)「WebSocket 输入」算子界面如下图所示:
设置项 | 说明 |
---|---|
数据源 | WebSocket 类型的数据连接 |
输出字段 | 配置读取 WebSocket 消息中哪些信息传输给下游算子
|
同步类型 | 仅增量同步,不可自定义 |
增量同步起点 | 任务启动时间,不可自定义 |
样本设置 | 只支持「手动配置」 |
3. 操作步骤
实时任务中读取 WebSocket 数据,经过 JSON 解析后,输出到数据库表中。
注:需要先配置 WebSocket数据连接
3.1 WebSocket 输入
1)进入 FineDataLink 工程,点击「数据开发>实时任务」,创建实时任务。如下图所示:
2)进入编辑页面后,拖入「WebSocket 输入」算子,读取 WebSocket 数据。如下图所示:
点击「数据预览」,如下图所示:
3.2 JSON 解析
拖入「JSON 解析」算子,解析 WebSocket 数据。如下图所示:
点击「数据预览」,如下图所示:
3.3 数据输出
拖入「DB表输出」算子,将处理后的数据输出。如下图所示:
3.4 启动任务
点击右上角的「启动」按钮,启动实时任务。启动后界面如下图所示: