ApsaraMQ for MQTT：雲訊息佇列 Kafka 版

建立訊息流程出任務

1. 登入雲Message QueueTT 版控制台，並在左側導覽列選擇消息集成 > 任务列表。

2. 在頂部功能表列選擇地區，如华东1（杭州），然後在任务列表頁面中，單擊建立任務。

3. 在创建任务面板，設定任务名称和描述，配置以下參數，單擊儲存。

   • 任務建立

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

        參數	說明	樣本
        地域	預設選擇建立任務時所在的地區。	華東1（杭州）
        MQTT 实例	選擇MQTT執行個體。	post-cn-jajh8i****
        MQTT Topic	選擇MQTT執行個體中的Topic。	test-topic
        資料格式	資料格式是針對支援二進位傳遞的資料來源端推出的指定內容格式的編碼能力。支援多種資料格式編碼，如無特殊編碼訴求可將格式設定為Json。 Json（預設Json格式編碼，位元據按照utf-8 編碼為Json格式放入Payload。） Text（文字格式設定編碼，位元據按照utf-8編碼為字串放入Payload。） Binary（二進位格式編碼，位元據按照Base64編碼為字串放入Payload。）	Json
        批量推送	批量推送可幫您批量彙總多個事件，當批量推送条数和批量推送间隔（单位：秒）兩者條件達到其一時即會觸發批量推送。 例如：您設定的推送條數為100 條，間隔時間為15 s，在10 s內訊息條數已達到100條，那麼該次推送則不會等15 s後再推送。	開啟
        批量推送条数	調用函數發送的最大批量訊息條數，當積壓的訊息數量到達設定值時才會發送請求，取值範圍為 [1,10000]。	100
        批量推送间隔（单位：秒）	調用函數的間隔時間，系統每到間隔時間點會將訊息彙總後發給Function Compute，取值範圍為[0,15]，單位為秒。0秒錶示無等待時間，直接投遞。	3

     2. 在Filtering（过滤）設定精靈，設定資料模式内容過濾發送的請求。更多資訊，請參見訊息過濾。

     3. 在Transform（转换）設定精靈，設定資料清洗，實現分割、映射、富化及動態路由等繁雜資料加工能力。更多資訊，請參見使用Function Compute實現訊息資料清洗。

     4. 在Sink（目标）設定精靈，選擇服务类型為訊息佇列 Kafka 版，配置以下參數。

        參數	說明	樣本
        实例ID	選擇已建立的雲訊息佇列 Kafka 版執行個體。	test
        Topic	選擇已建立執行個體中的Topic。	test
        确认模式（ack）	選擇雲訊息佇列 Kafka 版接收到資料後給用戶端發出的確認訊號。	None
        消息体（Value）	事件匯流排EventBridge通過JSONPath提取事件中的資料，將指定的事件內容路由到事件目標。	資料提取 $.data.value
        消息键值（Key）	事件匯流排EventBridge通過JSONPath提取事件中的資料，將指定的事件內容路由到事件目標。	資料提取 $.data.key

   • 任務屬性

     配置事件推送失敗時的重試策略及錯誤發生時的處理方式。更多資訊，請參見重試和死信。

4. 返回任务列表頁面，找到建立好的任務，在其右側操作列，單擊启用。

5. 在提示對話方塊，閱讀提示資訊，然後單擊确认。

   啟用任務後，會有30秒~60秒的延遲時間，您可以在任务列表頁面的状态欄查看啟動進度。

其他動作

在任务列表頁面，找到目標任務，在其右側操作列，執行其他動作。

• 查看任務詳情：單擊详情，在任務頁面，查看任務的基礎資訊、任務屬性及監控指標。

• 編輯任務配置：單擊编辑，在編輯任務面板，修改任務詳情及屬性。

• 啟停任務：單擊启用或者停用，然後在提示對話方塊，單擊确认。

• 刪除任務：單擊删除，然後在提示對話方塊，單擊确认。