全部產品
Search
文件中心

ApsaraMQ for RabbitMQ:輕量訊息佇列(原 MNS)

更新時間:Dec 27, 2024

本文介紹如何在雲訊息佇列 RabbitMQ 版控制台建立訊息流程出任務,將雲訊息佇列 RabbitMQ 版的資料匯出至輕量訊息佇列(原 MNS)

前提條件

開服地區

在訊息整合中建立訊息流程出任務時,支援將輕量訊息佇列(原 MNS)作為訊息流程出任務目標端的地區有華東1(杭州)、華東2(上海)、華北1(青島)、華北2(北京)、華北3(張家口)、華北5(呼和浩特)、華南1(深圳)、西南1(成都)、中國香港、美國(矽谷)、美國(維吉尼亞)、德國(法蘭克福)、新加坡、日本(東京)、馬來西亞(吉隆坡)和印尼(雅加達)。

建立訊息流程出任務

  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(目标)設定精靈,選擇服务类型Message Service MNS,配置以下參數。

        參數

        說明

        樣本

        隊列名稱

        選擇接收源端訊息的目標輕量訊息佇列(原 MNS)隊列。

        test

        開啟 Base64編碼

        • :開啟Base64編碼,會協助您將資料編碼後投遞至輕量訊息佇列(原 MNS)中的隊列。

        • :不開啟Base64編碼。

        消息体(body)

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

        完整資料

    • 任務屬性

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

其他動作

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

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

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

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

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