Gegevens verwerken en routeren met gegevensstromen
Met gegevensstromen kunt u verschillende gegevensbronnen verbinden en gegevensbewerkingen uitvoeren, waardoor het instellen van gegevenspaden wordt vereenvoudigd om gegevens te verplaatsen, transformeren en verrijken. Het gegevensstroomonderdeel maakt deel uit van Azure IoT Operations, dat wordt geïmplementeerd als een Azure Arc-extensie. De configuratie voor een gegevensstroom wordt uitgevoerd via aangepaste Kubernetes-resourcedefinities (CRD's).
U kunt configuraties schrijven voor verschillende gebruiksvoorbeelden, zoals:
- Gegevens transformeren en terugsturen naar MQTT
- Gegevens transformeren en verzenden naar de cloud
- Gegevens verzenden naar de cloud of edge zonder transformatie
Gegevensstromen zijn niet beperkt tot de regio waar het IoT Operations-exemplaar wordt geïmplementeerd. U kunt gegevensstromen gebruiken om gegevens naar cloudeindpunten in verschillende regio's te verzenden.
Belangrijkste functies
Dit zijn de belangrijkste functies van gegevensstromen.
Gegevensverwerking en routering
Met gegevensstromen kunt u de opname, verwerking en routering van de berichten naar opgegeven sinks inschakelen. U kunt het volgende opgeven:
- Bronnen: Waar berichten worden opgenomen vanuit
- Bestemmingen: waar berichten worden leeggezogen naar
- Transformaties (optioneel): configuratie voor gegevensverwerkingsbewerkingen
Transformatiemogelijkheden
Transformaties kunnen tijdens de verwerkingsfase op gegevens worden toegepast om verschillende bewerkingen uit te voeren. Deze bewerkingen kunnen het volgende omvatten:
- Nieuwe eigenschappen berekenen: Op basis van bestaande eigenschappen in het bericht
- Naam van eigenschappen wijzigen: gegevens standaardiseren of verduidelijken
- Eenheden converteren: Waarden converteren naar verschillende maateenheden
- Waarden standaardiseren: eigenschapswaarden schalen naar een door de gebruiker gedefinieerd bereik
- Gegevens contextualiseren: Referentiegegevens toevoegen aan berichten voor verrijking en het stimuleren van inzichten
Configuratie en implementatie
De configuratie wordt opgegeven met behulp van Kubernetes CRD's. Op basis van deze configuratie maakt de gegevensstroomoperator gegevensstroomexemplaren om hoge beschikbaarheid en betrouwbaarheid te garanderen.
Vergoedingen
- Vereenvoudigde installatie: eenvoudig verbinding maken met gegevensbronnen en bestemmingen.
- Flexibele transformaties: voer een breed scala aan gegevensbewerkingen uit.
- Schaalbare configuratie: Gebruik Kubernetes CRD's voor schaalbare en beheerbare configuraties.
- Hoge beschikbaarheid: De systeemeigen Kubernetes-resource zorgt voor betrouwbaarheid.
Met behulp van gegevensstromen kunt u uw gegevenspaden efficiënt beheren. U kunt ervoor zorgen dat gegevens nauwkeurig worden verzonden, getransformeerd en verrijkt om te voldoen aan uw operationele behoeften.
Schemaregister
Schemaregister, een functie van Azure Device Registry, is een gesynchroniseerde opslagplaats in de cloud en aan de rand. In het schemaregister worden de definities opgeslagen van berichten die afkomstig zijn van edge-assets en wordt vervolgens een API beschikbaar gemaakt voor toegang tot deze schema's aan de rand. Zuidkomende connectors zoals de connector voor OPC UA kunnen berichtschema's maken en deze toevoegen aan het schemaregister of klanten kunnen schema's uploaden naar de webgebruikersinterface voor bewerkingen.
Gegevensstromen maken gebruik van berichtenschema's om het bericht te transformeren in de indeling die wordt verwacht door het doeleindpunt.
Zie Berichtschema's begrijpen voor meer informatie.