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

IoT Platform:AMQP コンシューマーグループへのデータ転送

最終更新日:Mar 27, 2025

ルールエンジンを使用して、デバイスから IoT Platform に送信されたメッセージを転送できます。これらのメッセージは、SQL 文を使用して処理し、Advanced Message Queuing Protocol(AMQP)コンシューマーグループに転送し、AMQP クライアントによって使用できます。

前提条件

  • データ転送ルールが作成され、データの処理に使用する SQL 文が記述されています。詳細については、「データ転送ルールの設定」をご参照ください。
  • AMQP コンシューマーグループが作成され、データ転送先として使用されています。コンシューマーグループの作成と管理方法の詳細については、「コンシューマーグループの管理」をご参照ください。

手順

  1. IoT Platform コンソール にログオンします。
  2. [概要] ページで、[すべての環境] をクリックします。[すべての環境] タブで、管理するインスタンスを見つけ、インスタンス ID またはインスタンス名をクリックします。

  3. 左側のナビゲーションウィンドウで、[メッセージ転送] > [データ転送] を選択します。
  4. 管理するルールの横にある [表示] をクリックします。[データ転送ルール] ページが表示されます。
    重要 データ転送ページの新バージョンが表示されている場合は、右上隅の [以前のバージョンに戻る] をクリックし、管理するルールの [操作] 列の [表示] をクリックします。
  5. [データ転送] セクションで、[操作の追加] をクリックします。
  6. [操作の追加] ダイアログボックスで、[AMQP サブスクライブ済みコンシューマーグループに公開] を選択します。指示に従って必須パラメーターを設定し、[OK] をクリックします。
    Add Operation
    パラメーター説明
    操作の選択[AMQP サブスクライブ済みコンシューマーグループに公開] を選択します。
    コンシューマーグループ既存のコンシューマーグループをデータ転送先として選択します。[コンシューマーグループの作成] をクリックして、コンシューマーグループを作成します。
    タグタグを設定すると、この操作によって AMQP コンシューマーグループに転送されるすべてのメッセージにタグが追加されます。
    タグは 1 ~ 128 文字の長さでなければなりません。定数または変数を指定できます。
    • 定数には、文字と数字を含めることができます。
    • 変数を指定する場合は、${key} の形式を使用します。${key} は、変数が SQL 文の JSON 結果のキーの値を参照することを示します。値が使用できない場合、タグはメッセージに追加されません。
  7. [データ転送] ページに移動し、管理したルールを見つけ、そのルールの [操作] 列の [開始] をクリックします。

AMQP クライアントがメッセージを使用するように設定する

データが AMQP コンシューマーグループに転送された後、サーバーは AMQP クライアントを使用してメッセージを使用します。AMQP クライアントの設定方法の詳細については、「AMQP クライアントを IoT Platform に接続する」をご参照ください。

AMQP クライアント実装のサンプルコードについては、以下のトピックを参照してください。