分布式消息服務MQTT事件源
更新時間 2025-06-18 17:55:22
最近更新時間: 2025-06-18 17:55:22
分享文章
本文介紹如何在事件總線EventBridge控制臺添加分布式消息服務MQTT作為事件流中的事件提供方。
前提條件
事件總線EventBridge
分布式消息服務MQTT
開通分布式消息服務MQTT。
操作步驟
登錄事件總線控制臺。
在左側導航欄,單擊事件流。
在事件流頁面,單擊創建事件流。
在事件源(Source)配置面板,事件提供方選擇分布式消息MQTT,選擇或填入主題等配置然后單擊確認,如圖1所示。
圖1 創建事件流時分布式消息服務MQTT作為流的事件提供方
參數說明
| 參數 | 說明 | 示例 |
|---|---|---|
| MQTT實例 | 選擇MQTT實例。 | instance-xxx |
| MQTT主題 | 選擇或輸入MQTT的主題。 | topic-xxx |
事件示例
{
"id":"b5771f76-6cdf-48ed-b1ba-d15418c*****",
"source":"ctyun:mqtt",
"specversion":"1.0",
"type":"mqtt:Topic:SendMessage",
"subject":"ctyun:mqtt:bb9fdb42***********1610242ac110002:1******6789:topic/topic-test",
"time":"2024-03-05T13:52:18.374Z",
"datacontenttype":"application/json;charset=utf-8",
"data":{
"body":{
"key": "value"
},
"props": {
"topic": "topic-test"
}
},
"ctyunaccountid":"1******6789",
"ctyuneventbusname":"my-bus",
"ctyunregion":"bb9fdb42***********1610242ac110002",
}data字段包含的參數解釋如下表所示。
| 參數 | 類型 | 示例值 | 描述 |
|---|---|---|---|
| props | Object | {"topic":"topic-test"} | 消息屬性。 |
| body | Object | {"key":"value"} | 消息體,默認以JSON格式編碼。 |