文档

路由到轻量消息队列(原 MNS) SMQ(Simple Message Queue (formerly MNS))MNS

更新时间:

本文介绍如何在事件总线EventBridge控制台添加轻量消息队列(原 MNS)作为事件流中的服务类型。

前提条件

创建事件流

  1. 登录事件总线EventBridge控制台,在左侧导航栏,单击事件流
  2. 在顶部菜单栏,选择地域,然后单击创建事件流
  3. 创建事件流面板,设置任务名称描述,配置以下参数,然后单击保存

    • 任务创建

      1. Source(源)Filtering(过滤)Transform(转换)配置向导,设置事件过滤、转换规则,单击下一步。事件转换的配置说明,请参见使用函数计算实现消息数据清洗

      2. Sink(目标)配置向导,选择服务类型轻量消息队列(原 MNS) SMQ(Simple Message Queue (formerly MNS))MNS,配置以下参数。

        参数

        说明

        示例

        队列名称

        选择已创建的轻量消息队列(原 MNS)队列。

        test

        开启 Base64 编码

        选择是否开启Base64编码,如不开启,会导致接收到的消息为乱码。

        消息体(body)

        选择事件内容转换类型。更多信息,请参考事件内容转换

        完整事件

    • 任务属性

      设置事件流的重试策略及死信队列。更多信息,请参见重试和死信

  4. 返回事件流页面,找到创建好的事件流,在其右侧操作栏,单击启用

    启用事件流后,会有30秒~60秒的延迟时间,您可以在事件流页面的状态栏查看启动进度。

结果验证

您可以在轻量消息队列(原 MNS)控制台确认是否接收到事件。

  1. 登录轻量消息队列(原 MNS)控制台,在左侧导航栏,单击队列列表

  2. 在顶部菜单栏,选择地域。

  3. 队列列表页面,找到目标队列,在其右侧操作列选择更多 > 收发消息

  4. 队列收发消息快速体验页面的接收消息区域,单击接收消息

    接收到的示例消息内容如下所示。

    {
        "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****"
    }