IoT Platform:Reenviar datos a Tablestore

Requisitos previos

• Ha conectado un dispositivo a una instancia Enterprise Edition. Para obtener más información, consulte Connect a device and report data.

• Ha activado Tablestore. Para obtener más información, consulte Activate Tablestore.

Crear una tabla de datos

1. Inicie sesión en la consola de Tablestore. En la barra de navegación superior, seleccione la región Japan (Tokyo).

   Importante

   Si utiliza una instancia Enterprise Edition de IoT Platform, la instancia de Tablestore debe encontrarse en la misma región que su instancia de IoT Platform.

2. Haga clic en Create Instance. En el cuadro de diálogo Create Instance, introduzca un nombre de instancia, por ejemplo, IoTDataStore; mantenga los valores predeterminados para los demás parámetros y haga clic en OK.

   Para obtener más información, consulte Create a Tablestore instance.

3. En la pestaña Instance Details de la instancia IoTDataStore, haga clic en Create Table. Introduzca un nombre para la tabla de datos, como iot_data, y agregue dos claves principales: deviceName (String) y timestamp (Integer). Para obtener más información, consulte Create a data table.

Configurar una regla de reenvío de datos

1. En el panel de navegación izquierdo de la instancia IoT Test Environment, vaya a Rules Engine > Data Forwarding.

2. En la página Data Forwarding, haga clic en Create Rule.

   Importante

   Si aparece la página Data Forwarding de la versión más reciente, haga clic en Back to Previous Version en la esquina superior derecha de la página. Cuando aparezca la página Data Forwarding de la versión anterior, haga clic en Create Rule.

3. En el cuadro de diálogo Create Data Forwarding Rule, introduzca un nombre de regla, como ThermostatDataForwarding; establezca Data Format en JSON y haga clic en OK.

4. Después de crear la regla, aparece la página Data Forwarding Rules. En esta página, escriba una instrucción SQL para procesar los datos del mensaje y configure un destino de reenvío de datos.

   La página tiene dos secciones: Process Data y Forward Data. La sección Process Data contiene la instrucción de consulta de la regla y un botón Write SQL, mientras que la sección Forward Data enumera los destinos de datos y cuenta con un botón Add Operation.

   1. Haga clic en Write SQL. En el cuadro de diálogo que aparece, introduzca los campos para la cláusula SELECT. Como origen de datos del tema, seleccione TSL Data Reporting para Data Type, Home Thermostat para Product, Device1 para Device, Default Module para Module y thing/event/property/post para topic. Haga clic en OK.

      La cláusula SELECT para este ejemplo es la siguiente:

      items.temperature.value as temperature, items.humidity.value as humidity,deviceName() as deviceName,timestamp() as time

      Para obtener más información sobre cómo escribir consultas SQL, consulte SQL expressions y Functions.

      La sección Rule Query Statement en la parte superior del cuadro de diálogo muestra la instrucción SQL completa. La sección Topic en la parte inferior muestra los parámetros seleccionados.

   2. En la sección Forward Data, haga clic en Add Operation para establecer la tabla de datos iot_data como destino de reenvío de datos. Para obtener más información, consulte Forward data to Tablestore.

      En el cuadro de diálogo Edit Operation, seleccione Forward data to Tablestore para Operation. Seleccione China (Shanghai) para Region, IoTDataStore para Instance e iot_data para Data Table. En Primary Key, establezca el valor de la clave deviceName en ${deviceName} y el valor de la clave timestamp en ${time}. Seleccione AliyunIOTAccessingOTSRole para Role y haga clic en OK.

      @props:intl

      Configure los siguientes parámetros en el cuadro de diálogo Edit Operation:

      • Operation: Forward data to Tablestore

      • Region: Japan (Tokyo)

      • Instance: IoTDataStore

      • Data Table: iot_data

      • Primary Key: deviceName, value: ${deviceName}

      • Primary Key: timestamp, value: ${time}

      • Role: AliyunIOTAccessingOTSRole

      @/props

5. Una vez completada la configuración, regrese a la página Data Forwarding. Busque la regla que creó y haga clic en Start en la columna Actions. Una vez iniciada, la regla reenvía los datos según lo configurado.

   Después de que el dispositivo virtual reporte datos, puede consultarlos en tiempo real en la tabla de datos iot_data dentro de Tablestore.

   La tabla de datos contiene cuatro campos: deviceName (clave principal), timestamp (clave principal), humidity y temperature. Cada fila representa una lectura de temperatura y humedad reportada por el dispositivo.

   También puede consultar los registros completos de reenvío en Log Service para su instancia Enterprise Edition con el fin de solucionar problemas de reenvío.

   En la pestaña Cloud Run Logs, seleccione el Product correspondiente para ver las entradas de registro. Las entradas incluyen información como Time, TraceID, MessageId, Message Content, DeviceName, Business Type, Action, Content y Status. Puede rastrear el flujo de datos filtrando por Business Type, como Rules Engine o TSL. Un Status de 200 indica que el procesamiento de datos fue exitoso.

Siguientes pasos

Subscribe to device messages on the server side