Traiter et acheminer des données avec des flux de données
Les flux de données vous permettent de connecter différentes sources de données et d’effectuer des opérations sur les données, ce qui simplifie la configuration des chemins de données pour déplacer, transformer et enrichir les données. Le composant de flux de données fait partie d’Opérations Azure IoT, qui est déployé en tant qu’extension Azure Arc. La configuration pour un flux de données est effectuée via les définitions de ressources personnalisées (CRD) de Kubernetes.
Vous pouvez rédiger des configurations pour différents cas d’utilisation, comme par exemple :
- Transformer les données et les renvoyer à MQTT
- Transformer les données et les envoyer dans le cloud
- Envoyer des données vers le cloud ou en périphérie sans transformation
Les flux de données ne sont pas limités à la région où l’instance Opérations IoT est déployée. Vous pouvez utiliser des flux de données pour envoyer des données à des points de terminaison du cloud dans différentes régions.
Fonctionnalités clés
Voici les principales fonctionnalités des flux de données.
Traitement et acheminement des données
Les flux de données permettent l’ingestion, le traitement et l’acheminement des messages vers des récepteurs spécifiques. Vous pouvez spécifier les valeurs suivantes :
- Sources : Emplacement où sont ingérés les messages
- Destinations: Emplacement vers lesquels les messages sont acheminés
- Transformations (facultatif) : Configuration des opérations de traitement des données
Fonctionnalités de transformation
Les transformations peuvent être appliquées aux données au cours de la phase de mise en lots afin d’effectuer diverses 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
Configuration et déploiement
La configuration est spécifiée à l’aide des CRD de Kubernetes. Sur la base de cette configuration, l’opérateur de flux de données crée des instances de flux de données pour garantir une disponibilité et une fiabilité élevées.
Avantages
- Configuration simplifiée : Connecter facilement les sources de données et les destinations.
- Transformations flexibles : Effectuer un large éventail d’opérations sur les données.
- Configuration évolutive : Utiliser les CRD de Kubernetes pour des configurations évolutives et gérables.
- Haute disponibilité : La ressource native de Kubernetes garantit la fiabilité.
En utilisant des flux de données, vous pouvez gérer efficacement vos chemins de données. Vous pouvez vous assurer que les données sont correctement envoyées, transformées et enrichies pour répondre à vos besoins opérationnels.
Registre de schémas
Le registre de schéma est une fonctionnalité fournie par le Registre de Dispositifs Azure. Il s’agit d’un référentiel synchronisé dans le cloud et à la périphérie. Le registre de schémas stocke les définitions des messages provenant des ressources de périphérie, puis expose une API pour accéder à ces schémas à la périphérie. Les connecteurs vers des composants de niveau inférieur comme le Connecteur OPC UA peuvent créer des schémas de message et les ajouter au registre de schéma. Les clients peuvent également charger des schémas dans l’interface utilisateur web de l’expérience Opérations.
Les flux de données utilisent des schémas de messages pour transformer le message dans le format attendu par le point de terminaison de destination.
Pour plus d’informations, consultez Comprendre les schémas de message.