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

操作步骤

  1. 登录事件总线EventBridge控制台
  2. 在左侧导航栏,单击事件总线
  3. 在顶部菜单栏,选择地域。
  4. 事件总线页面,单击目标总线名称。
  5. 在左侧导航栏,单击事件源
  6. 事件源页面,单击添加事件源
  7. 添加自定义事件源面板,输入名称描述事件提供方选择消息队列RocketMQ版,配置以下参数,然后单击确定
    • 地域:选择已创建的消息队列RocketMQ版实例所在的地域。
    • RocketMQ 实例:选择已创建的消息队列RocketMQ版实例。
    • Topic:选择已创建的Topic。
    • (可选)Tag:输入过滤标签。
    • Group ID:选择已创建的Group ID。
      说明 一个Group对应一类业务消息。因此,新增自定义事件源消息队列RocketMQ版时,请确保不要与已有业务共用同一个Group ID。
    • 消费位点:选择消费位点,默认为最新位点。

事件示例

{
    "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
    "source":"acs:mq",
    "specversion":"1.0",
    "type":"mq:Topic:SendMessage",
    "datacontenttype":"application/json; charset=utf-8",
    "subject":"acs:mq:cn-hangzhou:123456789098****:MQ_INST_123456789098****_BXhFHryi%TopicName",
    "time":"2021-04-08T06:01:20.766Z",
    "aliyunpublishtime":"2021-04-08T06:01:20.725Z",
    "aliyuneventbusname":"BusName",
    "data":{
        "topic":"TopicName",
        "systemProperties":{
            "MIN_OFFSET":"0",
            "TRACE_ON":"true",
            "MAX_OFFSET":"8",
            "MSG_REGION":"cn-hangzhou",
            "KEYS":"systemProperties.KEYS",
            "CONSUME_START_TIME":1628577790396,
            "UNIQ_KEY":"AC14C305069E1B28CDFA3181CDA2****",
            "TAGS":"systemProperties.TAGS",
            "INSTANCE_ID":"MQ_INST_123456789098****_BXhFHryi"
        },
        "userProperties":{
        },
        "body":"TEST"
    }
}

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

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

参数 类型 示例值 描述
topic String TopicName Topic名称。
systemProperties Map 系统属性。
MIN_OFFSET Int 0 最低位点。
TRACE_ON Boolean true 是否有消息轨迹。取值说明如下:
  • true:有消息轨迹。
  • false:无消息轨迹。
MAX_OFFSET Int 8 最高位点。
MSG_REGION String cn-hangzhou 发送消息的地域。
KEYS String systemProperties.KEYS 过滤属性。
CONSUME_START_TIME Long 1628577790396 开始消费时间。单位:毫秒。
UNIQ_KEY String AC14C305069E1B28CDFA3181CDA2**** 消息唯一键。
TAGS String systemProperties.TAGS 过滤属性。
INSTANCE_ID String MQ_INST_123456789098****_BXhFHryi 实例ID。
userProperties Map 用户属性。
body String TEST 消息内容。