Tutoriel : envoyer la télémétrie de ressources au cloud en utilisant un flux de données

Important

Opérations Azure IoT Préversion avec Azure Arc est actuellement en préversion. Vous ne devez pas utiliser ce logiciel en préversion dans des environnements de production.

Vous devrez déployer une nouvelle installation d’Opérations Azure IoT lorsqu’une version en disponibilité générale sera disponible. Vous ne pourrez pas mettre à niveau une installation en préversion.

Pour connaître les conditions juridiques qui s’appliquent aux fonctionnalités Azure en version bêta, en préversion ou plus généralement non encore en disponibilité générale, consultez l’Avenant aux conditions d’utilisation des préversions de Microsoft Azure.

Dans ce tutoriel, vous utilisez un flux de données pour transférer des messages du répartiteur MQTT vers un hub d’événements dans le service Azure Event Hubs. Le hub d’événements peut fournir les données à d’autres services cloud pour leur stockage et leur analyse. Dans le tutoriel suivant, vous utilisez un tableau de bord en temps réel pour visualiser les données.

Prérequis

Avant de commencer ce tutoriel, vous devez terminer le Tutoriel : Ajouter des ressources OPC UA à votre cluster Préversion Opérations Azure IoT.

Quel problème résoudrons-nous ?

Pour utiliser un outil tel que le tableau de bord en temps réel pour analyser vos données OPC UA, vous devez envoyer les données à un service cloud tel qu’Azure Event Hubs. Un flux de données peut s’abonner à une rubrique MQTT et transférer les messages à un hub d’événements dans votre espace de noms Azure Event Hubs. Le guide de tutoriel suivant vous montre comment utiliser des tableaux de bord en temps réel pour visualiser et analyser vos données.

Définir vos variables d’environnement

Si vous utilisez l’environnement Codespaces, les variables d’environnement obligatoires sont déjà définies et vous pouvez ignorer cette étape. Sinon, définissez les variables d’environnement suivantes dans votre interpréteur de commandes :

Bash

# The name of the resource group where your Kubernetes cluster is deployed
RESOURCE_GROUP=<resource-group-name>

# The name of your Kubernetes cluster
CLUSTER_NAME=<kubernetes-cluster-name>

PowerShell

# The name of the resource group where your Kubernetes cluster is deployed
$RESOURCE_GROUP = "<resource-group-name>"

# The name of your Kubernetes cluster
$CLUSTER_NAME = "<kubernetes-cluster-name>"

Créer un espace de noms Event Hubs

Pour créer un espace de noms Event Hubs et un Event Hub, exécutez les commandes Azure CLI suivantes dans votre interpréteur de commandes. Ces commandes créent l’espace de noms Event Hubs dans le même groupe de ressources que votre cluster Kubernetes :

Bash

az eventhubs namespace create --name ${CLUSTER_NAME:0:24} --resource-group $RESOURCE_GROUP --disable-local-auth true

az eventhubs eventhub create --name destinationeh --resource-group $RESOURCE_GROUP --namespace-name ${CLUSTER_NAME:0:24} --retention-time 1 --partition-count 1 --cleanup-policy Delete

PowerShell

az eventhubs namespace create --name $CLUSTER_NAME.Substring(0, [MATH]::Min($CLUSTER_NAME.Length, 24)) --resource-group $RESOURCE_GROUP --disable-local-auth true

az eventhubs eventhub create --name destinationeh --resource-group $RESOURCE_GROUP --namespace-name $CLUSTER_NAME.Substring(0, [MATH]::Min($CLUSTER_NAME.Length, 24)) --retention-time 1 --partition-count 1 --cleanup-policy Delete

Pour accorder à l’extension Azure IoT Operations dans votre cluster l’accès à votre espace de noms Event Hubs, exécutez les commandes Azure CLI suivantes :

Bash

EVENTHUBRESOURCE=$(az eventhubs namespace show --resource-group $RESOURCE_GROUP --namespace-name ${CLUSTER_NAME:0:24} --query id -o tsv)

PRINCIPAL=$(az k8s-extension list --resource-group $RESOURCE_GROUP --cluster-name $CLUSTER_NAME --cluster-type connectedClusters -o tsv --query "[?extensionType=='microsoft.iotoperations'].identity.principalId")

az role assignment create --role "Azure Event Hubs Data Sender" --assignee $PRINCIPAL --scope $EVENTHUBRESOURCE

PowerShell

$EVENTHUBRESOURCE = $(az eventhubs namespace show --resource-group $RESOURCE_GROUP --namespace-name $CLUSTER_NAME.Substring(0, [MATH]::Min($CLUSTER_NAME.Length, 24)) --query id -o tsv)

$PRINCIPAL = $(az k8s-extension list --resource-group $RESOURCE_GROUP --cluster-name $CLUSTER_NAME --cluster-type connectedClusters -o tsv --query "[?extensionType=='microsoft.iotoperations'].identity.principalId")

az role assignment create --role "Azure Event Hubs Data Sender" --assignee $PRINCIPAL --scope $EVENTHUBRESOURCE

Créer un flux de données pour envoyer des données de télémétrie à un hub d’événements

Utilisez l’interface utilisateur de l’expérience des opérations pour créer et configurer un flux de données dans votre cluster qui :

