事件匯流排EventBridge支援接入雲訊息佇列 RocketMQ 版的訊息,進行事件分析、查看事件軌跡、進行資料轉寄等操作。本文介紹如何在事件匯流排EventBridge控制台添加雲訊息佇列 RocketMQ 版類型的自訂事件來源。
前提條件
雲訊息佇列 RocketMQ 版
事件匯流排EventBridge
操作步驟
- 登入事件匯流排EventBridge控制台。
- 在左側導覽列,單擊事件匯流排。
- 在頂部功能表列,選擇地區。
- 在事件匯流排頁面,單擊目標匯流排名稱。
- 在左側導覽列,單擊事件來源。
在事件源頁面,單擊添加事件源。
在添加自定义事件源面板,輸入名称和描述,事件提供方選擇消息队列 RocketMQ 版,配置以下參數,然後單擊确认。
地域:選擇已建立的雲訊息佇列 RocketMQ 版執行個體所在的地區。
版本:選擇RocketMQ 4.x或者RocketMQ 5.x。
RocketMQ 实例:選擇已建立的雲訊息佇列 RocketMQ 版執行個體。
Topic:選擇已建立的Topic。
(可選)Tag:輸入過濾標籤。
Group ID:選擇已建立的Group ID。
說明一個Group對應一類業務訊息。請確保不同的事件來源使用獨立的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 | 是否有訊息軌跡。取值說明如下:
|
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 | 訊息內容。 |