
产品注册版本为「v5.0共创版」时,才能使用数据开发-实时任务:
1) 如需申请免费试用或增购功能点,请填写链接:实时任务意向使用申请表
2) 如需了解更多实时任务详细信息,可联系技术支持(技术支持联系方式:前往「服务」,选择「在线支持」、电话「400-811-8890」)。
1. 概述
1.1 版本
FineDataLink 版本 | 功能变动 |
---|---|
5.0.0.1 | - |
5.0.0.4 | 支持配置消息格式类型 |
1.2 应用场景
用户需要在 FVS Demo 中实时监听 WebSocket 数据,实现三维场景内的精确运动还原,所以希望通过实时任务将数据转换后输出到 WebSocket 。
1.3 功能简介
数据开发-实时任务中,新增「WebSocket 输出」算子,支持将数据实时输出到 WebSocket 。如下图所示:
2. 功能说明
1)需要先配置 WebSocket数据连接
2)「WebSocket 输出」算子界面如下图所示:
设置项 | 说明 |
---|---|
数据连接 | WebSocket 类型的数据连接 |
消息格式类型&输出样例 | debezium-json: 按照元数据、事件类型和数据变化情况,构造包含老数据、新数据、操作类型等信息的消息结构,格式为:
json: 把一行记录当前的字段值打包成 json 格式,示例为: 注:当前任务中,存在产生更新流的算子时,json 格式禁用;会产生更新流的算子:CDC输入、分组汇总、数据关联(多个实时数据源进行关联)。
|
写入方式 | 只支持「追加写入」 |
3. 操作步骤
示例:将 MySQL 数据库中的数据实时同步到 WebSocket 。
3.1 设置 CDC 输入
1)进入 FineDataLink 数据平台后,点击「数据开发>实时任务」,新建实时任务。如下图所示:
2)进入编辑界面后,拖入「CDC输入」算子,选择数据源和数据表。如下图所示:
点击「数据预览」即可看到取出的数据。如下图所示:
3.2 取部分字段
拖入「字段设置」算子,删除不需要的字段。如下图所示:
3.3 输出到 WebSocket
拖入「WebSocket 输出」算子,将数据输出到 WebSocket 。如下图所示:
3.4 启动任务
点击右上角的「启动」按钮,启动实时任务。启动后界面如下图所示: