ルールエンジンを使用して、IoT Platform から ApsaraMQ for RocketMQ にデータを転送できます。これにより、デバイス、IoT Platform、ApsaraMQ for RocketMQ からアプリケーションサーバーへの信頼性の高いエンドツーエンドの転送が保証されます。
前提条件
ApsaraMQ for RocketMQ へのデータ転送をサポートするリージョンに、ApsaraMQ for RocketMQ にデータを転送できる IoT Platform インスタンスが作成されていること。 ApsaraMQ for RocketMQ へのデータ転送をサポートするリージョンの詳細については、「リージョン」をご参照ください。
データを受信するために使用できる ApsaraMQ for RocketMQ インスタンスと Topic が作成されていること。詳細については、「ApsaraMQ for RocketMQ を使用する」をご参照ください。
重要ApsaraMQ for RocketMQ インスタンスは、データ転送ルールを構成する IoT Platform インスタンスと同じリージョンに存在する必要があります。この制限は、異なるリージョンのインスタンス間でデータを転送するために使用される既存のデータ転送ルールには適用されません。
ApsaraMQ for RocketMQ V4.x インスタンスまたは V5.x インスタンスの Topic にのみデータを転送できます。
データ転送ルールが作成され、データを処理するために使用される SQL 文が記述されていること。詳細については、「データ転送ルールの構成」をご参照ください。
注意事項
データ転送機能の新バージョンまたは以前のバージョンを使用して、ApsaraMQ for RocketMQ にデータを転送できます。データ転送機能の新バージョンの使用方法の詳細については、「データ転送機能の新バージョンを使用して ApsaraMQ for RocketMQ にデータを転送する」をご参照ください。
データ転送先を構成するときに ApsaraMQ for RocketMQ へのデータ送信を指定すると、次の設定が自動的に構成されます。構成が完了すると、IoT Platform のルールエンジンを使用して、デバイスデータを ApsaraMQ for RocketMQ V5.0 インスタンスに転送できます。
ApsaraMQ for RocketMQ インスタンスが接続されている vSwitch の 2 つの IP アドレスが IoT Platform に割り当てられます。
ApsaraMQ for RocketMQ インスタンスが存在する仮想プライベートクラウド (VPC) に、マネージドセキュリティグループが作成されます。デフォルトでは、セキュリティグループの名前は sg-nsm- で始まります。
手順
- IoT Platform コンソール にログオンします。
[概要] ページで、[すべての環境] をクリックします。[すべての環境] タブで、管理するインスタンスを見つけ、インスタンス ID またはインスタンス名をクリックします。
- 左側のナビゲーションウィンドウで、 を選択します。
- 管理するルールの横にある [表示] をクリックします。[データ転送ルール] ページが表示されます。重要 データ転送ページの新バージョンが表示されている場合は、右上隅にある [以前のバージョンに戻る] をクリックし、管理するルールの [アクション] 列にある [表示] をクリックします。
- [データ転送] セクションで、[操作を追加] をクリックします。
[操作を追加] ダイアログボックスで、[操作] ドロップダウンリストから [apsaramq For Apache Rocketmq にデータを送信] を選択します。プロンプトに従って他のパラメータを構成し、[OK] をクリックします。次の表にパラメータを示します。
パラメータ
説明
操作
[apsaramq For Rocketmq にデータを送信] を選択します。
リージョン
ApsaraMQ for RocketMQ インスタンスが存在するリージョンを選択します。
インスタンス
ApsaraMQ for RocketMQ インスタンスを選択します。
[インスタンスの作成] をクリックして ApsaraMQ for RocketMQ コンソールに移動し、ApsaraMQ for RocketMQ インスタンスを作成できます。詳細については、ApsaraMQ for RocketMQ ドキュメント を参照してください。
Topic
IoT Platform からデータを受信するために使用する ApsaraMQ for RocketMQ Topic を選択します。
[topic の作成] をクリックして ApsaraMQ for RocketMQ コンソールに移動し、ApsaraMQ for RocketMQ Topic を作成できます。
タグ
オプション。タグを指定します。
タグを指定すると、そのタグは ApsaraMQ for RocketMQ Topic に転送されるすべてのメッセージに添付されます。コンシューマークライアントでタグ別にメッセージをフィルタリングできます。
タグの最大長は 128 バイトです。定数または変数を入力できます。変数は ${key} 形式で指定します。${key} は、変数が SQL 文の JSON 結果のキーの値を参照することを指定します。
承認
IoT Platform に ApsaraMQ for RocketMQ にデータを書き込む権限を付与します。
Resource Access Management (RAM) ロールがない場合は、[RAM ロールの作成] をクリックして RAM コンソールに移動し、RAM ロールを作成して、そのロールに権限を付与します。詳細については、「RAM ロールの作成」をご参照ください。
- [データ転送] ページに移動し、管理したルールを見つけ、そのルールの [アクション] 列にある [開始] をクリックします。
テストを実行します。
データ転送ルールで構成されている SQL 文で定義されている Topic にメッセージをパブリッシュします。次に、ApsaraMQ for RocketMQ コンソール に移動して、メッセージが受信されているかどうかを確認します。