• Renomme le champ Tag 10 dans le message entrant en Humidity.
• Renomme le champ temperature dans le message entrant en Temperature.
• Ajoute un champ appelé AssetId qui contient le nom de l'actif.
• Transfère les messages transformés de la rubrique MQTT vers l’Event Hub que vous avez créé.

Pour la création du flux de données :

1. Accédez à l’interface utilisateur de l’expérience des opérations et recherchez votre instance. Sélectionnez ensuite points de terminaison de flux de données , puis + Nouveau dans la vignette Azure Event Hubs :

   

2. Dans le Créer un point de terminaison de flux de données : Azure Event Hubs, entrez event-hubs-target comme nom et mettez à jour le champ Hôte avec l’adresse de l’espace de noms Event Hubs que vous avez créé. Sélectionnez Appliquer :

   

   Votre nouveau point d'arrivée de flux de données est créé et s'affiche dans la liste de la page Points de terminaison de flux de données.

3. Sélectionnez Flux de données, puis sélectionnez + Créer un flux de données. La page <nouveau flux de données> s’affiche :

   

4. Dans l’éditeur de flux de données, sélectionnez Sélectionner une source. Sélectionnez ensuite la ressource thermostat que vous avez créée précédemment et sélectionnez Appliquer.

5. Dans l’éditeur de flux de données, sélectionnez Sélectionner le point de terminaison de flux de données. Sélectionnez ensuite le point de terminaison event-hubs-target que vous avez créé précédemment et sélectionnez Appliquer.

6. Dans la page suivante, entrez destinationeh comme rubrique. La rubrique fait référence au hub que vous avez créé dans l’espace de noms Event Hubs. Sélectionnez Appliquer. Votre flux de données dispose désormais de la ressource thermostat comme source et d’un hub dans votre espace de noms Event Hubs comme destination.

7. Pour ajouter une transformation, sélectionnez Ajouter une transformation (facultatif).

8. Pour renommer les champs Tag 10 et temperature dans le message entrant, sélectionnez + Ajouter dans la vignette Renommer.

9. Ajoutez les deux transformations de renommage suivantes :

   Datapoint	Nouveau nom de point de données
   Balise 10.Value	ThermostatHumidity
   température.Valeur	ThermostatTemperature

   La transformation du nom ressemble à la capture d'écran suivante :

   

   Sélectionnez Appliquer.

10. Pour ajouter un champ d’ID de ressource au message, sélectionnez la zone Transformations dans l’éditeur, puis sélectionnez + Ajouter dans la vignette Nouvelle propriété.

11. Dans l’éditeur Nouvelle propriété , entrez AssetId comme clé de propriété, thermostat-01 comme valeur de propriété, puis sélectionnez Appliquer. L'éditeur de flux de données ressemble maintenant à la capture d'écran suivante :

    

12. Pour démarrer le flux de données en cours d’exécution, entrez tutoriel-flux de données comme nom, puis sélectionnez Enregistrer. Après quelques minutes, l’état d’approvisionnement passe à réussi. Le flux de données est maintenant en cours d’exécution dans votre cluster.

Votre flux de données s’abonne à une rubrique MQTT pour recevoir des messages de la ressource thermostat. Il renomme certains des champs du message et transfère les messages transformés au hub d’événements que vous avez créé.

Vérifier que les données circulent

Pour vérifier que les données circulent vers le cloud, vous pouvez afficher votre instance Event Hubs dans le Portail Azure. Il se peut que vous deviez attendre quelques minutes pour que le flux de données démarre et que les messages circulent vers le Event Hub.

Si les messages circulent vers l’instance, vous pouvez voir le nombre de messages entrants sur la page Vue d’ensemble de l’instance :

Si des messages circulent, vous pouvez utiliser Data Explorer pour afficher les messages :

Conseil

Vous devez peut-être vous attribuer le rôle Récepteur de données Azure Event Hubs pour l’espace de noms Event Hubs afin d’afficher les messages.

Comment avons-nous résolu le problème ?

Dans ce tutoriel, vous avez utilisé un flux de données pour connecter une rubrique MQTT à un hub d’événements dans votre espace de noms Azure Event Hubs. Dans le tutoriel suivant, vous utilisez Microsoft Fabric Real-Time Intelligence pour visualiser les données.

Nettoyer les ressources

Si vous passez au tutoriel suivant, conservez toutes vos ressources.

Si vous voulez supprimer le déploiement d’Opérations Azure IoT mais conserver votre cluster, utilisez la commande az iot ops delete :

az iot ops delete --cluster $CLUSTER_NAME --resource-group $RESOURCE_GROUP

Si vous voulez supprimer toutes les ressources que vous avez créées pour ce démarrage rapide, supprimez le cluster Kubernetes où vous avez déployé Opérations Azure IoT, puis supprimez le groupe de ressources Azure qui contenait le cluster.

Si vous avez utilisé Codespaces pour ces démarrages rapides, supprimez votre codespace de GitHub.

Remarque

Le groupe de ressources contient l’espace de noms Event Hubs que vous avez créé dans ce tutoriel.

Étape suivante

Tutoriel : Obtenir des insights à partir de la télémétrie de vos ressources