注:数据开发中实时任务当前属于内测阶段,如需试用或者了解详细信息,请联系技术支持(技术支持联系方式:前往「服务」,选择「在线支持」、电话「400-811-8890」)。
用户需要实时读取 IBM MQ 中的数据,将数据解析后,写入指定数据库中,并使用数据进行报表和实时大屏制作和展示。
FineDataLink 的「数据开发-实时任务」支持使用「IBM MQ输入」算子实时读取数据。
「IBM MQ输入」算子设置界面如下图所示:
各设置项说明如下:
1)主题(topic):消息的 topic 名称
2)消息内容(applicationData):消息的实际内容
对于不同数据格式的 value(xml、json、键值对、Avro等),统一都转换为文本格式
可后接转换算子进行解析
不可设置,默认为「仅增量同步」,即从指定的起点开始,持续同步新增的变化数据(增/删/改)
由于 IBM MQ 的输入只支持获取生成订阅后的消息,因此无法直接从 IBM MQ 中提取已有的数据,并且考虑到主题(topic)中不一定有「保留消息」,所以「IBM MQ输入」算子的「样本设置」中提供「手动配置」功能
当选择「手动配置」时,根据配置的输出字段,在样本设置弹窗内生成一个 N 列、1 行的二维表,默认生成一条样本数据,用户可以修改其中每一个单元格的内容,各输出字段的默认值为:
topic:用户配置的 topic
applicationData:空
按照配置的输出字段和样本设置展示数据
如果获取保留消息时,topic 中没有保留消息,则只生成表结构,没有数据行
1)登录 FDL 工程,点击「数据开发>实时任务>新建」,新建实时任务。如下图所示:
自定义位置和名称后,点击「编辑」按钮进入实时任务设计页面。如下图所示:
2)拖入「IBM MQ输入」算子,选择数据源,设置 Topic 和输出字段。如下图所示:
点击「数据预览」,可预览数据:
取出的数据为 JSON 格式数据。
1)拖入「JSON解析」算子,解析 3.1 节取出的数据。如下图所示:
2)点击「数据预览」,如下图所示:
拖入「DB表输出」算子,将数据输出至指定的数据库中。如下图所示:
DB表输出设置详情参见:DB表输出(实时任务)
写入方式默认即可。
点击「启动」按钮,即可启动实时任务,如下图所示:
可在 任务管理界面 看到任务运行状态和运行详情。
滑鼠選中內容,快速回饋問題
滑鼠選中存在疑惑的內容,即可快速回饋問題,我們將會跟進處理。
不再提示
10s後關閉
反馈已提交
网络繁忙