創建事件流

1. 登錄事件總線EventBridge控制臺，在左側導航欄，單擊事件流。
2. 在頂部菜單欄，選擇地域，然后單擊創建事件流。

3. 在創建事件流面板，設置任務名稱和描述，配置以下參數，然后單擊保存。

   • 任務創建

     1. 在Source（源）、Filtering（過濾）、Transform（轉換）配置向導，設置事件過濾、轉換規則，單擊下一步。事件轉換的配置說明，請參見使用函數計算實現消息數據清洗。

     2. 在Sink（目標）配置向導，選擇服務類型為輕量消息隊列（原 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****"
   }