本文介紹如何在事件總線EventBridge管理控制臺中添加分布式消息服務RocketMQ類型的自定義事件源。

前提條件

事件總線EventBridge

• 開通事件總線EventBridge并委托授權。

• 創建自定義總線。

分布式消息服務RocketMQ

• 開通分布式消息服務RocketMQ。

• 創建實例，并創建對應主題與消費組。

操作步驟

1. 登錄事件總線管理控制臺。

2. 在左側導航欄，單擊事件總線。

3. 在事件總線頁面，單擊目標總線名稱。

4. 在左側導航欄，單擊事件源。

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

6. 在添加自定義事件源面板，輸入名稱和描述，事件提供方選擇分布式消息服務RocketMQ，選擇實例、主題等配置然后單擊確認，如圖1所示。

   

   圖1 創建事件源時事件提供方選擇分布式消息服務RocketMQ

參數說明

事件示例

{
    "id": "210018FC0EE205EF04B51CF068350066",
    "source": "source_test",
    "specversion": "1.0",
    "subject": "ctyun:rocketmq:0023exxxxxxxc9e11818c12938140:topic:source2",
    "time": "2024-12-06T06:51:57.3695504Z",
    "datacontenttype": "application/json",
    "type": "rocketmq:Topic:SendMessage",
    "ctyunregion": "b342b77ef2xxxxxxx0242ac110002",
    "ctyunaccountid": "0023e4d7exxxxxxxxxx18c12938140",
    "data": {
        "systemProperties": {
            "MIN_OFFSET": "0",
            "MAX_OFFSET": "1",
            "KEYS": "webtest",
            "CONSUME_START_TIME": "1733467917369",
            "CLUSTER": "16e0eef12f83485dbba23a0750ec5078",
            "UNIQ_KEY": "210018FC0EE205EF04B51CF068350066",
            "TAGS": "1733467917351_0"
        },
        "userProperties": {
            "MIN_OFFSET": "0",
            "MAX_OFFSET": "1",
            "KEYS": "webtest",
            "CONSUME_START_TIME": "1733467917369",
            "CLUSTER": "16e0eef12f83485dbba23a0750ec5078",
            "UNIQ_KEY": "210018FC0EE205EF04B51CF068350066",
            "TAGS": "1733467917351_0"
        },
        "topic": "source2",
        "msgId": "210018FC0EE205EF04B51CF068350066",
        "body": "WebsFjDDxPd503bG60bNdaT0qMrsjt5evXd9df"
    }
}

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

data字段中properties屬性的參數解釋如下圖所示：