創(chuàng)建RabbitMQ Source Connector
本文介紹如何在云消息隊列 Kafka 版控制臺創(chuàng)建流入任務(wù)，將云消息隊列 RabbitMQ 版中的數(shù)據(jù)快速導(dǎo)入至云消息隊列 Kafka 版。
前提條件
您已購買云消息隊列 Kafka 版實例，且實例處于服務(wù)中狀態(tài)。具體步驟，請參見步驟二：購買和部署實例。
您已購買并部署云消息隊列 RabbitMQ 版實例，且實例處于服務(wù)中狀態(tài)。具體步驟，請參見步驟二：創(chuàng)建資源。
創(chuàng)建消息流入任務(wù)
登錄云消息隊列 Kafka 版控制臺，在概覽頁面的資源分布區(qū)域，選擇地域。
在左側(cè)導(dǎo)航欄，選擇。
在任務(wù)列表頁面，單擊創(chuàng)建任務(wù)。
在創(chuàng)建任務(wù)面板，設(shè)置任務(wù)名稱和描述，配置以下參數(shù)，單擊保存。
任務(wù)創(chuàng)建
在Source（源）配置向?qū)Вx擇數(shù)據(jù)提供方為消息隊列 RabbitMQ 版，設(shè)置以下參數(shù)，然后單擊下一步。
參數(shù)
說明
示例
地域
選擇云消息隊列 RabbitMQ 版源實例所在的地域。
華東1（杭州）
RabbitMQ 實例
選擇生產(chǎn)云消息隊列 RabbitMQ 版消息的源實例。
amqp-cn-7pp2mwbc****
Vhost
選擇源實例中的Vhost。
test
Queue
選擇存儲消息的隊列。
test
批量推送
批量推送可幫您批量聚合多個事件，當(dāng)批量推送條數(shù)和批量推送間隔（單位：秒）兩者條件達到其一時即會觸發(fā)批量推送。
例如：您設(shè)置的推送條數(shù)為100 條，間隔時間為15 s，在10 s內(nèi)消息條數(shù)已達到100條，那么該次推送則不會等15 s后再推送。
開啟
批量推送條數(shù)
調(diào)用函數(shù)發(fā)送的最大批量消息條數(shù)，當(dāng)積壓的消息數(shù)量到達設(shè)定值時才會發(fā)送請求，取值范圍為 [1,10000]。
100
批量推送間隔（單位：秒）
調(diào)用函數(shù)的間隔時間，系統(tǒng)每到間隔時間點會將消息聚合后發(fā)給函數(shù)計算，取值范圍為[0,15]，單位為秒。0秒表示無等待時間，直接投遞。
3
在Filtering（過濾）配置向?qū)ВO(shè)置數(shù)據(jù)模式內(nèi)容過濾發(fā)送的請求。更多信息，請參見消息過濾。
在Transform（轉(zhuǎn)換）配置向?qū)ВO(shè)置數(shù)據(jù)清洗，實現(xiàn)分割、映射、富化及動態(tài)路由等繁雜數(shù)據(jù)加工能力。更多信息，請參見數(shù)據(jù)清洗。
在Sink（目標(biāo)）配置向?qū)Вx擇服務(wù)類型為消息隊列 Kafka 版，配置以下參數(shù)。
參數(shù)
說明
示例
實例ID
選擇已創(chuàng)建的云消息隊列 Kafka 版實例。
test
Topic
選擇已創(chuàng)建實例中的Topic。
test
確認模式（ack）
選擇云消息隊列 Kafka 版接收到數(shù)據(jù)后給客戶端發(fā)出的確認信號。
None
消息體（body）
事件總線EventBridge通過JSONPath提取事件中的數(shù)據(jù)，將指定的事件內(nèi)容路由到事件目標(biāo)。
部分事件
$.data.value消息鍵值（Key）
事件總線EventBridge通過JSONPath提取事件中的數(shù)據(jù)，將指定的事件內(nèi)容路由到事件目標(biāo)。
部分事件
$.data.key
任務(wù)屬性
配置事件推送失敗時的重試策略及錯誤發(fā)生時的處理方式。更多信息，請參見重試和死信。
返回任務(wù)列表頁面，找到創(chuàng)建好的任務(wù)，在其右側(cè)操作列，單擊啟用。
在提示對話框，閱讀提示信息，然后單擊確認。
啟用任務(wù)后，會有30秒~60秒的延遲時間，您可以在任務(wù)列表頁面的狀態(tài)欄查看啟動進度。
其他操作
在任務(wù)列表頁面，找到目標(biāo)任務(wù)，在其右側(cè)操作列，執(zhí)行其他操作。
查看任務(wù)詳情：單擊詳情，在任務(wù)頁面，查看任務(wù)的基礎(chǔ)信息、任務(wù)屬性及監(jiān)控指標(biāo)。
編輯任務(wù)配置：單擊編輯，在編輯任務(wù)面板，修改任務(wù)詳情及屬性。
啟停任務(wù)：單擊啟用或者停用，然后在提示對話框，單擊確認。
刪除任務(wù)：單擊刪除，然后在提示對話框，單擊確認。