Partager via

Traitement des messages dans une solution IoT

Cette vue d’ensemble présente les concepts clés relatifs au traitement des messages envoyés à partir de vos ressources et appareils dans une solution Azure IoT classique. Chaque section inclut des liens vers du contenu qui fournit des détails et des conseils supplémentaires.

Le diagramme suivant montre une vue générale des composants d’une solution IoT basée sur la périphérie classique. Cet article se concentre sur les composants de traitement des messages d’une solution IoT basée sur la périphérie.

Diagramme montrant l’architecture de solution IoT basée sur la périphérie de haut niveau mettant en évidence les zones de traitement des messages.

Dans Azure IoT, le traitement des messages fait référence à des processus tels que le routage et l’enrichissement des messages envoyés par les ressources et les appareils. Ces processus permettent de contrôler le flux de messages via la solution IoT et d’ajouter des informations supplémentaires aux messages.

Acheminer les messages

Pour acheminer les messages de vos ressources vers différents points de terminaison, Azure IoT Operations utilise des flux de données. Les points de terminaison de destination peuvent se trouver dans le cloud ou en périphérie. La liste des points de terminaison de destination disponibles inclut :

Type de point de terminaison Description
MQTT Pour la messagerie bidirectionnelle avec les répartiteurs MQTT, notamment l’une intégrée aux opérations Azure IoT et Event Grid.
Kafka Pour la messagerie bidirectionnelle avec les brokers Kafka, y compris Azure Event Hubs.
Data Lake Pour charger des données dans des comptes de stockage Azure Data Lake Gen2.
Microsoft Fabric OneLake Pour charger des données dans Microsoft Fabric OneLake lakehouses.
Explorateur de données Azure Pour charger des données dans des bases de données Azure Data Explorer.
Stockage local Pour l’envoi de données à un volume persistant disponible localement, éventuellement configurable avec Stockage Conteneur Azure activé par Azure Arc.

L’interface utilisateur web de l’expérience des opérations fournit un environnement sans code pour la création et l’exécution de vos flux de données.

Pour une sécurité renforcée dans les données routées vers vos points de terminaison, les secrets synchronisés cloud/edge sont utilisés dans les points de terminaison de flux de données pour l’authentification.

Bien que les flux de données vous permettent de configurer le routage à la périphérie, vous pouvez également définir le routage dans le cloud. Si votre flux de données envoie des messages à Azure Event Grid, vous pouvez utiliser ses fonctionnalités de routage pour déterminer où envoyer les messages.

Pour plus d’informations, consultez Traiter et router des données avec des flux de données.

Enrichir, transformer et traiter des messages

Les enrichissements et transformations peuvent être appliqués aux données pendant la phase de traitement pour effectuer différentes opérations. Ces opérations peuvent inclure :

  • Calculer de nouvelles propriétés : Sur la base des propriétés existantes dans le message
  • Renommer les propriétés : Pour normaliser ou clarifier les données
  • Convertir des unités : Convertir des valeurs en différentes unités de mesure
  • Normaliser les valeurs : Mettre à l’échelle des valeurs de propriété dans une plage définie par l’utilisateur
  • Contextualiser les données : Ajouter des données de référence aux messages pour les enrichir et générer des insights

Le registre de schémas stocke les schémas pour les messages provenant de vos ressources. Les flux de données utilisent ces schémas de message pour décoder les messages de différents formats afin qu’ils puissent être traités par des flux de données.

L’interface utilisateur web de l’expérience des opérations fournit un environnement sans code permettant de générer et d’exécuter les transformations dans vos flux de données.

Pour plus d’informations, consultez Enrichir les données à l’aide de flux de données.

Dans Azure IoT Operations, vous pouvez déployer vos propres applications edge hautement disponibles sur le cluster Kubernetes. Les applications edge peuvent interagir avec le répartiteur MQTT intégré pour :

  • Utiliser une logique de traitement personnalisé des messages sur les messages MQTT.
  • Générer une logique d’application personnalisée à exécuter en périphérie.
  • Exécutez des modèles d’IA Edge pour le traitement des données en temps réel et la prise de décision à la source de la génération de données, ce qui réduit la latence et l’utilisation de la bande passante.

Pour en savoir plus, consultez Développer des applications hautement disponibles pour le répartiteur MQTT Azure IoT Operations.

Autres services cloud

Vous pouvez utiliser d’autres services cloud pour traiter les messages de vos ressources et appareils.

Les points de terminaison de flux de données dans Azure IoT Operations vous permettent de vous connecter aux services cloud pour envoyer et recevoir des données de vos ressources. Un point de terminaison de flux de données est le point de connexion pour le flux de données.

Pour en savoir plus, consultez :

Dans IoT Hub et IoT Central, vous pouvez router les messages vers d’autres services. Par exemple, vous pouvez transférer des messages à Azure Stream Analytics pour analyser et traiter de grands volumes de données de streaming ou vers Azure Functions pour exécuter du code en réponse aux événements. Stream Analytics est également disponible sur le runtime Azure IoT Edge, ce qui lui permet de traiter des données à la périphérie plutôt que dans le cloud.

Pour en savoir plus, consultez :

Contenu connexe

  • Last updated on