本文介绍如何在事件总线EventBridge控制台添加消息队列RabbitMQ版作为事件流中的事件提供方。
前提条件
- 开通事件总线EventBridge并授权。
- 您已购买并部署消息队列RabbitMQ版实例,且实例处于服务中状态。具体步骤,请参见创建资源。
操作步骤
- 登录事件总线EventBridge控制台,在左侧导航栏,单击事件流。
- 在顶部菜单栏,选择地域,然后单击创建事件流。
- 在创建事件流面板,配置以下参数,然后单击创建。
事件示例
{
"specversion":"1.0",
"id":"8b09e19b-8cbd-4c46-ab77-9cc39c44****",
"source":"housekeeping.rabbitmq",
"type":"amqp:Queue:SendMessage",
"subject":"acs:amqp:cn-hangzhou:143998900779****:/instances/amqp-cn-zvp2av0m****/vhosts/eb-connect/queues/housekeeping",
"datacontenttype":"application/json;charset=utf-8",
"aliyunaccountid":"143998900779****",
"aliyunoriginalaccountid":"143998900779****",
"aliyunpublishtime":"2021-08-12T06:56:50.783Z",
"aliyuneventbusname":"Housekeeping-Connect",
"time":"2021-08-12T06:56:40.709Z",
"aliyunregionid":"cn-hangzhou",
"data":{
"envelope":{
"deliveryTag":98,
"exchange":"amq.direct",
"redeliver":false,
"routingKey":"housekeeping"
},
"body":{
"Hello":"EventBridge"
},
"props":{
"contentEncoding":"UTF-8",
"messageId":"f7622d51-e198-41de-a072-77c1ead7****"
}
}
}
CloudEvents规范中定义的参数解释,请参见事件概述。
data字段包含的参数解释如下表所示。
参数 | 类型 | 示例 | 描述 |
---|---|---|---|
envelope | Map | 消息中的envelope信息。 | |
deliveryTag | Int | 98 | 消息的Tag。 |
exchange | String | amq.direct | 消息的Exchange。 |
redeliver | Boolean | false | 是否支持重发消息。取值说明如下:
|
routingKey | String | housekeeping | 消息的路由规则。 |
body | Map | 消息内容。 | |
Hello | String | EventBridge | 用户数据。 |
props | Map | 消息属性。 | |
contentEncoding | String | UTF-8 | 消息内容编码。 |
messageId | String | f7622d51-e198-41de-a072-77c1ead7**** | 消息ID。每条消息的ID取值唯一。 |