应用与数据集成平台 ROMA CONNECT-配置目标端数据信息:RocketMQ
RocketMQ
返回页首
任务的“集成模式”为“定时”或“实时”时,可以选择RocketMQ作为目标端数据源。
- 在创建任务页面中配置目标端信息。
表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配置示例
- 完成目标端信息配置后,继续进行下一部分配置,配置数据映射规则。
- 华为云资料 2021年 7月刊
- RocketMQ是什么_RocketMQ介绍_分布式消息服务RocketMQ版
- RocketMQ的架构_RocketMQ的消息模式_分布式消息RocketMQ-华为云
- 分布式消息服务Kafka版与分布式消息服务RocketMQ版的区别_Kafka与RocketMQ对比_Kafka与RocketMQ差异
- 分布式消息中间件实战_分布式消息实战_分布式消息-华为云
- 分布式消息中间件的作用_分布式消息中间件_分布式消息-华为云
- kafka是什么_kafka介绍_分布式消息服务Kafka版
- 分布式消息队列是什么_分布式消息队列好处_消息队列-华为云
- RocketMQ主要应用场景有哪些_分布式消息中间件_分布式消息RocketMQ-华为云
- 分布式消息服务有哪些_分布式消息服务哪个好_分布式消息-华为云