本文介紹如何在雲訊息佇列 RabbitMQ 版控制台建立訊息流程出任務,將雲訊息佇列 RabbitMQ 版的資料匯出至Function Compute。
前提條件
建立訊息流程出任務
登入雲訊息佇列 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(目标)設定精靈,選擇服务类型為Function Compute,配置以下參數。
參數
說明
樣本
服務
選擇已建立的Function Compute的服務。
test
函數
選擇已建立的Function Compute的函數。
test
版本和別名
選擇服務版本或服務別名。
指定版本
版本
函數變更的對應版本,一般選擇為最新版。
LATEST
執行方式
選擇同步執行或非同步執行。
非同步
事件
選擇事件內容轉換類型。更多資訊,請參考事件內容轉換。
完整資料
任務屬性
配置事件推送失敗時的重試策略及錯誤發生時的處理方式。更多資訊,請參見重試和死信。
其他動作
在任务列表頁面,找到目標任務,在其右側操作列,執行其他動作。
查看任務詳情:單擊詳情,在訊息流程出詳情頁面,查看任務的源端配置、目標端配置及資源資訊。
編輯任務配置:單擊編輯,在訊息流程出編輯面板,修改資源配置和規則配置。
啟停任務:單擊啟用或者停用,然後在提示對話方塊,單擊確認。
刪除任務:單擊刪除,然後在提示對話方塊,單擊確認。