ApsaraMQ for RocketMQ：雲訊息佇列 Kafka 版

建立訊息流程入任務

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

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

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

   • 任務建立

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

        參數	說明	樣本
        地區	選擇雲訊息佇列 Kafka 版源執行個體所在的地區。	華北2（北京）
        kafka 執行個體	選擇生產雲訊息佇列 Kafka 版訊息的源執行個體。	MQ_INST_115964845466****_ByBeUp3p
        Topic	選擇生產雲訊息佇列 Kafka 版訊息的Topic。	topic
        Group ID	選擇源執行個體的消費組名稱。請使用獨立的消費組來建立事件來源，不要和已有的業務混用消費組，以免影響已有的訊息收發。	GID_http_1
        消費位點	選擇開始消費訊息的位點。 最新點位。 最早點位。	最新位點
        網路設定	選擇路由訊息的網路類型。 基礎網路。 自建公網。	基礎網路
        Virtual Private Cloud	選擇VPC ID。當網路設定設定為自建公網時需要設定此參數。	vpc-bp17fapfdj0dwzjkd****
        交換器	選擇vSwitch ID。當網路設定設定為自建公網時需要設定此參數。	vsw-bp1gbjhj53hdjdkg****
        安全性群組	選擇安全性群組。當網路設定設定為自建公網時需要設定此參數。	alikafka_pre-cn-7mz2****
        数据格式(Body)	資料格式是針對支援二進位傳遞的資料來源端推出的指定內容格式的編碼能力。支援多種資料格式編碼，如無特殊編碼訴求可將格式設定為Json。 Json（預設Json格式編碼，位元據按照utf-8 編碼為Json格式放入Payload。） Text（文字格式設定編碼，位元據按照utf-8編碼為字串放入Payload。） Binary（二進位格式編碼，位元據按照Base64編碼為字串放入Payload。）	Json
        批量推送条数	調用函數發送的最大批量訊息條數，當積壓的訊息數量到達設定值時才會發送請求，取值範圍為 [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. 完成上述配置後，單擊儲存。在工作清單頁面，找到剛建立的任務，此時狀態欄為啟動中，當狀態變為運行中時，任務建立成功。

其他動作