IoT Platform:Transférer des données vers Tablestore

Prérequis

• Un appareil est connecté à une instance Enterprise Edition. Pour plus d'informations, consultez la rubrique Connecter un appareil et signaler des données.

• Tablestore est activé. Pour plus d'informations, consultez la rubrique Activer Tablestore.

Créer une table de données

1. Connectez-vous à la console Tablestore. Dans la barre de navigation supérieure, sélectionnez la région Japan (Tokyo).

   Important

   Si vous utilisez une instance Enterprise Edition d'IoT Platform, l'instance Tablestore doit se trouver dans la même région que votre instance IoT Platform.

2. Cliquez sur Create Instance. Dans la boîte de dialogue Create Instance, saisissez un nom d'instance, par exemple IoTDataStore, conservez les valeurs par défaut pour les autres paramètres, puis cliquez sur OK.

   Pour plus d'informations, consultez la rubrique Créer une instance Tablestore.

3. Sous l'onglet Instance Details de l'instance IoTDataStore, cliquez sur Create Table. Saisissez un nom pour la table de données, tel que iot_data, et ajoutez deux clés primaires : deviceName (String) et timestamp (Integer). Pour plus d'informations, consultez la rubrique Créer une table de données.

Configurer une règle de transfert de données

1. Dans le volet de navigation de gauche de l'instance IoT Test Environment, choisissez Rules Engine > Data Forwarding.

2. Sur la page Data Forwarding, cliquez sur Create Rule.

   Important

   Si la page Data Forwarding de la dernière version s'affiche, cliquez sur Back to Previous Version dans le coin supérieur droit de la page. Lorsque la page Data Forwarding de la version précédente s'affiche, cliquez sur Create Rule.

3. Dans la boîte de dialogue Create Data Forwarding Rule, saisissez un nom de règle, tel que ThermostatDataForwarding, définissez le format des données sur JSON, puis cliquez sur OK.

4. Une fois la règle créée, la page Data Forwarding Rules s'affiche. Sur cette page, rédigez une instruction SQL pour traiter les données des messages et configurez une destination de transfert de données.

   La page comporte deux sections : Process Data et Forward Data. La section Process Data contient l'instruction de requête de la règle et un bouton Write SQL, tandis que la section Forward Data répertorie les destinations de données et dispose d'un bouton Add Operation.

   1. Cliquez sur Write SQL. Dans la boîte de dialogue qui s'affiche, saisissez les champs de la clause SELECT. Pour la source de données de topic, sélectionnez TSL Data Reporting comme type de données, Home Thermostat comme produit, Device1 comme appareil, Default Module comme module et thing/event/property/post comme topic. Cliquez sur OK.

      La clause SELECT de cet exemple est la suivante :

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

      Pour plus d'informations sur la rédaction de requêtes SQL, consultez les rubriques Expressions SQL et Fonctions.

      La section Rule Query Statement en haut de la boîte de dialogue affiche l'instruction SQL complète. La section Topic en bas présente les paramètres sélectionnés.

   2. Dans la section Forward Data, cliquez sur Add Operation pour définir la table de données iot_data comme destination de transfert de données. Pour plus d'informations, consultez la rubrique Transférer des données vers Tablestore.

      Dans la boîte de dialogue Edit Operation, sélectionnez Forward data to Tablestore pour l'Operation. Sélectionnez China (Shanghai) pour la Region, IoTDataStore pour l'Instance et iot_data pour la Data Table. Sous Primary Key, définissez la valeur de la clé deviceName sur ${deviceName} et la valeur de la clé timestamp sur ${time}. Sélectionnez AliyunIOTAccessingOTSRole pour le Role et cliquez sur OK.

      @props:intl

      Configurez les paramètres suivants dans la boîte de dialogue Edit Operation :

      • Operation : Forward data to Tablestore

      • Region : Japan (Tokyo)

      • Instance : IoTDataStore

      • Data Table : iot_data

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

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

      • Role : AliyunIOTAccessingOTSRole

      @/props

5. Une fois les paramètres configurés, revenez à la page Data Forwarding. Recherchez la règle que vous avez créée et cliquez sur Start dans la colonne Actions. Une fois démarrée, la règle transfère les données selon la configuration.

   Après que l'appareil virtuel a signalé des données, vous pouvez consulter les données en temps réel dans la table de données iot_data de Tablestore.

   La table de données contient quatre champs : deviceName (clé primaire), timestamp (clé primaire), humidity et temperature. Chaque ligne représente une lecture de température et d'humidité signalée par l'appareil.

   Vous pouvez également consulter les journaux de transfert complets dans Log Service pour votre instance Enterprise Edition afin de résoudre les problèmes de transfert.

   Sous l'onglet Cloud Run Logs, sélectionnez le Product correspondant pour afficher les entrées de journal. Les entrées de journal incluent des informations telles que Time, TraceID, MessageId, Message Content, DeviceName, Business Type, Action, Content et Status. Vous pouvez suivre le flux de données en filtrant par Business Type, tel que Rules Engine ou TSL. Un Status de 200 indique un traitement réussi des données.

Étapes suivantes

S'abonner aux messages des appareils côté serveur