全部產品
Search
文件中心

EventBridge:路由到Simple Message Queue (formerly MNS)

更新時間:May 08, 2026

本文介紹如何在事件匯流排EventBridge控制台添加輕量訊息佇列(原 MNS)作為事件流中的服務類型。

前提條件

建立事件流

  1. 登入事件匯流排EventBridge控制台,在左側導覽列,單擊事件流。
  2. 在頂部功能表列,選擇地區,然後單擊建立事件流。
  3. 在创建事件流面板,設定任务名称和描述,配置以下參數,然後單擊保存。

    • 任務建立

      1. 在Source(源)、Filtering(过滤)、Transform(转换)設定精靈,設定事件過濾、轉換規則,單擊下一步。事件轉換的配置說明,請參見使用Function Compute實現訊息資料清洗。

      2. 在Sink(目标)設定精靈,選擇服务类型為Simple Message Queue (formerly 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****"
    }