Function Compute：輕量訊息佇列（原 MNS）隊列觸發器

功能簡介

注意事項

• 作為觸發源的輕量訊息佇列（原 MNS）隊列必須和Function Compute的函數所在的地區相同。

• 建立的自訂匯流排以及事件規則的數量超過上限後，將無法再建立事件模式的Simple Message Queue (formerly MNS)隊列觸發器。

• 建立的事件流數量超過上限後，將無法再建立事件流模式的Simple Message Queue (formerly MNS)隊列觸發器。

在單個阿里雲帳號單個地區維度下，關於建立觸發器涉及的資源數量的限制，請參見使用限制。

前提條件

• 事件匯流排EventBridge

  • 開通事件匯流排EventBridge並授權

• Function Compute

  • 建立服務

  • 建立函數

• 輕量訊息佇列（原 MNS）

  • 開通輕量訊息佇列（原 MNS）並授權

  • 建立隊列

步驟一：建立觸發器

1. 登入Function Compute控制台，在左側導覽列，單擊服務及函數。
2. 在頂部功能表列，選擇地區，然後在服務列表頁面，單擊目標服務。

3. 在函數管理頁面，單擊目標函數名稱。

4. 在函數詳情頁面，單擊觸發器管理頁簽，從版本或別名下拉式清單選擇要建立觸發器的版本或別名，然後單擊建立觸發器。

5. 在建立觸發程序面板，填寫相關資訊。然後單擊確定。

   基礎配置項說明如下所示。

   配置項	操作	本文樣本
   觸發器類型	選擇輕量訊息佇列（原 MNS）（隊列觸發）。	輕量訊息佇列（原 MNS）
   名稱	填寫自訂的觸發器名稱。	mns-trigger
   版本或別名	預設值為LATEST，如果您需要建立其他版本或別名的觸發器，首先需要在函數詳情頁的右上方切換到該版本或別名。關於版本和別名的簡介，請參見管理版本和管理別名。	LATEST
   隊列名稱	選擇已建立的輕量訊息佇列（原 MNS）的隊列。	MyQueue
   調用方式	選擇函數調用方式。 取值說明如下。 同步調用：適用於順序調用情境。單個（批）事件觸發函數調用，等待函數執行完成返回結果後，再由下一個（批）事件繼續觸發函數調用。同步調用請求本文承載最大為32 MB。更多資訊，請參見同步調用。 非同步呼叫：可以快速消費事件。單個（批）事件觸發函數調用，Function Compute會立刻返迴響應，再由下一個（批）事件繼續觸發函數調用。該過程中函數會非同步執行。非同步呼叫請求本文承載最大為128 KB。更多資訊，請參見非同步呼叫。	同步調用
   訊息推送模式	訊息資料推送到Function Compute時的底層應用模式。 取值說明如下。 事件流模式：會根據您的攢批配置將一個或多個訊息事件以批的形式推送到函數中進行處理，適合端到端的流式資料處理情境。 事件模式：每次會將單個訊息作為事件參數傳入函數中，事件遵循CloudEvents規範。訊息內容和CloudEvents的關係，請參見步驟二：配置函數入口參數。	事件模式
   觸發器啟用狀態	建立觸發器後是否立即啟用。預設勾選啟用觸發器，即建立觸發器後立即啟用觸發器。	不涉及

   關於推送配置、重試和死信等進階配置項說明，請參見觸發器進階功能。

   建立完成後，在觸發器名稱列表中顯示已建立的觸發器。如需對建立的觸發器進行修改或刪除，具體操作，請參見觸發器管理。

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

輕量訊息佇列（原 MNS）事件來源會以event的形式作為輸入參數傳遞給函數，您可以手動將event傳給函數類比觸發事件，測試函數代碼是否正確。

