云消息队列 RocketMQ 版
更新时间:
本文介绍如何在云消息队列 RabbitMQ 版控制台创建消息流出任务,将云消息队列 RabbitMQ 版的数据导出至云消息队列 RocketMQ 版。
前提条件
创建消息流出任务
登录云消息队列 RabbitMQ 版控制台,然后左侧导航栏选择 。
在顶部菜单栏选择地域,如华东1(杭州),然后在消息流出页面,单击创建任务。
- 在消息流出创建面板,设置任务名称,选择流出类型为消息队列 RocketMQ版,配置以下信息,然后单击确定。
- 在资源配置区域,设置以下参数。
表 1. 源端消息队列RabbitMQ版参数配置 参数 说明 示例 地域 默认选择创建消息流出任务时选择的地域且不可更改。 华东1(杭州) RabbitMQ 实例 选择生产消息的源云消息队列 RabbitMQ 版实例。 amqp-cn-******lpc00a Vhost 选择源云消息队列 RabbitMQ 版实例的Vhost。 test Queue 选择源云消息队列 RabbitMQ 版实例的Vhost。 queue_test 表 2. 目标端消息队列RocketMQ版参数配置 参数 说明 示例 版本 选择云消息队列 RocketMQ 版实例的版本。 - RocketMQ 4.x:服务端4.x版本。
- RocketMQ 5.x:服务端5.x版本。
RocketMQ5.x 实例ID 选择接收源端数据的目标云消息队列 RocketMQ 版实例ID。 MQ_INST_115964845466****_BYEiGXc4 Topic 选择目标实例的Topic。 test - 在数据处理区域,设置消息的过滤、转换、重试和死信。
- 消息过滤
- 无需过滤:默认投递全部事件。
- 自定义配置:使用事件模式匹配特定事件。详细规则,请参见消息过滤。
- 消息转换
- 默认配置:默认将消息内容或相关属性映射到目标端。映射关系,请参见默认配置映射关系。
- 自定义配置:根据自身需求配置自定义参数投递至目标端。
参数 说明 示例 Body 需要投递的事件的消息内容。配置规则,请参见消息转换。 部分事件 $.data.body
Properties 需要投递的事件的属性。配置规则,请参见消息转换。 模板 // 变量 { "userProperties":"$.data.userProperties", "msgId":"$.data.systemProperties.UNIQ_KEY" } // 模板 { "EB_SYS_EMBED_OBJECT":"${userProperties}", "UNIQ_KEY":"${msgId}" }
Keys 需要投递的事件的过滤属性。配置规则,请参见消息转换。 部分事件 $.data.systemProperties.KEYS
Tags 需要投递的事件的过滤属性。配置规则,请参见消息转换。 部分事件 $.data.systemProperties.TAGS
- 重试和死信:配置事件推送失败时的重试策略及错误发生时的处理方式。更多信息,请参见重试和死信。
- 消息过滤
- 在资源配置区域,设置以下参数。
其他操作
在消息流出页面,找到目标任务,在其右侧操作列,执行其他操作。
- 查看任务详情:单击详情,在消息流出详情页面,查看任务的源端配置、目标端配置及资源信息。
- 编辑任务配置:单击编辑,在消息流出编辑面板,修改资源配置和规则配置。
- 启停任务:单击启用或者停用,然后在提示对话框,单击确认。
- 删除任务:单击删除,然后在提示对话框,单击确认。
文档内容是否对您有帮助?