IoT Platform:Lindorm にデータを転送する

制限事項

新しいバージョンのデータ転送機能のみを使用して、データを Lindorm に転送できます。

データ宛先の作成

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

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

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

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

   説明

   このステップを実行した場合、[メッセージ転送] > [データ転送] を選択すると、新しいバージョンの [データ転送] ページが表示されます。

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

6. [データ宛先の作成] ダイアログボックスで、データ宛先の名前を入力します。例: DataPurpose。他のパラメーターを設定し、[OK] をクリックします。次の表にパラメーターを示します。

   パラメーター	説明
   操作	[ApsaraDB For Lindorm にデータを保存] を選択します。
   承認	[承認] をクリックします。システムは、IoT Platform が Lindorm にデータを書き込むことを承認するロールとポリシーを自動的に作成します。詳細については、「AliyunServiceRoleForIoTRuleengineLindorm」をご参照ください。 説明 IoT Platform がすでに承認されている場合は、このステップをスキップしてください。
   リージョン	IoT Platform インスタンスが存在するリージョンを指定します。
   Lindorm インスタンス	VPC で作成した Lindorm インスタンスを指定します。
   データベース	データの受信に使用するデータベースの名前を指定します。データベースは Lindorm インスタンスに属している必要があります。
   テーブル名	データの受信に使用するテーブルの名前を指定します。テーブルはデータベースに属している必要があります。
   アカウント	時系列データベースの管理に使用するアカウントの名前と対応するパスワードを指定します。 詳細については、「ユーザーと権限の管理」をご参照ください。
   パスワード

パーサーの設定と開始

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

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

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

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

3. [パーサーの詳細] ページで、パーサーを作成済みのデータ宛先に関連付けます。

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

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

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

      パーサースクリプトを記述するときは、[データ宛先 ID] を使用する必要があります。

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

5. コードエディタにスクリプトを入力します。詳細については、「スクリプト構文」をご参照ください。

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

   // payload() 関数を呼び出して、デバイスから送信されたデータを取得し、JSON 形式のデータに変換します。
   var data = payload("json");
   // 送信された温度と湿度の値をフィルタリングします。
   var h = data.items.Humidity.value;
   var t = data.items.Temperature.value;
   
   var fields = {"temperature":t, "humidity":h};
   var tags = {"device_id": deviceName(), "region": "cn-shanghai"};
   var timestamp = timestamp();
   // 送信された TSL データを転送します。
   writeLindorm(1000, timestamp, tags, fields);

   説明

   Lindorm データベースの対応するテーブルフィールドのデータ型が Double であるが、デバイスから送信された湿度値のデータ型が INT である場合、データ転送を成功させるために、次のコードを使用してフィールドのデータ型を Double に変更する必要があります。

   varfields={        
              "temperature":t,        
              "humidity":{            
                 "type":"DOUBLE",            
                 "value":h        
              }    
   };

6. [デバッグ] をクリックします。表示されるダイアログボックスで、プロダクトとデバイスを選択し、Topic を指定してから、ペイロードデータを入力してスクリプトが期待どおりに実行されるかどうかを確認します。

   次の図にパラメーターを示します。

   次の結果は、スクリプトが実行されたことを示します。

   

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

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

9. デバイスをシミュレートして TSL データを送信し、データ転送結果を表示します。詳細については、「デバイスシミュレーション」をご参照ください。

   シミュレートされたデバイスによって送信されたデータが Lindorm 時系列データベースに転送された後、LindormTSDB SDK のクエリ操作を呼び出して、転送されたデータを取得できます。