本文介绍如何在云消息队列 RocketMQ 版控制台创建流出目标为云消息队列 RabbitMQ 版的消息流出任务。
前提条件
- 您已购买云消息队列 RocketMQ 版实例,且实例处于服务中状态。具体步骤,请参见创建资源。
- 您已购买并部署云消息队列 RabbitMQ 版实例,且实例处于服务中状态。具体步骤,请参见创建资源。
创建消息流出任务
- 登录云消息队列 RocketMQ 版控制台,在左侧导航栏选择。
- 在顶部菜单栏选择地域,如华东1(杭州),然后在消息流出页面中,单击创建任务。
- 在消息流出创建面板,设置任务名称,选择流出类型为消息队列 RabbitMQ版,配置以下信息,然后单击确定。
- 在资源配置页签,设置以下参数。
表 1. 源端消息队列RocketMQ版参数配置参数 | 说明 | 示例 |
---|
地域 | 默认选择创建消息流出任务时选择的地域且不可更改。 | 华东1(杭州) |
RocketMQ 实例 | 选择生产消息的源云消息队列 RocketMQ 版实例。 | MQ_INST_115964845466****_ByBeUp3p |
Topic | 选择生产消息的Topic。 | topic |
Group ID | 选择源实例中的消费组名称。请使用独立的消费组来创建事件源,不要和已有的业务混用消费组,以免影响已有的消息收发。 | GID_http_1 |
消费位点 | 选择开始消费消息的位点。 | 最新位点 |
表 2. 目标端消息队列RabbitMQ版参数配置参数 | 说明 | 示例 |
---|
实例ID | 选择接收源端消息的目标云消息队列 RabbitMQ 版实例。 | amqp-cn-i7m2slrc**** |
Vhost | 选择目标实例的Vhost。 | vhost |
- 在数据处理区域,设置消息的过滤、转换、重试和死信。
- 消息过滤
- 无需过滤:默认投递全部事件。
- 自定义配置:使用事件模式匹配特定事件。详细规则,请参见消息过滤。
- 消息转换
- 默认配置:默认将消息内容或相关属性映射到目标端。映射关系,请参见默认配置映射关系。
- 自定义配置:根据自身需求配置自定义参数投递至目标端。
参数 | 说明 | 示例 |
---|
目标类型 | - Exchange 模式:生产者将消息发送到Exchange,由Exchange将消息路由到一个或多个Queue中。
- Queue 模式:每个消息都会被投入到一个或多个Queue里。
| Queue 模式 |
Exchange | 选择目标云消息队列 RabbitMQ 版实例中的Exchange。仅当目标类型参数配置为Exchange 模式时需要配置该参数。 | amq.direct |
Queue | 选择目标云消息队列 RabbitMQ 版实例中的队列。仅当目标类型参数配置为Queue 模式时需要配置该参数。 | queue |
Routing Key | 路由消息规则。 | |
Body | 需要投递的事件的消息内容。配置规则,请参见消息转换。 | 部分事件$.data.body
|
MessageId | 需要投递的消息ID。配置规则,请参见消息转换。 | 部分事件$.data.props.messageId
|
Properties | 需要投递的事件的属性。配置规则,请参见消息转换。 | 部分事件$.data.props
|
- 重试和死信:配置事件推送失败时的重试策略及错误发生时的处理方式。更多信息,请参见重试和死信。
其他操作
在消息流出页面,找到目标任务,在其右侧操作列,执行其他操作。
- 查看任务详情:单击详情,在消息流出详情页面,查看任务的源端配置、目标端配置及资源信息。
- 编辑任务配置:单击编辑,在消息流出编辑面板,修改资源配置和规则配置。
- 启停任务:单击启用或者停用,然后在提示对话框,单击确认。
- 删除任务:单击删除,然后在提示对话框,单击确认。