全部產品
Search
文件中心

ApsaraMQ for RabbitMQ:雲訊息佇列RabbitMQ版

更新時間:Dec 27, 2024

本文介紹如何在雲訊息佇列 RabbitMQ 版控制台建立訊息流程出任務,將指定雲訊息佇列 RabbitMQ 版執行個體中的資料匯出至其他的雲訊息佇列 RabbitMQ 版執行個體中。

前提條件

建立訊息流程出任務

  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(目标)設定精靈,選擇服务类型訊息佇列 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.body

        MessageId

        事件匯流排EventBridge通過JSONPath提取事件中的資料,將指定的事件內容路由到事件目標。

        資料提取

        $.data.props.messageId

        自定义属性(Properties)

        事件匯流排EventBridge通過JSONPath提取事件中的資料,將指定的事件內容路由到事件目標。

        資料提取

        $.data.props
    • 任務屬性

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

其他動作

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

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

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

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

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