自定义事件源消息队列RabbitMQ版

本文介绍如何在事件总线EventBridge控制台添加云消息队列 RabbitMQ 版类型的自定义事件源。

前提条件

注意事项

支持自定义事件源云消息队列 RabbitMQ 版的地域以事件总线EventBridge控制台开服的地域为准。

操作步骤

  1. 登录事件总线EventBridge控制台
  2. 在左侧导航栏,单击事件总线
  3. 在顶部菜单栏,选择地域。
  4. 事件总线页面,单击目标总线名称。
  5. 在左侧导航栏,单击事件源
  6. 事件源页面,单击添加事件源

  7. 添加自定义事件源面板,输入名称描述事件提供方选择消息队列 RabbitMQ 版,配置以下参数,然后单击确认

    • 地域:选择已创建的云消息队列 RabbitMQ 版实例所在的地域。

    • RabbitMQ 实例:选择已创建的云消息队列 RabbitMQ 版实例。

    • Vhost:选择已创建的Vhost。

    • Queue:选择已创建的Queue。

事件示例

{
    "datacontenttype":"application/json;charset=utf-8",
    "aliyunaccountid":"143998900779****",
    "data":{
        "envelope":{
            "deliveryTag":98,
            "exchange":"",
            "redeliver":false,
            "routingKey":"housekeeping"
        },
        "body":{
            "Hello":"EventBridge"
        },
        "props":{
            "contentEncoding":"UTF-8",
            "messageId":"f7622d51-e198-41de-a072-77c1ead7****"
        }
    },
    "subject":"acs:amqp:cn-hangzhou:143998900779****:/instances/amqp-cn-zvp2av0m****/vhosts/eb-connect/queues/housekeeping",
    "aliyunoriginalaccountid":"143998900779****",
    "source":"housekeeping.rabbitmq",
    "type":"amqp:Queue:SendMessage",
    "aliyunpublishtime":"2021-08-12T06:56:50.783Z",
    "specversion":"1.0",
    "aliyuneventbusname":"Housekeeping-Connect",
    "id":"8b09e19b-8cbd-4c46-ab77-9cc39c44****",
    "time":"2021-08-12T06:56:40.709Z",
    "aliyunregionid":"cn-hangzhou"
}

CloudEvents规范中定义的参数解释,请参见事件概述

data字段包含的参数解释如下表所示。

参数

类型

示例值

描述

body

Map

消息内容。

Hello

String

EventBridge

用户数据。

props

Map

消息属性。

contentEncoding

String

utf-8

消息内容编码。

messageId

String

f7622d51-e198-41de-a072-77c1ead7****

消息ID。每条消息的ID取值唯一。

envelope

Map

消息的envelope信息。

deliveryTag

Int

98

消息的Tag。

exchange

String

消息的Exchange。

redeliver

Boolean

false

是否支持重发消息。取值说明如下:

  • true:支持

  • false:不支持

routingKey

String

housekeeping

消息的路由规则。