輕量消息隊列(原 MNS)的主題(Topic)可以作為事件源通過事件總線EventBridge與函數計算進行集成。通過輕量消息隊列(原 MNS)主題觸發器,當有新消息發送到您的輕量消息隊列(原 MNS)主題時,它會自動觸發與之關聯的函數執行,從而您可以輕松地對傳入的消息進行自定義處理。
背景介紹
輕量消息隊列(原 MNS)是一種高效、可靠、安全、便捷、可彈性擴展的分布式消息服務。幫助應用開發者在其應用的分布式組件上自由地傳遞數據、通知消息,構建松耦合系統。在輕量消息隊列(原 MNS)中,主題是發布消息的目的地。發布者可以通過PublishMessage接口向主題發布消息,主題的訂閱者接收該消息。接口信息,請參見PublishMessage。
配置一個輕量消息隊列(原 MNS)主題觸發器,相當于將函數注冊為這個輕量消息隊列(原 MNS)主題的訂閱者,當發布者向輕量消息隊列(原 MNS)主題發布消息的時候,就會把消息內容通知給函數,即觸發函數執行,同時消息內容作為函數入口的event參數。具體信息,請參見基礎信息。
輕量消息隊列(原 MNS)與函數計算集成有以下優勢:
可以實現對消息進行一些高階處理再發送郵件或者短信。
HTTP Endpoint不需要有自建的服務。
支持豐富的自定義處理。例如,把消息發送給slack,或者對于特定的消息進行持久化存儲。
前提條件
注意事項
輕量消息隊列(原 MNS)創建的主題和函數計算的函數部署在相同的地域。
避免出現循環調用的情況。
編寫函數時,注意不要出現以下邏輯:Topic A觸發函數B,函數B又發布新的消息到Topic A,從而造成函數無限循環調用。
步驟一:創建MNS主題觸發器
登錄函數計算控制臺,在左側導航欄,單擊服務及函數。
- 在頂部菜單欄,選擇地域,然后在服務列表頁面,單擊目標服務操作列的函數管理。
在函數管理頁面,單擊目標函數名稱。
在函數詳情頁面,單擊觸發器管理頁簽,從版本或別名下拉列表選擇要創建觸發器的版本或別名,然后單擊創建觸發器。
在創建觸發器面板,填寫相關信息。然后單擊確定。
參數
操作
本文示例
觸發器類型
選擇輕量消息隊列(原 MNS) topic 觸發 。
輕量消息隊列(原 MNS) topic觸發
名稱
填寫自定義的觸發器名稱。
trigger-mns
版本或別名
默認值為LATEST,如果您需要創建其他版本或別名的觸發器,需先在函數詳情頁的右上角切換到該版本或別名。關于版本和別名的簡介,請參見管理版本和管理別名。
LATEST
MNS地域
選擇Topic所在的地域。輕量消息隊列(原 MNS)主題和函數計算的函數要部署在相同的地域。
西南1(成都)
主題
在列表中選擇已創建的Topic。
Mytopic
過濾標簽
填寫消息過濾標簽。
只有收到包含了此處設置的過濾標簽字符串的消息時,才會觸發函數執行。
tag
Event格式
選擇Event格式。取值:
STREAM
JSON
JSON
重試策略
選擇重試策略。取值:
退避重試
指數衰減
如何選擇重試策略,請參見NotifyStrategy。
退避重試
角色名稱
選擇AliyunMNSNotificationRole。
說明如果您第一次創建該類型的觸發器,則需要在單擊確定后,在彈出的對話框中選擇立即授權。
AliyunMNSNotificationRole
創建完成后,在觸發器名稱列表中顯示已創建的觸發器。如需對創建的觸發器進行修改或刪除,具體操作,請參見觸發器管理。
步驟二:配置函數的入口參數
在函數詳情頁面,單擊函數代碼頁簽,然后單擊測試函數右側圖標,從下拉列表中,選擇配置測試參數。
在配置測試參數面板,選擇創建新測試事件或編輯已有測試事件頁簽,填寫事件名稱和事件內容。然后單擊確定。
發布在輕量消息隊列(原 MNS)主題上的消息根據notifyContentFormat進行處理,即入口函數的event。更多信息,請參見NotifyContentFormat。
創建觸發器時,若event格式設置為STREAM。
當消息中不含消息屬性(MessageAttributes)時,event格式如下。
說明當消息中不含消息屬性(MessageAttributes)時,event的內容格式為JSON字符串。
# 消息正文。 'hello topic'
當消息中含有消息屬性(MessageAttributes)時,event格式如下。
說明event的內容中包含MessageAttributes相關的鍵值對。更多信息,請參見PublishMessage。
{ "body": "hello topic", "attrs": { "Extend": "{\\"key\\":\\"value\\"}" } }
創建觸發器時,若event格式設置為JSON。
當消息中不含消息屬性(MessageAttributes)時,event格式如下。
{ "TopicOwner": "118620210433****", "Message": "hello topic", "Subscriber": "118620210433****", "PublishTime": 1550216480040, "SubscriptionName": "test-fc-subscribe", "MessageMD5": "BA4BA9B48AC81F0F9C66F6C909C3****", "TopicName": "Mytopic", "MessageId": "2F5B3C082B923D4EAC694B76D928****" }
當消息中含有消息屬性(MessageAttributes)時,event格式如下。
說明event的內容中包含MessageAttributes相關的鍵值對。更多信息,請參見PublishMessage。
{ "key": "value", "TopicOwner": "118620210433****", "Message": "hello topic", "Subscriber": "118620210433****", "PublishTime": 1550216302888, "SubscriptionName": "test-fc-subscribe", "MessageMD5": "BA4BA9B48AC81F0F9C66F6C909C3****", "TopicName": "Mytopic", "MessageId": "2F5B3C281B283D4EAC694B742528****" }
event參數中不同屬性字段的解釋如下表所示。
參數
類型
示例值
描述
key
String
value
消息屬性相關的鍵值對。
TopicOwner
String
118620210433****
訂閱Topic的AccountId。
Message
String
hello topic
消息內容。
Subscriber
String
118620210433****
用戶的AccountId。
PublishTime
Int
1550216302888
消息發布時間。
SubscriptionName
String
test-fc-subscribe
訂閱的名稱。
MessageMD5
String
BA4BA9B48AC81F0F9C66F6C909C3****
消息正文的MD5值。
TopicName
String
Mytopic
Topic名稱。
MessageId
String
2F5B3C281B283D4EAC694B742528****
消息的編號。
步驟三:編寫函數代碼并測試
完成創建輕量消息隊列(原 MNS)主題觸發器后,您可以開始編寫函數代碼并測試,以驗證代碼的正確性。
在函數詳情頁面,單擊函數代碼頁簽,在代碼編輯器中編寫代碼,然后單擊部署代碼。
本文以Python函數代碼為例。以下示例代碼可以作為輕量消息隊列(原 MNS)主題觸發器的函數模板。
import json import logging def handler(event, context): logger = logging.getLogger() logger.info("mns_topic trigger event = {}".format(event)) # 例如,將事件記錄到表格存儲。 return "OK"
單擊函數代碼頁簽的測試函數。
執行完成后,您可以在函數代碼頁簽的上方查看執行結果。
更多信息
除了函數計算控制臺,您還可通過以下方式配置觸發器:
通過Serverless Devs工具配置觸發器。更多操作,請參見Serverless Devs。
通過SDK配置觸發器。更多操作,請參見SDK列表。
如需對創建的觸發器進行修改或刪除,具體操作,請參見觸發器管理。