Function Compute:ApsaraMQ for RabbitMQトリガー

概要

制限事項

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

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

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

始める前に

• EventBridge

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

• Function Compute

  • イベント関数の作成

• ApsaraMQ for RabbitMQ

  • ApsaraMQ for RabbitMQの有効化

  • インスタンス、vhost、およびキューの作成

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

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

トリガーが作成されると、[トリガー] タブに表示されます。 トリガーを変更または削除するには、「トリガー管理」をご参照ください。

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

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

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

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

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

   パラメーター	データ型	例	説明
   ボディ	地図		メッセージ本文。
   こんにちは	String	EventBridge	ユーザーデータ。
   小道具	地図		メッセージ属性。
   contentEncoding	String	utf-8	メッセージ本文がエンコードされる形式。
   messageId	String	f7622d51-e198-41de-a072-77c1ead7 ****	メッセージ ID 各メッセージのIDは一意である。
   封筒	地図		メッセージエンベロープに関する情報。
   deliveryTag	Int	98	メッセージタグ。
   交換	String	なし	メッセージを送信する取引所の名前。
   再配信	Boolean	false	メッセージを再送信できるかどうかを指定します。 有効な値： true false
   routingKey	String	ハウスキーピング	メッセージのルーティングルール。

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

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

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

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

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

   

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

   

詳細情報

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