このトピックでは、ApsaraMQ for RabbitMQ コンソールでメッセージアウトフロータスクを作成し、ApsaraMQ for RabbitMQ から Function Compute にデータを同期する方法について説明します。
前提条件
ApsaraMQ for RabbitMQ インスタンスが購入され、デプロイされています。[実行中] 状態であることを確認してください。詳細については、「手順 2: リソースの作成」をご参照ください。
Function Compute がアクティブ化されています。詳細については、「関数をすばやく作成する」をご参照ください。
EventBridge がアクティブ化されており、必要な権限が Resource Access Management (RAM) ユーザーに付与されています。詳細については、「EventBridge のアクティブ化と RAM ユーザーへの権限の付与」をご参照ください。
メッセージアウトフロータスクの作成
ApsaraMQ for RabbitMQ コンソールにログオンします。左側のナビゲーションペインで、 を選択します。
上部のナビゲーションバーで、中国 (杭州) などのリージョンを選択します。タスクリスト ページで、タスクの作成 をクリックします。
タスクの作成 ページで、タスク名 パラメーターと 説明 パラメーターを構成し、画面の指示に従って他のパラメーターを構成します。次に、[保存] をクリックします。次のセクションでは、パラメーターについて説明します。
タスクの作成
Source (ソース) ステップで、データプロバイダー パラメーターを [apsaramq For Rabbitmq] に設定し、画面の指示に従って他のパラメーターを構成します。次に、[次のステップ] をクリックします。次の表にパラメーターを示します。
パラメーター
説明
例
リージョン
このセクションの手順 2 で選択したリージョンが使用されます。このパラメーターの値は変更できません。
中国 (杭州)
Apsaramq For Rabbitmq インスタンス
ルーティングするメッセージが生成される ApsaraMQ for RabbitMQ インスタンス。
amqp-cn-******lpc00a
vhost
ルーティングするメッセージが生成される ApsaraMQ for RabbitMQ インスタンスの vhost。
test
Queue
ルーティングするメッセージが生成される ApsaraMQ for RabbitMQ インスタンスのキュー。
queue_test
一括プッシュの件数
各関数呼び出しで送信できるメッセージの最大数。リクエストは、バックログ内のメッセージ数が指定された値に達した場合にのみ送信されます。有効な値: 1 ～ 10000。
100
バッチプッシュ間隔 (単位：秒)
関数が呼び出される時間間隔。システムは、指定された時間間隔で集約されたメッセージを Function Compute に送信します。有効な値: 0 ～ 15。単位: 秒。値 0 は、集約後すぐにメッセージが送信されることを指定します。
3
Filtering (フィルタリング) ステップで、パターン内容 コードエディターでデータをフィルタリングするためのデータパターンを定義します。詳細については、「イベントパターン」をご参照ください。
Transform (変換) ステップで、分割、マッピング、エンリッチメント、動的ルーティングなどのデータ処理機能を実装するためのデータクレンジング方法を指定します。詳細については、「Function Compute を使用したメッセージクレンジング」をご参照ください。
Sink (ターゲット) ステップで、サービスタイプ パラメーターを [function Compute] に設定し、画面の指示に従って他のパラメーターを構成します。次の表にパラメーターを示します。
パラメーター
説明
例
サービス
作成した Function Compute サービス。
test
関数
作成した Function Compute 関数。
test
バージョンとエイリアス
サービスのバージョンまたはエイリアス。
指定バージョン
バージョン
関数のバージョン。最新バージョンを選択することをお勧めします。
LATEST
呼び出しモード
呼び出しモード。有効な値: 同期および非同期。
非同期
イベント
イベントを変換するために使用するメソッド。詳細については、「イベント変換」をご参照ください。
完全なデータ
タスクのプロパティ
イベントのプッシュに失敗した場合に使用する再試行ポリシーと、障害を処理するために使用するメソッドを構成します。詳細については、「再試行ポリシーと配信不能キュー」をご参照ください。
その他の操作
[タスク]タスクリスト ページで、作成したタスクを見つけ、[アクション] 列でその他の操作を実行します。
タスクの詳細を表示する: [詳細] 列の [アクション] をクリックします。[メッセージアウトフロータスクの詳細] パネルで、タスクのソース構成、宛先構成、およびリソースを表示します。
タスクの構成を変更する: [編集] 列の [アクション] をクリックします。[メッセージアウトフロータスクの変更] パネルで、リソースとルールの構成を変更します。
タスクを有効または無効にする: [アクション] 列で [有効化] または [一時停止] をクリックします。[注記] メッセージで、[OK] をクリックします。
タスクを削除する: [削除] 列の [アクション] をクリックします。[注記] メッセージで、[OK] をクリックします。