本文介紹如何在雲訊息佇列 RabbitMQ 版控制台建立訊息流程出任務,將指定雲訊息佇列 RabbitMQ 版執行個體中的資料匯出至其他的雲訊息佇列 RabbitMQ 版執行個體中。
前提條件
您已購買雲訊息佇列 RabbitMQ 版執行個體,且執行個體處於服務中狀態。具體步驟,請參見步驟二:建立資源。
建立訊息流程出任務
登入雲訊息佇列 RabbitMQ 版控制台,在左側導覽列選擇。
在頂部功能表列選擇地區,如华东1(杭州),然後在任务列表頁面,單擊创建任务。
在创建任务面板,設定任务名称和描述,配置以下參數,單擊儲存。
任務建立
在Source(源)設定精靈,選擇数据提供方為訊息佇列 RabbitMQ 版,設定以下參數,然後單擊下一步。
參數
說明
樣本
地區
預設選擇建立訊息流程出任務時選擇的地區且不可更改。
華東1(杭州)
RabbitMQ 執行個體
選擇生產訊息的源雲訊息佇列 RabbitMQ 版執行個體。
amqp-cn-******lpc00a
Vhost
選擇源雲訊息佇列 RabbitMQ 版執行個體的Vhost。
test
Queue
選擇源雲訊息佇列 RabbitMQ 版執行個體的Queue。
queue_test
批量推送条数
調用函數發送的最大批量訊息條數,當積壓的訊息數量到達設定值時才會發送請求,取值範圍為 [1,10000]。
100
批量推送间隔(单位:秒)
調用函數的間隔時間,系統每到間隔時間點會將訊息彙總後發給Function Compute,取值範圍為[0,15],單位為秒。0秒錶示無等待時間,直接投遞。
3
在Filtering(过滤)設定精靈,設定資料模式内容過濾發送的請求。更多資訊,請參見事件模式。
在Transform(转换)設定精靈,設定資料清洗,實現分割、映射、富化及動態路由等繁雜資料加工能力。更多資訊,請參見使用Function Compute實現訊息資料清洗。
在Sink(目标)設定精靈,選擇服务类型為訊息佇列 RabbitMQ 版,配置以下參數。
參數
說明
樣本
实例ID
選擇已建立的雲訊息佇列 RabbitMQ 版執行個體。
amqp-cn-zvp2pny6****
Vhost
選擇已建立的Vhost。
test
目标类型
Exchange:生產者將訊息發送到Exchange,由Exchange將訊息路由到一個或多個Queue中。
Queue:每個訊息都會被投入到一個或多個Queue裡。
Queue 模式
Exchange
當目标类型為Exchange時,選擇雲訊息佇列 RabbitMQ 版中的Exchange。
exchange
Queue
當目标类型為Queue時,選擇雲訊息佇列 RabbitMQ 版中的選擇接收訊息的隊列。
queue
消息路由规则(Routing Key)
事件匯流排EventBridge通過JSONPath提取事件中的資料,將指定的事件內容路由到事件目標。當目标类型為Exchange時需要配置。
資料提取
$.data.key消息体(body)
事件匯流排EventBridge通過JSONPath提取事件中的資料,將指定的事件內容路由到事件目標。
資料提取
$.data.bodyMessageId
事件匯流排EventBridge通過JSONPath提取事件中的資料,將指定的事件內容路由到事件目標。
資料提取
$.data.props.messageId事件匯流排EventBridge通過JSONPath提取事件中的資料,將指定的事件內容路由到事件目標。
資料提取
$.data.props
任務屬性
配置事件推送失敗時的重試策略及錯誤發生時的處理方式。更多資訊,請參見重試和死信。
其他動作
在任务列表頁面,找到目標任務,在其右側操作列,執行其他動作。
查看任務詳情:單擊詳情,在訊息流程出詳情頁面,查看任務的源端配置、目標端配置及資源資訊。
編輯任務配置:單擊編輯,在訊息流程出編輯面板,修改資源配置和規則配置。
啟停任務:單擊啟用或者停用,然後在提示對話方塊,單擊確認。
刪除任務:單擊刪除,然後在提示對話方塊,單擊確認。