全部產品
Search
文件中心

ApsaraMQ for RabbitMQ:Function Compute

更新時間:Dec 27, 2024

本文介紹如何在雲訊息佇列 RabbitMQ 版控制台建立訊息流程出任務,將雲訊息佇列 RabbitMQ 版的資料匯出至Function Compute。

前提條件

建立訊息流程出任務

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

  2. 在頂部功能表列選擇地區,如华东1(杭州),然後在任务列表頁面,單擊创建任务

  3. 创建任务面板,設定任务名称描述,配置以下參數,單擊儲存

    • 任務建立

      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

      2. Filtering(过滤)設定精靈,設定資料模式内容過濾發送的請求。更多資訊,請參見事件模式

      3. Transform(转换)設定精靈,設定資料清洗,實現分割、映射、富化及動態路由等繁雜資料加工能力。更多資訊,請參見使用Function Compute實現訊息資料清洗

      4. Sink(目标)設定精靈,選擇服务类型Function Compute,配置以下參數。

        參數

        說明

        樣本

        服務

        選擇已建立的Function Compute的服務。

        test

        函數

        選擇已建立的Function Compute的函數。

        test

        版本和別名

        選擇服務版本或服務別名。

        指定版本

        版本

        函數變更的對應版本,一般選擇為最新版。

        LATEST

        執行方式

        選擇同步執行或非同步執行。

        非同步

        事件

        選擇事件內容轉換類型。更多資訊,請參考事件內容轉換

        完整資料

    • 任務屬性

      配置事件推送失敗時的重試策略及錯誤發生時的處理方式。更多資訊,請參見重試和死信

其他動作

任务列表頁面,找到目標任務,在其右側操作列,執行其他動作。

  • 查看任務詳情:單擊詳情,在訊息流程出詳情頁面,查看任務的源端配置、目標端配置及資源資訊。

  • 編輯任務配置:單擊編輯,在訊息流程出編輯面板,修改資源配置規則配置

  • 啟停任務:單擊啟用或者停用,然後在提示對話方塊,單擊確認

  • 刪除任務:單擊刪除,然後在提示對話方塊,單擊確認