云消息隊列 RocketMQ 版
本文介紹如何在云消息隊列 MQTT 版控制臺創建流出目標為云消息隊列 RocketMQ 版的消息流出任務。
前提條件
您已購買云消息隊列 MQTT 版實例，且實例處于服務中狀態。具體步驟，請參見創建資源。
創建消息流出任務
登錄云消息隊列 MQTT 版控制臺，并在左側導航欄選擇。
在頂部菜單欄選擇地域，如華東1（杭州），然后在任務列表頁面中，單擊創建任務。
在創建任務面板，設置任務名稱和描述，配置以下參數。
任務創建
在Source（源）配置向導，選擇數據提供方為消息隊列 MQTT 版，設置以下參數，然后單擊下一步。
參數
說明
示例
地域
默認選擇創建任務時所在的地域。
華東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
批量推送間隔（單位：秒）
調用函數的間隔時間，系統每到間隔時間點會將消息聚合后發給函數計算，取值范圍為[0,15]，單位為秒。0秒表示無等待時間，直接投遞。
3
在Filtering（過濾）配置向導，設置數據模式內容過濾發送的請求。更多信息，請參見事件模式。
在Transform（轉換）配置向導，設置數據清洗，實現分割、映射、富化及動態路由等繁雜數據加工能力。更多信息，請參見使用函數計算實現消息數據清洗。
在Sink（目標）配置向導，選擇服務類型為消息隊列 RocketMQ 版，配置以下參數。
參數
說明
示例
版本
選擇云消息隊列 RocketMQ 版實例版本。
RocketMQ 4.x
實例ID
選擇已創建的云消息隊列 RocketMQ 版實例。
test
Topic
選擇已創建的Topic。
test
消息體（body）
事件總線EventBridge通過JSONPath提取事件中的數據，將指定的事件內容路由到事件目標。
數據提取
$.data.body自定義屬性（Properties）
事件總線EventBridge通過JSONPath提取事件中的數據，將指定的事件內容路由到事件目標。
數據提取
$.data.userProperties消息索引（Keys）
事件總線EventBridge通過JSONPath提取事件中的數據，將指定的事件內容路由到事件目標。
數據提取
$.data.systemProperties.KEYS消息標簽（Tags）
事件總線EventBridge通過JSONPath提取事件中的數據，將指定的事件內容路由到事件目標。
數據提取
$.data.systemProperties.TAGS
任務屬性
配置事件推送失敗時的重試策略及錯誤發生時的處理方式。更多信息，請參見重試和死信。
返回任務列表頁面，找到創建好的任務，在其右側操作列，單擊啟用。
在提示對話框，閱讀提示信息，然后單擊確認。
啟用任務后，會有30秒~60秒的延遲時間，您可以在任務列表頁面的狀態欄查看啟動進度。
其他操作
在任務列表頁面，找到目標任務，在其右側操作列，執行其他操作。
查看任務詳情：單擊詳情，在任務頁面，查看任務的基礎信息、任務屬性及監控指標。
編輯任務配置：單擊編輯，在編輯任務面板，修改任務詳情及屬性。
啟停任務：單擊啟用或者停用，然后在提示對話框，單擊確認。
刪除任務：單擊刪除，然后在提示對話框，單擊確認。