Function Compute：RabbitMQ觸發器

功能簡介

注意事項

• 作為觸發源的訊息佇列 RabbitMQ 版執行個體必須和Function Compute的函數在相同的地區。

• 建立的事件流數量超過上限後，將無法再建立RabbitMQ觸發器。

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

前提條件

• 事件匯流排EventBridge

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

• Function Compute

  • 建立事件函數

• 訊息佇列 RabbitMQ 版

  • 開通訊息佇列RabbitMQ版服務

  • 建立執行個體、Vhost和Queue

步驟一：建立觸發器

當您已經建立好RabbitMQ的隊列，您需要登入Function Compute控制台，進入目標函數，選擇配置頁簽，建立觸發器，建立完成點擊確定如下圖所示。

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

步驟二：（可選）配置函數入口參數

訊息佇列 RabbitMQ 版事件來源會以event的形式作為輸入參數傳遞給函數，您可以使用代碼解析event參數，並對event進行處理。您可以手動將event傳給函數類比觸發事件，測試函數代碼是否正確。

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

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

   event格式如下所示。

   [
         {
       "id":"bj694332-4cj1-389e-9d8c-b137h30b****",
       "source":"RabbitMQ-Function-rabbitmq-trigger",
       "specversion":"1.0",
       "type":"amqp:Queue:SendMessage",
       "datacontenttype":"application/json;charset=utf-8",
       "subject":"acs:amqp:cn-hangzhou:164901546557****:/instances/amqp-cn-tl32e756****/vhosts/eb-connect/queues/housekeeping",
       "time":"2021-08-12T06:56:40.709Z",
       "aliyunaccountid":"164901546557****",
       "aliyunpublishtime":"2021-10-15T08:58:55.140Z",
       "aliyunoriginalaccountid":"164901546557****",
       "aliyuneventbusname":"RabbitMQ-Function-rabbitmq-trigger",
       "aliyunregionid":"cn-chengdu",
       "aliyunpublishaddr":"42.120.XX.XX",
       "data":{
           "envelope":{
               "deliveryTag":98,
               "exchange":"",
               "redeliver":false,
               "routingKey":"housekeeping"
           },
           "body":{
               "Hello":"RabbitMQ"
           },
           "props":{
               "contentEncoding":"UTF-8",
               "messageId":"f7622d51-e198-41de-a072-77c1ead7****"
           }
       }
       },
       {
       "id":"bj694332-4cj1-389e-9d8c-b137h30b****",
       "source":"RabbitMQ-Function-rabbitmq-trigger",
       "specversion":"1.0",
       "type":"amqp:Queue:SendMessage",
       "datacontenttype":"application/json;charset=utf-8",
       "subject":"acs:amqp:cn-hangzhou:164901546557****:/instances/amqp-cn-tl32e756****/vhosts/eb-connect/queues/housekeeping",
       "time":"2021-08-12T06:56:40.709Z",
       "aliyunaccountid":"164901546557****",
       "aliyunpublishtime":"2021-10-15T08:58:55.140Z",
       "aliyunoriginalaccountid":"164901546557****",
       "aliyuneventbusname":"RabbitMQ-Function-rabbitmq-trigger",
       "aliyunregionid":"cn-chengdu",
       "aliyunpublishaddr":"42.120.XX.XX",
       "data":{
           "envelope":{
               "deliveryTag":98,
               "exchange":"",
               "redeliver":false,
               "routingKey":"housekeeping"
           },
           "body":{
               "Hello":"RabbitMQ"
           },
           "props":{
               "contentEncoding":"UTF-8",
               "messageId":"f7622d51-e198-41de-a072-77c1ead7****"
           }
       }
       }
   ]

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

   參數	類型	樣本值	描述
   body	Map		訊息內容。
   Hello	String	EventBridge	使用者資料。
   props	Map		訊息屬性。
   contentEncoding	String	utf-8	訊息內容編碼。
   messageId	String	f7622d51-e198-41de-a072-77c1ead7****	訊息ID。每條訊息的ID取值唯一。
   envelope	Map		訊息的envelope資訊。
   deliveryTag	Int	98	訊息的Tag。
   exchange	String	無	訊息的Exchange。
   redeliver	Boolean	false	是否支援重發訊息。取值說明如下： true：支援 false：不支援
   routingKey	String	housekeeping	訊息的路由規則。

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

完成觸發器建立後，您可以開始編寫並測試函數代碼，以驗證代碼的正確性。在實際操作過程中，當訊息佇列 RabbitMQ 版事件通過事件匯流排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. 測試函數。

   方式一：如果您是配置函數入口參數event類比事件來源，單擊測試函數。

   方式二：登入雲訊息佇列 RabbitMQ 版控制台，選擇您建立的目標隊列，點擊發送訊息，如下圖。

   

3. 執行完成後，在即時日誌查看結果。

   

更多資訊

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