本文介绍如何在事件总线EventBridge控制台添加消息服务MNS作为事件流中的服务类型。
创建事件流
- 登录事件总线EventBridge控制台,在左侧导航栏,单击事件流。
- 在顶部菜单栏,选择地域,然后单击创建事件流。
- 在创建事件流面板,配置以下参数,然后单击创建。
- 在基本信息页签,设置事件流名称和描述,单击下一步。
- 在事件源页签和规则页签,设置事件源和事件规则,然后单击下一步。
- 在目标页签,选择服务类型为消息服务 MNS,设置以下参数,然后单击创建。
参数 |
说明 |
示例 |
队列名称 |
选择已创建的消息服务MNS队列。
|
test |
开启 Base64 编码 |
选择是否开启Base64编码,如不开启,会导致接收到的消息为乱码。 |
是 |
消息内容 |
选择事件内容转换类型。更多信息,请参考事件内容转换。
|
完整事件 |
- 返回事件流页面,找到创建好的事件流,在其右侧操作栏,单击启用。
启用事件流后,会有30秒~60秒的延迟时间,您可以在事件流页面的状态栏查看启动进度。
结果验证
您可以在消息服务MNS控制台确认是否接收到事件。
- 登录消息服务MNS控制台,在左侧导航栏,单击队列列表。
- 在顶部菜单栏,选择地域。
- 在队列列表页面,找到目标队列,在其右侧操作列选择。
- 在队列收发消息快速体验页面的接收消息区域,单击接收消息。
接收到的示例消息内容如下所示。
{
"data":{
"props":{
"firstTopic":"topci12****",
"secondTopic":"",
"clientId":"GID_MQTT_CONSOLE@@@lmqhb1share01vpc165759566****"
},
"body":"Hello World"
},
"id":"AC11C08E76C67E7740853B0F604D****",
"source":"acs:mqtt",
"specversion":"1.0",
"type":"mqtt:Topic:SendMessage",
"datacontenttype":"application/json; charset\u003dutf-8",
"time":"2022-07-12T03:14:23.447Z",
"subject":"acs:mq:cn-qingdao:182572506381****:topic/mqtt-cn-2r42rdr****/topci12****",
"aliyunaccountid":"182572506381****"
}