本文介紹如何在雲訊息佇列 RabbitMQ 版控制台建立訊息流程出任務,將雲訊息佇列 RabbitMQ 版的資料匯出至輕量訊息佇列(原 MNS)。
前提條件
您已購買雲訊息佇列 RabbitMQ 版執行個體,且執行個體處於服務中狀態。具體步驟,請參見步驟二:建立資源。
您已建立輕量訊息佇列(原 MNS)隊列。具體步驟,請參見開通輕量訊息佇列(原 MNS)並授權。
開服地區
在訊息整合中建立訊息流程出任務時,支援將輕量訊息佇列(原 MNS)作為訊息流程出任務目標端的地區有華東1(杭州)、華東2(上海)、華北1(青島)、華北2(北京)、華北3(張家口)、華北5(呼和浩特)、華南1(深圳)、西南1(成都)、中國香港、美國(矽谷)、美國(維吉尼亞)、德國(法蘭克福)、新加坡、日本(東京)、馬來西亞(吉隆坡)和印尼(雅加達)。
建立訊息流程出任務
登入雲訊息佇列 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(目标)設定精靈,選擇服务类型為Message Service MNS,配置以下參數。
參數
說明
樣本
隊列名稱
選擇接收源端訊息的目標輕量訊息佇列(原 MNS)隊列。
test
開啟 Base64編碼
是:開啟Base64編碼,會協助您將資料編碼後投遞至輕量訊息佇列(原 MNS)中的隊列。
否:不開啟Base64編碼。
是
消息体(body)
選擇事件內容轉換類型。更多資訊,請參考事件內容轉換。
完整資料
任務屬性
配置事件推送失敗時的重試策略及錯誤發生時的處理方式。更多資訊,請參見重試和死信。
其他動作
在任务列表頁面,找到目標任務,在其右側操作列,執行其他動作。
查看任務詳情:單擊詳情,在訊息流程出詳情頁面,查看任務的源端配置、目標端配置及資源資訊。
編輯任務配置:單擊編輯,在訊息流程出編輯面板,修改資源配置和規則配置。
啟停任務:單擊啟用或者停用,然後在提示對話方塊,單擊確認。
刪除任務:單擊刪除,然後在提示對話方塊,單擊確認。