反馈已提交

网络繁忙

IBM MQ输入

  • 文档创建者:Wendy123456
  • 历史版本:10
  • 最近更新:Richard.Guo 于 2025-08-29
  • icon提示:

    产品注册版本为「v5.0共创版」时,才能使用数据开发-实时任务:

    1) 如需申请免费试用或增购功能点,请填写链接:实时任务意向使用申请表

    2) 如需了解更多实时任务详细信息,可联系技术支持(技术支持联系方式:前往「服务」,选择「在线支持」、电话「400-811-8890」)。

    1. 概述

    1.1 版本

    FineDataLink 版本功能变动
    5.0.0.1-
    5.0.1.5实时任务中若使用 IBM MQ 输入 节点,不能再使用 分组汇总(实时任务)Flink SQL数据关联(多个实时数据源进行关联)

    1.2 应用场景

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

    1.3 功能简介

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

    1.4 功能限制

    5.0.1.5 及之后版本,实时任务中若使用 IBM MQ 输入节点,不能再使用 分组汇总(实时任务)Flink SQL数据关联(多个实时数据源进行关联)。

    2. 功能说明

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

    4.png

    各设置项说明如下:

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

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

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

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

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

    同步类型

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

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

    支持添加多条采样数据

    数据预览

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

    如果获取保留消息时,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

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

    附件列表


    主题: 数据开发-实时任务
    • 有帮助
    • 没帮助
    • 只是浏览
    中文(简体)

    鼠标选中内容,快速反馈问题

    鼠标选中存在疑惑的内容,即可快速反馈问题,我们将会跟进处理。

    不再提示

    10s后关闭



    AI

    联系我们
    在线支持
    获取专业技术支持,快速帮助您解决问题
    工作日9:00-12:00,13:30-17:30在线
    页面反馈
    针对当前网页的建议、问题反馈
    售前咨询
    采购需求/获取报价/预约演示
    或拨打: 400-811-8890 转1
    qr
    热线电话
    咨询/故障救援热线:400-811-8890转2
    总裁办24H投诉:17312781526
    提交页面反馈
    仅适用于当前网页的意见收集,帆软产品问题请在 问答板块提问前往服务平台 获取技术支持