全部產品
Search

搜尋本產品

    Function Compute：MNS隊列觸發器

    文件中心

    Function Compute：MNS隊列觸發器

    更新時間：Jul 06, 2024

    Message ServiceMNS的隊列（Queue）作為事件來源通過事件匯流排EventBridge與Function Compute整合後，通過Message ServiceMNS隊列觸發器（以下簡稱MNS隊列觸發器）能夠觸發關聯函數執行，通過函數可以對發布到Message ServiceMNS隊列中的訊息進行自訂處理。本文介紹如何在Function Compute控制台建立MNS隊列觸發器、配置函數入口參數和編寫代碼並測試。

    功能簡介

    您在Function Compute的控制台提交觸發器建立請求之後，Function Compute會根據觸發器的配置資訊，自動建立與事件匯流排EventBridge相關的資源。目前提供事件模式和事件流模式兩種訊息推送模式，每個模式建立的資源如下：
    建立完成後，您可以在Function Compute控制台查看觸發器資訊，同時也可以在事件匯流排EventBridge控制台查看自動建立的資源資訊。當源Message ServiceMNS隊列中有訊息入隊時，將會觸發Function Compute執行，不同訊息推送模式支援的參數內容也不同。
    • 事件模式：每次會將單個訊息作為事件參數傳入函數中，事件遵循CloudEvents規範。訊息內容和CloudEvents的關係，請參見參數內容。
    • 事件流模式：根據您的攢批配置，將一個或多個訊息事件以批的形式推送到函數中進行處理，適合端到端的流式資料處理情境。

    注意事項

    • 作為觸發源的Message ServiceMNS隊列必須和Function Compute的函數所在的地區相同。
    • 建立的自訂匯流排以及事件規則的數量超過上限後，將無法再建立事件模式的MNS隊列觸發器。
    • 建立的事件流數量超過上限後，將無法再建立事件流模式的MNS隊列觸發器。

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

    前提條件

    步驟一：建立觸發器

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

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

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

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

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

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


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

    Message ServiceMNS事件來源會以event的形式作為輸入參數傳遞給函數，您可以手動將event傳給函數類比觸發事件，測試函數代碼是否正確。

    1. 在函數詳情頁面，單擊函數代碼頁簽，然後單擊測試函數右側xialatubiao表徵圖，從下拉式清單中，選擇配置測試參數。
    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規範中定義的參數解釋，請參見事件概述。
      參數類型樣本值描述
      requestIdString606EA3074344430D4C81****請求ID。每個請求的ID取值唯一。
      messageIdStringC6DB60D1574661357FA227277445****訊息ID。每條訊息的ID取值唯一。
      messageBodyStringTEST訊息內容。

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

    完成觸發器建立後，您可以開始編寫並測試函數代碼，以驗證代碼的正確性。在實際操作過程中，當Message ServiceMNS自訂事件來源產生的事件通過事件匯流排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. 單擊函數代碼頁簽的測試函數。

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

    更多資訊

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