最新历史版本 :IBM MQ输入 返回文档
编辑时间: 内容长度:图片数:目录数: 修改原因:

注:数据开发中实时任务当前属于内测阶段,如需试用或者了解详细信息,请联系技术支持(技术支持联系方式:前往「服务」,选择「在线支持」、电话「400-811-8890」)。

目录:

1. 概述编辑

1.1 版本

 FineDataLink 版本功能变动
4.1.13.2新增「IBM MQ输入算子

1.2 应用场景

用户需要实时读取 IBM MQ 中的数据,将数据解析后,写入指定数据库中,并使用数据进行报表和实时大屏制作和展示。

1.3 功能简介

FineDataLink 的数据开发-实时任务支持使用IBM MQ输入算子实时读取数据。

2. 功能说明编辑

IBM MQ输入算子设置界面如下图所示:

4.png

各设置项说明如下:

设置项
说明
数据源
需要先 配置IBM MQ数据源 的数据连接,才能在此处选择;必填
Topic通过文本框输入 topic,比如:myhome/kitchen/smartdishwasher;必填
输出字段配置读取 IBM MQ 消息中哪些信息传输给下游算子,可选择「消息内容」、「主题」

1)主题(topic):消息的 topic 名称

2)消息内容(applicationData):消息的实际内容

  • 对于不同数据格式的 value(xml、json、键值对、Avro等),统一都转换为文本格式

  • 可后接转换算子进行解析

同步类型

不可设置,默认为仅增量同步,即从指定的起点开始,持续同步新增的变化数据(增/删/改)

增量同步起点默认为任务启动时间,不可自定义
样本设置

由于 IBM MQ 的输入只支持获取生成订阅后的消息,因此无法直接从 IBM MQ 中提取已有的数据,并且考虑到主题(topic)中不一定有保留消息,所以「IBM MQ输入算子样本设置」中提供「手动配置」功

1729065358535239.png

当选择「手动配置」时,根据配置的输出字段,在样本设置弹窗内生成一个 N 列、1 行的二维表,默认生成一条样本数据,用户可以修改其中每一个单元格的内容,各输出字段的默认值为:

  • topic:用户配置的 topic

  • applicationData:空

数据预览

按照配置的输出字段和样本设置展示数

如果获取保留消息时,topic 中没有保留消息,则只生成表结构,没有数据行

3. 取数示例编辑

3.1 IBM MQ输入算子读取数据

1)登录 FDL 工程,点击「数据开发>实时任务>新建」,新建实时任务。如下图所示:

2.png

自定义位置和名称后,点击编辑按钮进入实时任务设计页面。如下图所示:

3.png

2)拖入「IBM MQ输入算子,选择数据源,设置 Topic 和输出字段。如下图所示:

27.png

点击数据预览,可预览数据:

取出的数据为 JSON 格式数据。

1729065517864249.png

3.2 解析数据

1)拖入JSON解析算子,解析 3.1 节取出的数据。如下图所示:

1729065632191693.png

2)点击数据预览,如下图所示:

1729065670922141.png

3.3 数据输出

拖入DB表输出算子,将数据输出至指定的数据库中。如下图所示:

DB表输出设置详情参见:DB表输出(实时任务)

31.png

写入方式默认即可。

3.4 任务启动和管理

点击启动」按钮,即可启动实时任务,如下图所示:

32.png

可在 任务管理界面 看到任务运行状态和运行详情。