自定义分布式消息服务MQTT事件源
更新时间 2025-06-18 17:55:20
最近更新时间: 2025-06-18 17:55:20
本文介绍如何在事件总线EventBridge管理控制台添加分布式消息服务MQTT类型的自定义事件源。
前提条件
事件总线EventBridge
分布式消息服务MQTT
开通分布式消息服务MQTT并创建实例。
操作步骤
登录事件总线管理控制台。
在左侧导航栏,单击事件总线。
在事件总线页面,单击目标总线名称。
在左侧导航栏,单击事件源。
在事件源页面,单击添加事件源。
在添加自定义事件源面板,输入名称和描述,事件提供方选择分布式消息服务MQTT,选择或填入主题等配置然后单击确认,如图1所示。
图1 创建事件源时事件提供方选择分布式服务MQTT
参数说明
参数 | 说明 | 示例 |
---|---|---|
名称 | 事件源名。 | test |
MQTT实例 | 选择MQTT实例。 | instance-xxx |
MQTT主题 | 选择或输入MQTT的主题。 | topic-xxx |
事件示例
{
"id": "b5771f76-6cdf-48ed-b1ba-d15418c*****",
"source": "source_test",
"specversion": "1.0",
"subject": "ctyun:mqtt:region-code-xxx:1******6789:topic/topic-test",
"time": "2024-03-05T13:52:18.374Z",
"datacontenttype": "application/json;charset=utf-8",
"type": "mqtt:Topic:SendMessage",
"ctyunregion": "bb9fdb4205xxxxxxxxx0242ac110002",
"ctyunaccountid": "123456789****",
"data": {
"body": {
"key": "value"
},
"props": {
"topic": "topic-test"
}
}
}
data字段包含的参数解释如下表所示:
参数 | 类型 | 示例值 | 描述 |
---|---|---|---|
props | Object |
| 消息属性。 |
body | Object |
| 消息体,默认以JSON格式编码。 |