IoT Platform:Simple Message Queue (MNS) へのデータ転送

仕組み

データ転送機能は、同一プロダクト配下にあるすべて、または特定のデバイスの指定されたトピックから、MNS キューがサブスクライブしている MNS トピックへメッセージをリアルタイムで転送します。

上の図について：

• データソース：サポートされているトピックタイプについては、「データフォーマット (非ゲートウェイプロダクトおよびデバイス向け)」、「カスタムトピック (MQTT クラウドゲートウェイ向け)」、「メッセージ転送トピック (GB/T 32960 クラウドゲートウェイ向け)」、「メッセージ転送トピック (JT/T 808 クラウドゲートウェイ向け)」。

• データ送信先：デバイスデータを受信するために作成する MNS トピックです。このトピックからのすべてのメッセージは、それをサブスクライブしている MNS キューにプッシュされます。

• パーサスクリプト：データ転送関数 writeMns(destinationId, payload) を使用してトピックデータを MNS トピックに転送するように設定するスクリプトです。

  関数の詳細については、「関数リスト」をご参照ください。

制限事項

• MNS へのデータ転送は、特定のリージョンにある IoT Platform インスタンスでのみサポートされています。サポートされているリージョンの詳細については、「リージョン別の機能の可用性」をご参照ください。

• 新旧両バージョンのデータ転送機能が MNS へのデータ転送をサポートしています。旧バージョンの使用例については、「Message Service へのデータ転送 (旧バージョン)」をご参照ください。

• IoT Platform インスタンスからのデバイスメッセージ転送に関する制限事項の詳細については、「制限事項」をご参照ください。

データ送信先の作成

1. IoT Platform コンソールにログインします。

2. [概要] ページで、管理したいインスタンスを見つけ、インスタンス ID またはインスタンス名をクリックします。

3. 左側のナビゲーションウィンドウで、[メッセージ転送] > [データ転送] を選択します。

4. [データ転送] ページの右上隅にある [新しいバージョンへ] をクリックします。

   説明

   以前にこの操作を実行したことがある場合は、自動的に [データ転送] ページの新しいバージョンにリダイレクトされます。

5. [データ送信先] タブをクリックします。このタブで、[データ送信先の作成] をクリックします。

6. [データ送信先の作成] ダイアログボックスで、データ送信先の名前 (例：DataPurpose) を入力します。次の表の説明に従ってパラメーターを設定し、[OK] をクリックします。

   パラメーター	説明
   操作を選択	[Message Service (MNS) にデータを転送] を選択します。
   リージョン	Message Service が有効化されているリージョンを選択します。
   トピック	データを受信するために使用する SMQ トピックを選択します。 SMQ は、受信したメッセージをこのトピック配下の HTTP およびキューのサブスクリプションに転送します。現在、IoT Platform が SMQ トピックにプッシュするメッセージは、HTTP またはキューメソッドでのみサブスクライブできます。 [トピックの作成] をクリックして Simple Message Queue (formerly MNS) コンソールに移動し、SMQ トピックとサブスクリプションを作成できます。詳細については、「Simple Message Queue (SMQ) ドキュメント」をご参照ください。
   ロール	IoT Platform に Simple Message Queue (formerly MNS) へのデータ書き込み権限を付与します。 RAM ロールが存在しない場合は、[RAM ロールの作成] をクリックして RAM コンソールで RAM ロールと権限付与ポリシーを作成します。RAM ロールの作成

パーサの設定と開始

1. DataParser という名前のパーサを作成します。詳細については、「ステップ 1：パーサの作成」をご参照ください。

2. [パーサ詳細] ページで、パーサを作成したデータソースに関連付けます。

   1. ウィザードの [データソース] ステップで、[データソースの関連付け] をクリックします。

   2. 表示されたダイアログボックスで、[データソース] ドロップダウンリストから DataSource を選択し、次に [OK] をクリックします。

3. [パーサ詳細] ページで、パーサを作成したデータ送信先に関連付けます。

   1. ウィザードで [データ送信先] をクリックします。[データ送信先] セクションで、[データ送信先の関連付け] をクリックします。

   2. 表示されたダイアログボックスで、[データ宛先] ドロップダウンリストから DataPurpose を選択し、次に [OK] をクリックします。

   3. [データ送信先] セクションで、[データ送信先 ID] を表示して保存します。この例では、ID は 1000 です。

      パーサスクリプトを作成する際は、[データ送信先 ID] を使用する必要があります。

4. [パーサ詳細] ページで、[パーサ] をクリックします。

5. スクリプトエディタにパーサスクリプトを入力します。

   パーサスクリプトの構文は JavaScript に似ています。スクリプトの編集方法の詳細については、「スクリプト構文」をご参照ください。

   関数のパラメーターの詳細については、「関数リスト」をご参照ください。

   // payload() 関数を使用して、デバイスから報告されたメッセージ本文を取得し、JSON 形式に変換します。
   var data = payload("json");
   // TSL モデルデータを直接転送します。
   writeMns(1000, data);

6. [テスト] をクリックします。画面の指示に従ってプロダクトとデバイスを選択し、トピックとペイロードデータを入力して、スクリプトが実行可能であることを確認します。

   以下にパラメーターのサンプルを示します。サンプルトピック：/{productKey}/{deviceName}/thing/event/property/post。サンプルのペイロード JSON には、items 内に 2 つのプロパティが含まれています：

   • Temperature：値は 38、時間は 1626948134319

   • Humidity：値は 25、時間は 1626948134319

   以下の出力は、スクリプトの実行が成功したことを示します。

   出力は action: transmit to mns[destinationId=1000] です。

7. [公開] をクリックします。

8. [データ転送] ページの [パーサ] タブに移動します。DataParser パーサを見つけ、[操作] 列の [開始] をクリックしてパーサを開始します。

次のステップ

• [IoT プラットフォームログ] タブで、[デバイスからクラウドへのメッセージ] と [データ転送] の運用ログを表示できます。このタブに移動するには、IoT Platform コンソールに移動し、ご利用のインスタンスを見つけて、[O&M] > [Log Service] を選択します。詳細については、「IoT プラットフォームログ」をご参照ください。

• Simple Message Queue (旧称：MNS) コンソールにログインして、MNS トピックからキューにプッシュされたメッセージを表示できます。詳細については、「メッセージの受信」をご参照ください。

参考資料

• デバイスを IoT Platform に接続してデータを報告する方法については、「デバイス接続ガイド」をご参照ください。

• インスタンス詳細ページで利用可能なメッセージ転送 TPS リソースを確認し、デバイスメッセージが Simple Message Queue (formerly MNS) に転送されて消費されることを確認します。詳細については、「インスタンス情報と運用データの表示」をご参照ください。リソースが不足している場合は、インスタンスをスペックアップします。詳細については、「インスタンスのスペックアップ」をご参照ください。

• Simple Message Queue (formerly MNS) トピックのメトリックを表示して、受信したメッセージの数を確認できます。詳細については、「トピックメトリックの表示」をご参照ください。

• ログ管理機能を使用して、メッセージトピックの操作ログを Simple Log Service にプッシュします。メッセージ消費中に例外が発生した場合は、MessageId でメッセージトレースをクエリして問題を診断します。詳細については、「Simple Log Service へのログのプッシュ」および「Simple Log Service でのログの表示」をご参照ください。