すべてのプロダクト
Search

このプロダクト

    ApsaraMQ for RabbitMQ:ApsaraMQ for RabbitMQ

    ドキュメントセンター

    ApsaraMQ for RabbitMQ:ApsaraMQ for RabbitMQ

    最終更新日:Jan 14, 2025

    このトピックでは、ApsaraMQ for RabbitMQ コンソールでメッセージアウトフロータスクを作成して、ある ApsaraMQ for RabbitMQ インスタンスから別の ApsaraMQ for RabbitMQ インスタンスにデータを同期する方法について説明します。

    前提条件

    メッセージアウトフロータスクの作成

    1. ApsaraMQ for RabbitMQ コンソール にログオンします。左側のナビゲーションペインで、メッセージ統合 > タスクリスト を選択します。

    2. 上部のナビゲーションバーで、中国 (杭州) などのリージョンを選択します。タスクリスト ページで、タスクの作成 をクリックします。

    3. タスクの作成 ページで、タスク名 パラメーターと 説明 パラメーターを構成し、画面の指示に従って他のパラメーターを構成します。次に、[保存] をクリックします。次のセクションでは、パラメーターについて説明します。

      • タスクの作成

        1. 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

        2. Filtering (フィルタリング) 手順で、パターン内容 コードエディターでデータをフィルタリングするデータパターンを定義します。詳細については、「イベントパターン」をご参照ください。

        3. Transform (変換) 手順で、分割、マッピング、エンリッチメント、動的ルーティングなどのデータ処理機能を実装するためのデータクレンジング方法を指定します。詳細については、「Function Compute を使用してメッセージクレンジングを実行する」をご参照ください。

        4. Sink (ターゲット) 手順で、サービスタイプ パラメーターを [apsaramq For Rabbitmq] に設定し、画面の指示に従って他のパラメーターを構成します。次の表にパラメーターを示します。

          パラメーター

          説明

          例

          インスタンス ID

          作成した ApsaraMQ for RabbitMQ インスタンス。

          amqp-cn-zvp2pny6****

          Vhost

          作成した vhost。

          test

          ターゲットタイプ

          • Exchange: プロデューサーはメッセージを exchange に送信し、exchange はメッセージを 1 つ以上のキューにルーティングします。

          • Queue: 各メッセージは 1 つ以上のキューに送信されます。

          キュー

          Exchange

          ApsaraMQ for RabbitMQ インスタンスでイベントがルーティングされる exchange。ターゲットタイプ パラメーターを Exchange に設定した場合にのみ、このパラメーターが必要です。

          exchange

          Queue

          ApsaraMQ for RabbitMQ インスタンスでイベントがルーティングされるキュー。ターゲットタイプ パラメーターを Queue に設定した場合にのみ、このパラメーターが必要です。

          queue

          メッセージのルーティングルール (Routing Key)

          EventBridge は JSONPath を使用してイベントからデータを抽出し、イベントの指定されたコンテンツをイベントターゲットにルーティングします。ターゲットタイプ パラメーターを Exchange に設定した場合にのみ、このパラメーターが必要です。

          データ抽出

          $.data.key

          メッセージ本文

          EventBridge は JSONPath を使用してイベントからデータを抽出し、イベントの指定されたコンテンツをイベントターゲットにルーティングします。

          データ抽出

          $.data.body

          MessageId

          EventBridge は JSONPath を使用してイベントからデータを抽出し、イベントの指定されたコンテンツをイベントターゲットにルーティングします。

          データ抽出

          $.data.props.messageId

          カスタムプロパティ (Properties)

          EventBridge は JSONPath を使用してイベントからデータを抽出し、イベントの指定されたコンテンツをイベントターゲットにルーティングします。

          データ抽出

          $.data.props

      • タスクプロパティ

        イベントのプッシュに失敗した場合に使用する再試行ポリシーと、障害を処理するために使用するメソッドを構成します。詳細については、「再試行ポリシーとデッドレターキュー」をご参照ください。

    その他の操作

    [タスク]タスクリスト ページで、作成したタスクを見つけ、[アクション] 列で他の操作を実行します。

    • タスクの詳細を表示する: [アクション] 列の [詳細] をクリックします。[メッセージアウトフロータスクの詳細] パネルで、タスクのソース構成、宛先構成、およびリソースを表示します。

    • タスクの構成を変更する: [アクション] 列の [編集] をクリックします。[メッセージアウトフロータスクの変更] パネルで、リソースとルールの構成を変更します。

    • タスクを有効または無効にする: [アクション] 列の [有効化] または [一時停止] をクリックします。[注記] メッセージで、[OK] をクリックします。

    • タスクを削除する: [アクション] 列の [削除] をクリックします。[注記] メッセージで、[OK] をクリックします。