本文介紹如何在事件匯流排EventBridge控制台添加輕量訊息佇列(原 MNS)作為事件流中的事件提供方。
前提條件
您已建立輕量訊息佇列(原 MNS)隊列。具體步驟,請參見開通輕量訊息佇列(原 MNS)並授權。
操作步驟
- 登入事件匯流排EventBridge控制台,在左側導覽列,單擊事件流。
- 在頂部功能表列,選擇地區,然後單擊建立事件流。
在建立事件流面板,設定任務名稱和描述,配置以下參數,然後單擊儲存。
任務建立
在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
在Filtering(過濾)、Transform(轉換)及Sink(目標)設定精靈,設定事件過濾、轉換規則及事件目標。事件轉換的配置說明,請參見使用Function Compute實現訊息資料清洗。
任務屬性
設定事件流的重試策略及無效信件佇列。更多資訊,請參見重試和死信。
返回事件流頁面,找到建立好的事件流,在其右側操作欄,單擊啟用。
啟用事件流後,會有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 | 訊息內容。 |