EventBridge：雲Message QueueTT 版

操作步驟

1. 登入事件匯流排EventBridge控制台，在左側導覽列，單擊事件流。
2. 在頂部功能表列，選擇地區，然後單擊建立事件流。

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

   • 任務建立

     1. 在Source（源）設定精靈，選擇資料提供方為Message QueueTT版，配置以下參數，然後單擊下一步。

        參數	說明	樣本
        MQTT 实例	選擇MQTT執行個體。	test-instance
        MQTT Topic	選擇MQTT執行個體中的Topic。	test-topic
        批量推送	批量推送可幫您批量彙總多個事件，當批量推送条数和批量推送间隔（单位：秒）兩者條件達到其一時即會觸發批量推送。 例如：您設定的推送條數為100 條，間隔時間為15 s，在10 s內訊息條數已達到100條，那麼該次推送則不會等15 s後再推送。	開啟
        批量推送条数	調用函數發送的最大批量訊息條數，當積壓的訊息數量到達設定值時才會發送請求，取值範圍為 [1,10000]。	100
        批量推送间隔（单位：秒）	調用函數的間隔時間，系統每到間隔時間點會將訊息彙總後發給Function Compute，取值範圍為[0,15]，單位為秒。0秒錶示無等待時間，直接投遞。	3

     2. 在Filtering（過濾）、Transform（轉換）及Sink（目標）設定精靈，設定事件過濾、轉換規則及事件目標。事件轉換的配置說明，請參見使用Function Compute實現訊息資料清洗。

   • 任務屬性

     設定事件流的重試策略及無效信件佇列。更多資訊，請參見重試和死信。

4. 返回事件流頁面，找到建立好的事件流，在其右側操作欄，單擊啟用。

   啟用事件流後，會有30秒~60秒的延遲時間，您可以在事件流頁面的狀態欄查看啟動進度。

事件樣本

{
    "specversion":"1.0",
    "id":"AC1EC0C950650816F27D46F7D7CA****",
    "source":"acs:mqtt",
    "type":"mqtt:Topic:SendMessage",
    "subject":"acs:mq:cn-hangzhou:143998900779****:topic/mqtt-cn-2r42qam****/housekee****",
    "datacontenttype":"application/json; charset\u003dutf-8",
    "time":"2022-06-22T03:53:47.959Z",
    "aliyunaccountid":"143998900779****",
    "data":{
        "props":{
            "firstTopic":"housekee****",
            "secondTopic":"/testMq4****",
            "clientId":"GID_****"
        },
        "body":"TEST"
    }
}

CloudEvents規範中定義的參數解釋，請參見事件概述。

data欄位包含的參數解釋如下表所示。