背景介紹

輕量消息隊列（原 MNS）是一種高效、可靠、安全、便捷、可彈性擴展的分布式消息服務。幫助應用開發者在其應用的分布式組件上自由地傳遞數據、通知消息，構建松耦合系統。在輕量消息隊列（原 MNS）中，主題是發布消息的目的地。發布者可以通過PublishMessage接口向主題發布消息，主題的訂閱者接收該消息。接口信息，請參見PublishMessage。

配置一個輕量消息隊列（原 MNS）主題觸發器，相當于將函數注冊為這個輕量消息隊列（原 MNS）主題的訂閱者，當發布者向輕量消息隊列（原 MNS）主題發布消息的時候，就會把消息內容通知給函數，即觸發函數執行，同時消息內容作為函數入口的event參數。具體信息，請參見基礎信息。

輕量消息隊列（原 MNS）與函數計算集成有以下優勢：

• 可以實現對消息進行一些高階處理再發送郵件或者短信。

• HTTP Endpoint不需要有自建的服務。

• 支持豐富的自定義處理。例如，把消息發送給slack，或者對于特定的消息進行持久化存儲。

前提條件

• 函數計算

  • 創建函數

• 輕量消息隊列（原 MNS）

  • 創建主題

注意事項

• 輕量消息隊列（原 MNS）創建的主題和函數計算的函數部署在相同的地域。

• 避免出現循環調用的情況。

  編寫函數時，注意不要出現以下邏輯：Topic A觸發函數B，函數B又發布新的消息到Topic A，從而造成函數無限循環調用。

步驟一：創建輕量消息隊列（原 MNS）主題觸發器

1. 登錄函數計算控制臺，在左側導航欄，單擊函數。

2. 在頂部菜單欄，選擇地域，然后在函數頁面，單擊目標函數。

3. 在函數詳情頁面，選擇配置頁簽，在左側導航欄，單擊觸發器，然后單擊創建觸發器。

4. 在創建觸發器面板，填寫相關信息，然后單擊確定。

   參數	操作	本文示例
   觸發器類型	選擇輕量消息隊列（原 MNS） topic 觸發 。	輕量消息隊列（原 MNS） topic觸發
   名稱	填寫自定義的觸發器名稱。	trigger-mns
   版本或別名	默認值為LATEST，如果您需要創建其他版本或別名的觸發器，需先在函數詳情頁的右上角切換到該版本或別名。關于版本和別名的簡介，請參見版本管理和別名管理。	LATEST
   輕量消息隊列（原 MNS） 地域	選擇Topic所在的地域。輕量消息隊列（原 MNS）主題和函數計算的函數要部署在相同的地域。	西南1（成都）
   主題	在列表中選擇已創建的Topic。	Mytopic
   過濾標簽	填寫消息過濾標簽。 只有收到包含了此處設置的過濾標簽字符串的消息時，才會觸發函數執行。	tag
   Event 格式	選擇Event格式。取值： STREAM JSON	JSON
   重試策略	選擇重試策略。取值： 退避重試 指數衰減 如何選擇重試策略，請參見NotifyStrategy。	退避重試
   角色名稱	選擇AliyunMNSNotificationRole。 說明 如果您第一次創建該類型的觸發器，則需要在單擊確定后，在彈出的對話框中選擇立即授權。	AliyunMNSNotificationRole

步驟二：配置函數的入口參數

1. 在函數詳情頁面的代碼頁簽，單擊測試函數右側的圖標，從下拉列表中，選擇配置測試參數。

2. 在配置測試參數面板，選擇創建新測試事件或編輯已有測試事件，填寫事件名稱和事件內容，然后單擊確定。

   發布在輕量消息隊列（原 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）主題觸發器后，您可以開始編寫函數代碼并測試，以驗證代碼的正確性。

1. 在函數詳情頁面的代碼頁簽，在代碼編輯器中編寫代碼，然后單擊部署代碼。

   本文以Python函數代碼為例。以下示例代碼可以作為輕量消息隊列（原 MNS）主題觸發器的函數模板。

   import json
   import logging
   
   def handler(event, context):
     logger = logging.getLogger()
     logger.info("mns_topic trigger event = {}".format(event))
     # 例如，將事件記錄到表格存儲。
     return "OK"                     

2. 單擊測試函數。

   執行完成后，您可以在函數代碼頁簽的上方查看執行結果。

更多信息

如需對創建的觸發器進行修改或刪除，具體操作，請參見觸發器管理。