IoT Platform:Transférer des données vers Message Queue for Apache RocketMQ

Prérequis

• Vous avez créé une instance IoT Platform dans une région prenant en charge le transfert de données vers Message Queue for Apache RocketMQ. Pour plus d'informations, consultez la page Disponibilité des fonctionnalités par région.

• Vous avez créé une source de données nommée DataSource et y avez ajouté un sujet de communication TSL. Pour plus d'informations, consultez la section Ajouter une source de données.

• Vous avez créé une instance ApsaraMQ for RocketMQ et un sujet pour recevoir les données. Consultez le guide Démarrage rapide d'ApsaraMQ for RocketMQ.

Notes d'utilisation

• Vous pouvez utiliser la nouvelle ou l'ancienne version de la fonctionnalité de transfert de données pour envoyer des données vers Message Queue for Apache RocketMQ. Pour savoir comment utiliser l'ancienne version, consultez la page Transférer des données vers ApsaraMQ for RocketMQ.

Créer une destination de données

1. Connectez-vous à la console IoT Platform.

2. Sur la page Overview, repérez l'instance à gérer et cliquez sur son ID ou son nom.

3. Dans le volet de navigation de gauche, sélectionnez Message Forwarding > Data Forwarding.

4. Sur la page Data Forwarding, cliquez sur Go to New Version dans le coin supérieur droit.

   Remarque

   Si vous avez déjà effectué cette opération, vous êtes automatiquement redirigé vers la nouvelle version de la page Data Forwarding.

5. Cliquez sur l'onglet Data destination, puis sur Create data destination.

6. Dans la boîte de dialogue Create Data Destination, saisissez un nom pour la destination de données. Dans cet exemple, nous utilisons DataPurpose. Configurez les paramètres et cliquez sur OK.

   

   Parameter	Description
   Operation	Sélectionnez Forward data to ApsaraMQ for RocketMQ.
   Region	Sélectionnez la région de l'instance ApsaraMQ for RocketMQ.
   Instance	Sélectionnez une instance ApsaraMQ for RocketMQ. Cliquez sur Create Instance pour en créer une depuis la console ApsaraMQ for RocketMQ. Consultez la documentation ApsaraMQ for RocketMQ documentation.
   Topic	Sélectionnez le sujet ApsaraMQ for RocketMQ qui recevra les données d'IoT Platform. Cliquez sur Create Topic pour en créer un depuis la console ApsaraMQ for RocketMQ.
   Grant permissions	Accordez à IoT Platform un accès en écriture à ApsaraMQ for RocketMQ. Si aucun rôle RAM n'existe, cliquez sur Create RAM Role pour créer un rôle RAM et une stratégie d'autorisation depuis la console RAM. Consultez la section Create a RAM role.

Configurer et démarrer un analyseur

1. Créez un analyseur, par exemple DataParser. Pour plus d'informations, consultez la section Step 1: Create a parser.

2. Sur la page Resolver Details, associez la source de données.

   1. Dans l'assistant de configuration, sous la section Data Source, cliquez sur Associate Data Source.

   2. Dans la boîte de dialogue, sélectionnez DataSource dans la liste déroulante Data Source et cliquez sur OK.

3. Sur la page Resolver Details, associez les destinations de données.

   1. Dans l'assistant de configuration, cliquez sur Data Destination. Ensuite, dans le coin supérieur droit de la liste Data Destination, cliquez sur Associate Data Destination.

   2. Dans la boîte de dialogue qui s'affiche, sélectionnez DataPurpose dans la liste déroulante Data Destination et cliquez sur OK.

   3. Dans la liste des destinations de données, repérez l'Data Destination ID et notez-le. Par exemple, 1000.

      Vous aurez besoin de cet Data Destination ID dans le script d'analyse.

4. Sur la page parser details, cliquez sur l'onglet Parser Script.

5. Dans l'éditeur de code, saisissez un script. Pour savoir comment modifier un script, consultez la section Script syntax.

   Pour plus d'informations sur les paramètres des fonctions, consultez la page Function list.

   // Use the payload() function to obtain the data that is submitted by devices and convert the data to JSON-formatted data. 
   var data = payload("json");
   // Forward submitted TSL data. 
   writeMq(1000, data, "debug");

6. Cliquez sur Debugging. Dans le panneau qui s'affiche, sélectionnez un produit et un appareil, spécifiez un sujet, puis saisissez les données de charge utile pour vérifier que le script s'exécute comme prévu.

   La figure suivante illustre les paramètres.

   Le résultat suivant indique que le script s'exécute correctement.

   

7. Cliquez sur Publish.

8. Revenez à l'onglet Resolver sur la page Data Forwarding et cliquez sur Start pour l'analyseur DataParser.

9. Dans la console Message Queue for Apache RocketMQ, vérifiez si le message a bien été reçu.