ApsaraMQ for RocketMQ：Data Transmission Service

開服地區

在訊息整合中建立訊息流程入任務時，支援將Data Transmission Service作為訊息流程入任務源端的地區有華東1（杭州）、華東2（上海）、華北1（青島）、華北2（北京）、華南1（深圳）、華南3（廣州）、西南1（成都）和中國香港。

建立訊息流程入任務

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

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

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

   • 任務建立

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

        參數	說明	樣本
        地域	預設選擇建立訊息流程入任務時所選的地區。	華東1（杭州）
        資料訂閱任務	選擇您在Data Transmission Service控制台上建立的資料訂閱任務ID。	dts8jqe****
        接入方式	預設為建立的資料訂閱任務的接入方式且不可更改。	RDS
        執行個體ID	預設為建立資料訂閱任務時訂閱的執行個體且不可更改。	rm-bp18mj3q2dzyb****
        消費組	在前提條件中建立的用於消費訂閱任務資料的消費組名稱。 說明 請確保該消費組沒有在其他用戶端的執行個體上運行，否則可能導致傳入的消費位點失效。	test
        帳號	建立消費組時設定的帳號。	test
        密碼	建立消費組時設定的密碼。	******
        消費位點	期望消費第一條資料的時間戳記。消費位點必須在訂閱執行個體的資料範圍之內。 說明 消費位點僅在新消費組第一次運行時生效，若後續任務重啟，則會基於上次消費位點繼續消費。	2022-06-21 00:00:00
        批量推送条数	調用函數發送的最大批量訊息條數，當積壓的訊息數量到達設定值時才會發送請求，取值範圍為 [1,10000]。	100
        批量推送间隔（单位：秒）	調用函數的間隔時間，系統每到間隔時間點會將訊息彙總後發給Function Compute，取值範圍為[0,15]，單位為秒。0秒錶示無等待時間，直接投遞。	3

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

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

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

        參數	說明	樣本
        版本	選擇雲訊息佇列 RocketMQ 版執行個體的版本。 RocketMQ 4.x：服務端4.x版本。 RocketMQ 5.x：服務端5.x版本。	RocketMQ 5.x
        实例ID	選擇雲訊息佇列 RocketMQ 版訊息的目標執行個體。	rmq-cn-****
        Topic	選擇目標執行個體的Topic。	topic
        消息体（body）	完整資料。 資料提取。 固定值。 模板。	資料提取 $.data.body
        自定义属性（Properties）	空。 資料提取。 模板。	模板 變數： { "userProperties":"$.data.userProperties", "msgId":"$.data.systemProperties.UNIQ_KEY" } 模板： { "EB_SYS_EMBED_OBJECT":"${userProperties}", "UNIQ_KEY":"${msgId}" }
        消息索引（Keys）	空。 資料提取。 固定值。 模板。	資料提取 $.data.systemProperties.KEYS
        消息标签（Tags）	空。 資料提取。 固定值。 模板。	資料提取 $.data.systemProperties.TAGS

   • 任務屬性

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

4. 完成上述配置後，單擊儲存。在工作清單頁面，找到剛建立的任務，此時狀態欄為啟動中，當狀態變為運行中時，任務建立成功。

其他動作