全部產品
Search
文件中心

EventBridge:Simple Message Queue (formerly MNS)

更新時間:Dec 27, 2024

本文介紹如何在事件匯流排EventBridge控制台添加輕量訊息佇列(原 MNS)作為事件流中的事件提供方。

前提條件

操作步驟

  1. 登入事件匯流排EventBridge控制台,在左側導覽列,單擊事件流
  2. 在頂部功能表列,選擇地區,然後單擊建立事件流
  3. 建立事件流面板,設定任務名稱描述,配置以下參數,然後單擊儲存

    • 任務建立

      1. Source(源)設定精靈,選擇資料提供方Simple Message Queue (formerly MNS),配置以下參數,然後單擊下一步

        參數

        說明

        樣本

        队列名称

        選擇Simple Message Queue (formerly MNS)

        test-queue

        Base64 解码

        勾選此項會協助您將Simple Message Queue (formerly MNS)的資料解碼後進行投遞。

        test

        批量推送

        批量推送可幫您批量彙總多個事件,當批量推送条数批量推送间隔(单位:秒)兩者條件達到其一時即會觸發批量推送。

        例如:您設定的推送條數為100 條,間隔時間為15 s,在10 s內訊息條數已達到100條,那麼該次推送則不會等15 s後再推送。

        開啟

        批量推送条数

        調用函數發送的最大批量訊息條數,當積壓的訊息數量到達設定值時才會發送請求,取值範圍為 [1,10000]。

        100

        批量推送间隔(单位:秒)

        調用函數的間隔時間,系統每到間隔時間點會將訊息彙總後發給Function Compute,取值範圍為[0,15],單位為秒。0秒錶示無等待時間,直接投遞。

        3

      2. Filtering(過濾)Transform(轉換)Sink(目標)設定精靈,設定事件過濾、轉換規則及事件目標。事件轉換的配置說明,請參見使用Function Compute實現訊息資料清洗

    • 任務屬性

      設定事件流的重試策略及無效信件佇列。更多資訊,請參見重試和死信

  4. 返回事件流頁面,找到建立好的事件流,在其右側操作欄,單擊啟用

    啟用事件流後,會有30秒~60秒的延遲時間,您可以在事件流頁面的狀態欄查看啟動進度。

事件樣本

{
    "specversion":"1.0",
    "id":"bffb9722-9c48-407b-9895-b038f78f****",
    "source":"acs:mns",
    "type":"mns:Queue:SendMessage",
    "subject":"acs:mns:cn-hangzhou:123456789098****:queues/zeus",
    "datacontenttype":"application/json; charset=utf-8",
    "time":"2021-04-08T06:28:17.093Z",
    "aliyunpublishtime":"2021-04-08T06:30:31.367Z",
    "aliyuneventbusname":"mybus",
    "data":{
        "requestId":"606EA3074344430D4C81****",
        "messageId":"C6DB60D1574661357FA227277445****",
        "messageBody":"TEST"
    }
}

CloudEvents規範中定義的參數解釋,請參見事件概述

data欄位包含的參數解釋如下表所示。

參數

類型

樣本

描述

requestId

String

606EA3074344430D4C81****

請求ID。每個請求的ID取值唯一。

messageId

String

C6DB60D1574661357FA227277445****

訊息ID。每條訊息的ID取值唯一。

messageBody

String

TEST

訊息內容。