操作步驟

1. 登錄事件總線EventBridge控制臺。
2. 在左側(cè)導(dǎo)航欄，單擊事件總線。
3. 在頂部菜單欄，選擇地域。
4. 在事件總線頁面，單擊目標(biāo)總線名稱。
5. 在左側(cè)導(dǎo)航欄，單擊事件源。

6. 在事件源頁面，單擊添加事件源。

7. 在添加自定義事件源面板，輸入名稱和描述，事件提供方選擇消息隊列 RocketMQ 版，配置以下參數(shù)，然后單擊確認(rèn)。

   • 地域：選擇已創(chuàng)建的云消息隊列 RocketMQ 版實例所在的地域。

   • 版本：選擇RocketMQ 4.x或者RocketMQ 5.x。

   • RocketMQ 實例：選擇已創(chuàng)建的云消息隊列 RocketMQ 版實例。

   • Topic：選擇已創(chuàng)建的Topic。

   • （可選）Tag：輸入過濾標(biāo)簽。

   • Group ID：選擇已創(chuàng)建的Group ID。

     說明

     一個Group對應(yīng)一類業(yè)務(wù)消息。請確保不同的事件源使用獨立的Group ID，且不要與已有業(yè)務(wù)共用。

   • 消費位點：選擇消費位點，默認(rèn)為最新位點。

事件示例

{
    "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規(guī)范中定義的參數(shù)解釋，請參見事件概述。

data字段包含的參數(shù)解釋如下表所示。