分布式消息服务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格式编码。 |