本文介绍如何在事件总线EventBridge控制台添加云消息队列 RabbitMQ 版作为事件流中的服务类型。
前提条件
您已购买并部署云消息队列 RabbitMQ 版实例,且实例处于服务中状态。具体步骤,请参见步骤一:创建资源。
创建事件流
- 登录事件总线EventBridge控制台,在左侧导航栏,单击事件流。
- 在顶部菜单栏,选择地域,然后单击创建事件流。
在创建事件流面板,设置任务名称和描述,配置以下参数,然后单击保存。
任务创建
在Source(源)、Filtering(过滤)、Transform(转换)配置向导,设置事件过滤、转换规则,单击下一步。事件转换的配置说明,请参见使用函数计算实现消息数据清洗。
在Sink(目标)配置向导,选择服务类型为消息队列RabbitMQ版,配置以下参数。
参数
说明
示例
实例ID
选择已创建的云消息队列 RabbitMQ 版实例。
amqp-cn-zvp2pny6****
Vhost
选择已创建的Vhost。
test
目标类型
Exchange:生产者将消息发送到Exchange,由Exchange将消息路由到一个或多个Queue中。
Queue:每个消息都会被投入到一个或多个Queue里。
Queue 模式
Exchange
当目标类型为Exchange时,选择云消息队列 RabbitMQ 版中的Exchange。
exchange
Queue
当目标类型为Queue时,选择云消息队列 RabbitMQ 版中的选择接收消息的队列。
queue
消息路由规则(Routing Key)
事件总线EventBridge通过JSONPath提取事件中的数据,将指定的事件内容路由到事件目标。当目标类型为Exchange时需要配置。
部分事件
$.data.key
消息体(body)
事件总线EventBridge通过JSONPath提取事件中的数据,将指定的事件内容路由到事件目标。
部分事件
$.data.body
MessageId
事件总线EventBridge通过JSONPath提取事件中的数据,将指定的事件内容路由到事件目标。
部分事件
$.data.props.messageId
自定义属性(Properties)
事件总线EventBridge通过JSONPath提取事件中的数据,将指定的事件内容路由到事件目标。
部分事件
$.data.props
任务属性
设置事件流的重试策略及死信队列。更多信息,请参见重试和死信。
返回事件流页面,找到创建好的事件流,在其右侧操作栏,单击启用。
启用事件流后,会有30秒~60秒的延迟时间,您可以在事件流页面的状态栏查看启动进度。
结果验证
登录云消息队列 RabbitMQ 版控制台,在概览页面的资源分布区域,选择地域。
在实例列表页面,单击目标实例名称。
在实例详情页面的基本信息区域,单击消息查询。
在消息查询页面,选择查询方式为按 Queue 查询,设置时间范围,然后单击查询。