Verarbeiten und Weiterleiten von Daten mit Dataflows
Mit Dataflows können Sie verschiedene Datenquellen verbinden, Datenvorgänge ausführen und das Einrichten von Datenpfaden zum Verschieben, Transformieren und Anreichern von Daten vereinfachen. Die Datenflusskomponente ist Teil von „Azure IoT Einsatz“, was als Azure Arc-Erweiterung bereitgestellt wird. Die Konfiguration für einen Datenfluss erfolgt über Kubernetes-CRDs (Custom Resource Definitions).
Sie können Konfigurationen für verschiedene Anwendungsfälle schreiben, z. B.:
- Transformieren von Daten und Senden an MQTT
- Transformieren von Daten und Senden an die Cloud
- Senden von Daten an die Cloud oder den Edge ohne Transformation
Datenflüsse sind nicht auf die Region beschränkt, in der die Instanz von „IoT Einsatz“ bereitgestellt wird. Sie können Dataflows verwenden, um Daten an Cloudendpunkte in verschiedenen Regionen zu senden.
Schlüsselfunktionen
Im Folgenden sind die Hauptfunktionen von Datenflüssen aufgelistet.
Datenverarbeitung und -routing
Datenflüsse ermöglichen die Erfassung, Verarbeitung und das Routing der Nachrichten an angegebene Senken. Sie können Folgendes angeben:
- Quellen: wo Nachrichten erfasst werden
- Ziele: wo Nachrichten hingeleitet werden
- Transformationen (optional): Konfiguration für Datenverarbeitungsvorgänge
Transformationsfunktionen
Transformationen können während der Verarbeitungsphase auf Daten angewendet werden, um verschiedene Vorgänge auszuführen. Zu diesen Vorgängen gehören:
- Neue Eigenschaften berechnen: basierend auf vorhandenen Eigenschaften in der Nachricht
- Eigenschaften umbenennen: um Daten zu standardisieren oder zu präzisieren
- Einheiten konvertieren: Konvertieren von Werten in verschiedene Maßeinheiten
- Werte standardisieren: Skalieren der Eigenschaftswerte in einen benutzerdefinierten Bereich
- Daten kontextualisieren: Hinzufügen von Referenzdaten zu Nachrichten zur Anreicherung und Förderung von Erkenntnissen
Konfiguration und Bereitstellung
Die Konfiguration wird mithilfe von Kubernetes-CRDs angegeben. Basierend auf dieser Konfiguration erstellt der Datenflussbetreiber Datenflussinstanzen und sorgt so für Hochverfügbarkeit und Zuverlässigkeit.
Vorteile
- Vereinfachtes Setup: Einfaches Verbinden von Datenquellen und Zielen.
- Flexible Transformationen: Durchführen verschiedenster Datenvorgänge.
- Skalierbare Konfiguration: Verwenden von Kubernetes-CRDs für skalierbare und verwaltbare Konfigurationen.
- Hochverfügbarkeit: Native Kubernetes-Ressource sorgt für Zuverlässigkeit.
Mithilfe von Datenflüssen können Sie Ihre Datenpfade effizient verwalten. Sie können sicherstellen, dass Daten korrekt gesendet, transformiert und angereichert werden, um Ihren betrieblichen Anforderungen gerecht zu werden.
Schemaregistrierung
Die Schemaregistrierung ist ein Feature, das von der Azure Device Registry bereitgestellt wird und ist ein synchronisiertes Repository in der Cloud und am Edge. In der Schemaregistrierung werden die Definitionen von Nachrichten gespeichert, die von Edgeobjekten stammen, und anschließend wird eine API für den Zugriff auf diese Schemata am Edge verfügbar gemacht. Southbound-Connectors wie der Connector für OPC UA können Nachrichtenschemata erstellen und sie der Schemaregistrierung hinzufügen, oder Kunden können Schemata in die Web-Benutzeroberfläche von Azure IoT Einsatz hochladen.
Dataflows verwenden Nachrichtenschemas, um die Nachricht in das vom Zielendpunkt erwartete Format zu transformieren.
Weitere Informationen finden Sie unter Grundlegendes zu Nachrichtenschemata.