本文介绍如何在事件总线EventBridge控制台添加轻量消息队列(原 MNS)作为事件流中的服务类型。
前提条件
创建事件流
- 登录事件总线EventBridge控制台,在左侧导航栏,单击事件流。
- 在顶部菜单栏,选择地域,然后单击创建事件流。
在创建事件流面板,设置任务名称和描述,配置以下参数,然后单击保存。
任务创建
在Source(源)、Filtering(过滤)、Transform(转换)配置向导,设置事件过滤、转换规则,单击下一步。事件转换的配置说明,请参见使用函数计算实现消息数据清洗。
在Sink(目标)配置向导,选择服务类型为轻量消息队列(原 MNS) SMQ(Simple Message Queue (formerly MNS))MNS,配置以下参数。
参数
说明
示例
队列名称
选择已创建的轻量消息队列(原 MNS)队列。
test
开启 Base64 编码
选择是否开启Base64编码,如不开启,会导致接收到的消息为乱码。
是
消息体(body)
选择事件内容转换类型。更多信息,请参考事件内容转换。
完整事件
任务属性
设置事件流的重试策略及死信队列。更多信息,请参见重试和死信。
返回事件流页面,找到创建好的事件流,在其右侧操作栏,单击启用。
启用事件流后,会有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****" }
文档内容是否对您有帮助?