Function Compute:ApsaraMQ for RocketMQトリガー

概要

使用上の注意

• トリガーソースとして使用されるApsaraMQ for RocketMQインスタンスは、Function Compute関数と同じリージョンに存在する必要があります。

• 作成されたイベントストリームの数が上限を超えると、ApsaraMQ for RocketMQトリガーを作成できなくなります。

各Alibaba Cloudアカウントの1つのリージョンのトリガーに関連するリソースの制限については、「制限」をご参照ください。

始める前に

• EventBridge

  • EventBridgeを有効にしてRAMユーザーに権限を付与

• Function Compute

  • イベント関数の作成

• ApsaraMQ for RocketMQ

  • ApsaraMQ for RocketMQのアクティブ化と権限付与

  • インスタンス、トピック、グループIDの作成

ステップ1: トリガーを作成する

ApsaraMQ for RocketMQインスタンスを作成した後、Function Computeコンソールにログインし、関数の詳細ページに移動し、[設定] タブをクリックし、[トリガー] ページの [トリガーの作成] をクリックします。 トリガーの作成後、[OK] をクリックします。 詳細は以下の図をご参照ください。

ステップ2: (オプション) 入力パラメーターの設定

ApsaraMQ for RocketMQは、入力パラメーターとしてeventの形式でイベントソースを関数に渡します。 コードを使用して、イベントを解析および処理できます。 eventを関数に手動で渡してトリガーイベントをシミュレートし、関数コードが正しいかどうかをテストできます。

1. 関数の詳細ページの [コード] タブで、[テスト関数] の隣のアイコンをクリックし、ドロップダウンリストから [テストパラメーターの設定] を選択します。

2. [テストパラメーターの設定] パネルで、[新しいテストイベントの作成] または [既存のテストイベントの変更] タブをクリックし、イベント名とイベント内容を入力し、[OK] をクリックします。

   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仕様で定義されているパラメーターについては、「概要」をご参照ください。

   パラメーター	データ型	例	説明
   トピック	String	TopicName	トピック名。
   systemProperties	地図		システムのプロパティ。
   MIN_OFFSET	Int	0	最も早いオフセット。
   TRACE_ON	Boolean	true	メッセージトレースが存在するかどうかを示します。 有効な値： true false
   MAX_OFFSET	Int	8	最新のオフセット。
   MSG_地域	String	cn-hangzhou	メッセージの送信元のリージョン。
   キー	String	systemProperties.KEYS	メッセージのフィルタリングに使用されるキー。
   CONSUME_START_TIME	Long	1628577790396	メッセージ消費の開始時刻。 単位：ミリ秒。
   UNIQ_KEY	String	AC14C305069E1B28CDFA3181CDA2 ****	メッセージの一意のキー。
   タグ	String	systemProperties.TAGS	メッセージのフィルタリングに使用されるタグ。
   INSTANCE_ID	String	MQ_INST_123456789098 ****_BXhFHryi	ApsaraMQ for RocketMQインスタンスのID。
   userProperties	地図	なし	ユーザーのプロパティ。
   ボディ	String	TEST	メッセージ本文。

ステップ3: 関数コードを記述し、関数をテストする

トリガーの作成後、関数コードを記述し、関数をテストして、コードが正しいかどうかを確認できます。 ApsaraMQ for 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);
     // Parse the event parameters and process the event. 
     callback(null, 'return result');
   }

2. 関数をテストします。

   方法1: eventを設定してイベントソースをシミュレートする場合は、[Test Function] をクリックします。

   方法2: ApsaraMQ for RocketMQコンソールにログインし、作成したトピックを選択し、[メッセージの送信] をクリックします。 以下の図は一例です。

   

3. 実行が完了したら、結果をリアルタイムログで表示します。

   

追加情報

既存のトリガーを変更または削除するには、「トリガーの管理」をご参照ください。