IoT Platform:Forward data to Lindorm

Limits

You can use only the new version of the data forwarding feature to forward data to Lindorm.

Create a data destination

1. Log on to the IoT Platform console.

2. On the Overview page, click All environment. On the All environment tab, find the instance that you want to manage and click the instance ID or instance name.

3. In the left-side navigation pane, choose Message Forwarding > Data Forwarding.

4. In the upper-right corner of the Data Forwarding page, click Go to New Version to go to the new version.

   Note

   If you have performed this step, the Data Forwarding page of the new version appears after you choose Message Forwarding > Data Forwarding.

5. Click Data Destination. On the Data Destination tab, click Create Data Destination.

6. In the Create Data Destination dialog box, enter a name for the data destination. Example: DataPurpose. Configure other parameters and click OK. The following table describes the parameters.

   Parameter	Description
   Operation	Select Store Data to ApsaraDB for Lindorm.
   Authorize	Click Authorize. The system automatically creates a role and a policy that authorize IoT Platform to write data to Lindorm. For more information, see AliyunServiceRoleForIoTRuleengineLindorm. Note If IoT Platform is already authorized, skip this step.
   Region	Specify the region where the IoT Platform instance resides.
   Lindorm Instance	Specify the Lindorm instance that you created in a VPC.
   Database	Specify the name of the database that you want to use to receive data. The database must belong to the Lindorm instance.
   Table Name	Specify the name of the table that you want to use to receive data. The table must belong to the database.
   Account	Specify the name of the account and the corresponding password that you want to use to manage the time series database. For more information about database management accounts and passwords, see User and permission management.
   Password

Configure and start a parser

1. Create a parser named DataParser. For more information, see Create a parser.

2. On the Parser Details page, associate the parser with the created data source.

   1. In the Data Source step of the wizard, click Associate Data Source.

   2. In the dialog box that appears, select DataSource from the Data Source drop-down list, and then click OK.

3. On the Parser Details page, associate the parser with the created data destination.

   1. Click Data Destination in the wizard. In the Data Destination section, click Associate Data Destination.

   2. In the dialog box that appears, select DataPurpose from the Data Destination drop-down list, and then click OK.

   3. In the Data Destination section, view and save the data destination ID. In this example, the ID is 1000.

      When you write the parser script, you must use the data destination ID.

4. On the Parser Details page, click Parser.

5. In the code editor, enter a script. For more information about how modify a script, see Script syntax.

   For more information about function parameters, see Functions.

   // Call the payload() function to obtain the data that is submitted by a device and convert the data to JSON-formatted data. 
   var data = payload("json");
   // Filter the submitted temperature and humidity values. 
   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();
   // Forward the submitted TSL data. 
   writeLindorm(1000, timestamp, tags, fields);

   Note

   If the data type of the corresponding table field in the Lindorm database is Double but the data type of the humidity value that is submitted by the device is INT, you must use the following code to change the data type of the field to Double to ensure successful data forwarding:

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

6. Click Debugging. In the dialog box that appears, select a product and a device, specify a topic, and then enter payload data to check whether the script runs as expected.

   The following figure shows the parameters.

   The following result indicates that the script is executed:

   

7. Click Publish.

8. Go to the Parser tab of the Data Forwarding page. Find the DataParser parser and click Start in the Actions column to start the parser.

9. Simulate the device to submit TSL data and view the data forwarding result. For more information, see Device simulation.

   After the data that is submitted by the simulated device is forwarded to the Lindorm time series database, you can call the query operation of a LindormTSDB SDK to obtain the forwarded data.