すべてのプロダクト
Search
ドキュメントセンター

ApsaraMQ for RabbitMQ:Simple Message Queue (旧称 MNS)

最終更新日:Jan 14, 2025

このトピックでは、ApsaraMQ for RabbitMQ コンソールでメッセージ流出タスクを作成して、ApsaraMQ for RabbitMQ から Simple Message Queue (旧称 MNS) にデータをエクスポートする方法について説明します。

前提条件

サポートされているリージョン

メッセージ流出タスクを作成する場合、次のリージョンで Simple Message Queue (旧称 MNS) を送信先として使用できます。中国 (杭州)、中国 (上海)、中国 (青島)、中国 (北京)、中国 (張家口)、中国 (フフホト)、中国 (深セン)、中国 (成都)、中国 (香港)、米国 (シリコンバレー)、米国 (バージニア)、ドイツ (フランクフルト)、シンガポール、日本 (東京)、マレーシア (クアラルンプール)、インドネシア (ジャカルタ)。

メッセージ流出タスクの作成

  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 (ターゲット) 手順で、サービスタイプ パラメーターを [メッセージサービス] に設定し、画面の指示に従って他のパラメーターを構成します。次の表にパラメーターを示します。

        パラメーター

        説明

        キュー名

        メッセージをルーティングする Simple Message Queue (旧称 MNS) キュー。

        test

        Base64 エンコーディングを有効にする

        • はい: Base64 エンコーディングを有効にします。Base64 エンコーディングを有効にすると、データは送信先の Simple Message Queue (旧称 MNS) キューに送信される前に Base64 形式でエンコードされます。

        • いいえ: Base64 エンコーディングを無効にします。

        はい

        メッセージ本文

        イベント変換方法。詳細については、「イベント変換」をご参照ください。

        完全なデータ

    • タスクのプロパティ

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

その他の操作

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

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

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

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

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