1. 在函數詳情頁面，單擊函數代碼頁簽，然後單擊測試函數右側表徵圖，從下拉式清單中，選擇配置測試參數。

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

   事件模式的event格式如下所示。

   {
       "id":"c2g71017-6f65-fhcf-a814-a396fc8d****",
       "source":"MNS-Function-mnstrigger",
       "specversion":"1.0",
       "type":"mns:Queue:SendMessage",
       "datacontenttype":"application/json; charset=utf-8",
       "subject":"acs:mns:cn-hangzhou:164901546557****:queues/zeus",
       "time":"2021-04-08T06:28:17.093Z",
       "aliyunaccountid":"164901546557****",
       "aliyunpublishtime":"2021-10-15T07:06:34.028Z",
       "aliyunoriginalaccountid":"164901546557****",
       "aliyuneventbusname":"MNS-Function-mnstrigger",
       "aliyunregionid":"cn-chengdu",
       "aliyunpublishaddr":"42.120.XX.XX",
       "data":{
           "requestId":"606EA3074344430D4C81****",
           "messageId":"C6DB60D1574661357FA227277445****",
           "messageBody":"TEST"
       }
   }

   事件流模式的event格式如下所示。

   [
       {
       "id":"c2g71017-6f65-fhcf-a814-a396fc8d****",
       "source":"MNS-Function-mnstrigger",
       "specversion":"1.0",
       "type":"mns:Queue:SendMessage",
       "datacontenttype":"application/json; charset=utf-8",
       "subject":"acs:mns:cn-hangzhou:164901546557****:queues/zeus",
       "time":"2021-04-08T06:28:17.093Z",
       "aliyunaccountid":"164901546557****",
       "aliyunpublishtime":"2021-10-15T07:06:34.028Z",
       "aliyunoriginalaccountid":"164901546557****",
       "aliyuneventbusname":"MNS-Function-mnstrigger",
       "aliyunregionid":"cn-chengdu",
       "aliyunpublishaddr":"42.120.XX.XX",
       "data":{
           "requestId":"606EA3074344430D4C81****",
           "messageId":"C6DB60D1574661357FA227277445****",
           "messageBody":"TEST"
       }
       },
       {
       "id":"d2g71017-6f65-fhcf-a814-a396fc8d****",
       "source":"MNS-Function-mnstrigger",
       "specversion":"1.0",
       "type":"mns:Queue:SendMessage",
       "datacontenttype":"application/json; charset=utf-8",
       "subject":"acs:mns:cn-hangzhou:164901546557****:queues/zeus",
       "time":"2021-04-08T06:28:17.093Z",
       "aliyunaccountid":"164901546557****",
       "aliyunpublishtime":"2021-10-15T07:06:34.028Z",
       "aliyunoriginalaccountid":"164901546557****",
       "aliyuneventbusname":"MNS-Function-mnstrigger",
       "aliyunregionid":"cn-chengdu",
       "aliyunpublishaddr":"42.120.XX.XX",
       "data":{
           "requestId":"606EA3074344430D4C81****",
           "messageId":"C6DB60D1574661357FA227277445****",
           "messageBody":"TEST"
       }
       }
   ]

   data欄位包含的參數解釋如下表所示。關於CloudEvents規範中定義的參數解釋，請參見事件概述。

   參數	類型	樣本值	描述
   requestId	String	606EA3074344430D4C81****	請求ID。每個請求的ID取值唯一。
   messageId	String	C6DB60D1574661357FA227277445****	訊息ID。每條訊息的ID取值唯一。
   messageBody	String	TEST	訊息內容。

步驟三：編寫函數代碼並測試

完成觸發器建立後，您可以開始編寫並測試函數代碼，以驗證代碼的正確性。在實際操作過程中，當輕量訊息佇列（原 MNS）自訂事件來源產生的事件通過事件匯流排EventBridge投遞到Function Compute時，觸發器會自動觸發函數的執行。

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

   本文以Node.js函數代碼為例。

   'use strict';
   /*
   To enable the initializer feature
   please implement the initializer function as below：
   exports.initializer = (context, callback) => {
     console.log('initializing');
     callback(null, '');
   };
   */
   exports.handler = (event, context, callback) => {
     console.log("event: %s", event);
     //解析event參數，對event進行處理。
     callback(null, 'return result');
   }

2. 單擊函數代碼頁簽的測試函數。

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

更多資訊

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