ルールエンジンを使用して、デバイスから IoT Platform に送信されたメッセージを転送できます。これらのメッセージは、SQL 文を使用して処理し、Advanced Message Queuing Protocol(AMQP)コンシューマーグループに転送し、AMQP クライアントによって使用できます。
前提条件
- データ転送ルールが作成され、データの処理に使用する SQL 文が記述されています。詳細については、「データ転送ルールの設定」をご参照ください。
- AMQP コンシューマーグループが作成され、データ転送先として使用されています。コンシューマーグループの作成と管理方法の詳細については、「コンシューマーグループの管理」をご参照ください。
手順
- IoT Platform コンソール にログオンします。
[概要] ページで、[すべての環境] をクリックします。[すべての環境] タブで、管理するインスタンスを見つけ、インスタンス ID またはインスタンス名をクリックします。
- 左側のナビゲーションウィンドウで、 を選択します。
- 管理するルールの横にある [表示] をクリックします。[データ転送ルール] ページが表示されます。重要 データ転送ページの新バージョンが表示されている場合は、右上隅の [以前のバージョンに戻る] をクリックし、管理するルールの [操作] 列の [表示] をクリックします。
- [データ転送] セクションで、[操作の追加] をクリックします。
- [操作の追加] ダイアログボックスで、[AMQP サブスクライブ済みコンシューマーグループに公開] を選択します。指示に従って必須パラメーターを設定し、[OK] をクリックします。

パラメーター 説明 操作の選択 [AMQP サブスクライブ済みコンシューマーグループに公開] を選択します。 コンシューマーグループ 既存のコンシューマーグループをデータ転送先として選択します。[コンシューマーグループの作成] をクリックして、コンシューマーグループを作成します。 タグ タグを設定すると、この操作によって AMQP コンシューマーグループに転送されるすべてのメッセージにタグが追加されます。 タグは 1 ~ 128 文字の長さでなければなりません。定数または変数を指定できます。- 定数には、文字と数字を含めることができます。
- 変数を指定する場合は、${key} の形式を使用します。${key} は、変数が SQL 文の JSON 結果のキーの値を参照することを示します。値が使用できない場合、タグはメッセージに追加されません。
- [データ転送] ページに移動し、管理したルールを見つけ、そのルールの [操作] 列の [開始] をクリックします。
AMQP クライアントがメッセージを使用するように設定する
データが AMQP コンシューマーグループに転送された後、サーバーは AMQP クライアントを使用してメッセージを使用します。AMQP クライアントの設定方法の詳細については、「AMQP クライアントを IoT Platform に接続する」をご参照ください。
AMQP クライアント実装のサンプルコードについては、以下のトピックを参照してください。