RocketMQ觸發器

功能簡介

注意事項

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

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

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

前提條件

• 事件匯流排EventBridge

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

• Function Compute

  • 建立事件函數

• 訊息佇列 RocketMQ 版

  • 開通訊息佇列服務並授權

  • 建立執行個體、Topic和Group ID

步驟一：建立觸發器

1. 登入Function Compute控制台，找到目標函數，在函數詳情頁面，選擇触发器頁簽，單擊创建触发器。

2. 在建立觸發程序面板，触发器类型選擇訊息佇列RocketMQ版，設定以下配置項，然後單擊确定。

   配置項	操作	本文樣本
   名称	填寫自訂的觸發器名稱。	rocketmq-trigger
   版本或别名	預設值為LATEST，如果您需要建立其他版本或別名的觸發器，需先在函數詳情頁的右上方切換到該版本或別名。關於版本和別名的簡介，請參見版本管理和別名管理。	LATEST
   RocketMQ 实例	選擇已建立的RocketMQ執行個體。	rmq-zky****
   Topic	選擇已建立的RocketMQ執行個體的Topic。	topic1
   Tag	填寫訊息過濾標籤。只有收到包含此過濾標籤的訊息，才會觸發函數執行。	tag
   Group ID	快速建立或選擇已有的Group ID。 注意不要與已有業務共用同一個Group ID，以免影響已有業務訊息收發。	GID_FC_TRIGGER_****
   消费位点	選擇訊息的消費位點，即訊息佇列 RocketMQ 版從事件匯流排開始拉取訊息的位置。取值說明如下。 最新位点：從最新位點開始消費。 最早位点：從最早位點開始消費。 指定时间戳：從指定時間戳記開始消費。	最新位點
   调用方式	選擇函數調用方式。 取值說明如下。 同步调用：適用於順序調用情境。單個（批）事件觸發函數調用，等待函數執行完成返回結果後，再由下一個（批）事件繼續觸發函數調用。同步調用請求本文承載最大為32 MB。更多資訊，請參見同步調用。 异步调用：可以快速消費事件。單個（批）事件觸發函數調用，Function Compute會立刻返迴響應，再由下一個（批）事件繼續觸發函數調用。該過程中函數會非同步執行。非同步呼叫請求本文承載最大為128 KB。更多資訊，請參見非同步呼叫。	同步調用

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

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

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

1. 在函數詳情頁面的代码頁簽，單擊测试函数右側的表徵圖，從下拉式清單中，選擇配置测试参数。

2. 在配置测试参数面板，選擇创建新测试事件或编辑已有测试事件，填寫事件名稱和事件內容，然後單擊確定。

   event格式如下所示。

   [
       {
       "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
       "source":"RocketMQ-Function-rocketmq-trigger",
       "specversion":"1.0",
       "type":"mq:Topic:SendMessage",
       "datacontenttype":"application/json; charset=utf-8",
       "subject":"acs:mq:cn-hangzhou:164901546557****:MQ_INST_164901546557****_BXhFHryi%TopicName",
       "time":"2021-04-08T06:01:20.766Z",
       "aliyunaccountid":"164901546557****",
       "aliyunpublishtime":"2021-10-15T02:05:16.791Z",
       "aliyunoriginalaccountid":"164901546557****",
       "aliyuneventbusname":"RocketMQ-Function-rocketmq-trigger",
       "aliyunregionid":"cn-chengdu",
       "aliyunpublishaddr":"42.120.XX.XX",
       "data":{
           "topic":"TopicName",
           "systemProperties":{
               "MIN_OFFSET":"0",
               "TRACE_ON":"true",
               "MAX_OFFSET":"8",
               "MSG_REGION":"cn-hangzhou",
               "KEYS":"systemProperties.KEYS",
               "CONSUME_START_TIME":1628577790396,
               "TAGS":"systemProperties.TAGS",
               "INSTANCE_ID":"MQ_INST_164901546557****_BXhFHryi"
           },
           "userProperties":{
   
           },
           "body":"TEST"
       }
       },
       {
       "id":"94ebc15f-f0db-4bbe-acce-56fb72fb****",
       "source":"RocketMQ-Function-rocketmq-trigger",
       "specversion":"1.0",
       "type":"mq:Topic:SendMessage",
       "datacontenttype":"application/json; charset=utf-8",
       "subject":"acs:mq:cn-hangzhou:164901546557****:MQ_INST_164901546557****_BXhFHryi%TopicName",
       "time":"2021-04-08T06:01:20.766Z",
       "aliyunaccountid":"164901546557****",
       "aliyunpublishtime":"2021-10-15T02:05:16.791Z",
       "aliyunoriginalaccountid":"164901546557****",
       "aliyuneventbusname":"RocketMQ-Function-rocketmq-trigger",
       "aliyunregionid":"cn-chengdu",
       "aliyunpublishaddr":"42.120.XX.XX",
       "data":{
           "topic":"TopicName",
           "systemProperties":{
               "MIN_OFFSET":"0",
               "TRACE_ON":"true",
               "MAX_OFFSET":"8",
               "MSG_REGION":"cn-hangzhou",
               "KEYS":"systemProperties.KEYS",
               "CONSUME_START_TIME":1628577790396,
               "TAGS":"systemProperties.TAGS",
               "INSTANCE_ID":"MQ_INST_164901546557****_BXhFHryi"
           },
           "userProperties":{
   
           },
           "body":"TEST"
       }
       }
   ]

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

   參數	類型	樣本值	描述
   topic	String	TopicName	Topic名稱。
   systemProperties	Map		系統屬性。
   MIN_OFFSET	Int	0	最低位點。
   TRACE_ON	Boolean	true	是否有訊息軌跡。取值說明如下： true：有訊息軌跡。 false：無訊息軌跡。
   MAX_OFFSET	Int	8	最高位點。
   MSG_REGION	String	cn-hangzhou	發送訊息的地區。
   KEYS	String	systemProperties.KEYS	過濾屬性。
   CONSUME_START_TIME	Long	1628577790396	開始消費時間。單位：毫秒。
   UNIQ_KEY	String	AC14C305069E1B28CDFA3181CDA2****	訊息唯一鍵。
   TAGS	String	systemProperties.TAGS	過濾屬性。
   INSTANCE_ID	String	MQ_INST_123456789098****_BXhFHryi	執行個體ID。
   userProperties	Map	無	使用者屬性。
   body	String	TEST	訊息內容。

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

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

   方式二：登入訊息佇列 RocketMQ 版控制台，找到目標RocketMQ執行個體的目標Topic，單擊訊息一鍵收發體驗，然後根據介面提示發送訊息。

3. 執行完成後，在目標函數詳情頁面的代码頁簽，單擊即時日誌查看結果。