应用与数据集成平台 ROMA CONNECT-配置目标端数据信息:RocketMQ

时间:2024-11-08 14:31:36

RocketMQ

返回页首

任务的“集成模式”为“定时”或“实时”时,可以选择RocketMQ作为目标端数据源。

  1. 在创建任务页面中配置目标端信息。
    表25 目标端RocketMQ信息

    参数

    配置说明

    目标端实例

    配置为当前正在使用的ROMA Connect实例,源端实例配置后目标端自动关联,无需配置。

    目标端集成应用

    选择RocketMQ数据源所属的集成应用,在接入数据源时已配置。

    目标端数据类型

    选择“RocketMQ”。

    数据源名称

    选择接入数据源中已配置的RocketMQ数据源。

    Topic

    主题字符串/队列名称.

    元数据

    定义写入到目标端的JSON格式数据中,每一个底层key-value型数据元素。源端有多少个字段需要集成,则目标端需要定义相同个数的元数据。

    • 别名:对元数据的自定义名称。
    • 类型:元数据的数据类型,需要与源端数据中对应字段的数据类型一致。
    • 解析路径:元数据的完整路径,具体请参见元数据解析路径配置说明

    元数据解析路径配置说明:

    • JSON格式数据中不含数组

      如以下写入目标端的JSON格式数据,元素a的完整路径定义为a,元素b的完整路径为a.b,元素c的完整路径为a.b.c,元素d的完整路径为a.b.d,元素c和d为底层数据元素。

      此场景下,元素c的解析路径需要设置为a.b.c,元素d的解析路径需设置为a.b.d

      {
         "a": {
            "b": {
               "c": "xx",
               "d": "xx"
            }
         }
      }
    • JSON格式数据中含数组

      如以下写入目标端的JSON格式数据,元素a的完整路径定义为a,元素b的完整路径为a.b,元素c的完整路径为a.b[i].c,元素d的完整路径为a.b[i].d。元素c和d为底层数据元素。

      此场景下,元素c的解析路径需要设置为a.b[i].c,元素d的解析路径需设置为a.b[i].d

      {
         "a": {
            "b": [{
               "c": "xx",
               "d": "xx"
            },
            {
               "c": "yy",
               "d": "yy"
            }
            ]
         }
      }

    目标端为RocketMQ的配置示例如下图所示。

    图11 RocketMQ配置示例
  2. 完成目标端信息配置后,继续进行下一部分配置,配置数据映射规则
support.huaweicloud.com/usermanual-roma/fdi-ug-190624007.html