Utilisez le moteur de règles pour transférer des données vers DataHub. Vous pouvez ensuite acheminer ces données depuis DataHub vers Realtime Compute for Apache Flink ou MaxCompute pour traitement. Cette rubrique décrit le processus de transfert de données. Dans cet exemple, un topic de communication TSL (Thing Specification Language) sert de topic source.
Prérequis
Une instance IoT Platform dont les données peuvent être transférées vers DataHub est créée dans une région prenant en charge le transfert de données vers DataHub. Pour plus d'informations sur les régions compatibles, consultez la page Régions.
Une source de données nommée DataSource est créée et un TSL communication topic is added to the data source. Pour plus d'informations, consultez la page Créer une source de données.
-
Un projet DataHub et un topic destiné à recevoir les données sont créés. Pour plus d'informations sur l'utilisation de DataHub, consultez la page Gérer les projets.
ImportantSi vous utilisez une instance Enterprise Edition, le projet DataHub doit se trouver dans la même région que l'instance Enterprise Edition.
Notes d'utilisation
Vous pouvez utiliser la nouvelle version ou la version précédente de la fonctionnalité de transfert de données pour envoyer des données vers DataHub. Pour plus d'informations sur l'utilisation de la version précédente, consultez la page Transférer des données vers DataHub (à l'aide de la version précédente de la fonctionnalité).
Créer une destination de données
Connectez-vous à la console IoT Platform.
Sur la page Overview, localisez l'instance à gérer et cliquez sur son ID ou son nom.
Dans le volet de navigation de gauche, accédez à .
-
Sur la page Data Forwarding, cliquez sur Go to New Version dans le coin supérieur droit.
RemarqueSi vous avez déjà effectué cette opération, vous êtes automatiquement redirigé vers la nouvelle version de la page Data Forwarding.
Cliquez sur l'onglet Data Destination. Sur cet onglet, cliquez sur Create Data Destination.
-
Dans la boîte de dialogue Create Data Destination, saisissez un nom pour la destination de données. Par exemple : DataPurpose. Configurez les autres paramètres et cliquez sur OK. Le tableau suivant décrit les paramètres.
Parameter
Description
Operation
Sélectionnez Send data to DataHub.
Region
Sélectionnez la région où se trouve votre projet DataHub.
Project
Sélectionnez un projet DataHub.
Vous pouvez cliquer sur Create Project pour accéder à la console DataHub et créer un projet. Pour plus d'informations, consultez la page Opérations relatives aux projets.
Topic
Sélectionnez le topic DataHub qui recevra les données.
Après la sélection d'un topic, le moteur de règles récupère automatiquement le schéma du topic et y mappe les données filtrées.
Remarque-
Lors du mappage des données au schéma, utilisez
${}. Sinon, le système stockera une constante dans la table. -
Les types de données du schéma doivent correspondre aux types de données traités par le moteur de règles. Sinon, le système ne pourra pas stocker les données.
Vous pouvez cliquer sur Create Topic pour accéder à la console DataHub et créer un topic DataHub.
Role
Sélectionnez le rôle RAM qui accorde à IoT Platform l'autorisation d'écrire des données dans DataHub.
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 dans la console RAM. Créer un rôle RAM.
-
Configurer et démarrer un analyseur
Créez un analyseur nommé DataParser. Pour plus d'informations, consultez la section Étape 1 : Créer un analyseur.
-
Sur la page Parser Details, associez l'analyseur à la source de données créée.
À l'étape Data Source de l'assistant, cliquez sur Associate Data Source.
Dans la boîte de dialogue qui s'affiche, sélectionnez DataSource dans la liste déroulante Data Source, puis cliquez sur OK.
-
Sur la page Parser Details, associez l'analyseur à la destination de données créée.
Cliquez sur Data Destination dans l'assistant. Dans la section Data Destination, cliquez sur Associate Data Destination.
Dans la boîte de dialogue qui s'affiche, sélectionnez DataPurpose dans la liste déroulante Data Destination, puis cliquez sur OK.
-
Dans la section Data Destination, consultez et enregistrez l'data destination ID. Dans cet exemple, l'ID est 1000.
Lors de la rédaction du script de l'analyseur, vous devez utiliser l'data destination ID.
Sur la page Parser Details, cliquez sur Parser.
-
Dans l'éditeur de code, saisissez un script. Pour savoir comment modifier un script, consultez la section Syntaxe des scripts.
Pour plus d'informations sur les paramètres de fonction, consultez la page Fonctions.
// Use the payload() function to obtain data that is submitted by devices and convert the data to the JSON format. var data = payload("json"); // Forward the submitted TSL data. writeDatahub(1000, data); -
Cliquez sur Debugging. Dans la boîte de dialogue qui s'affiche, sélectionnez un produit et un appareil, spécifiez un topic, puis saisissez les données de charge utile pour vérifier si le script s'exécute comme prévu.
La figure suivante illustre les paramètres.

Le résultat suivant indique que le script a été exécuté :

Cliquez sur Publish.
Accédez à l'onglet Parser de la page Data Forwarding. Localisez l'analyseur DataParser et cliquez sur Start dans la colonne Actions pour démarrer l'analyseur.