Bearbeta och dirigera data med dataflöden

Dataflöden förenklar konfigurationen av datavägar för att flytta, transformera och berika data. Genom att använda dataflöden kan du ansluta olika datakällor och utföra dataåtgärder. Dataflödeskomponenten är en del av Azure IoT Operations som du distribuerar som ett Azure Arc-tillägg. Du konfigurerar ett dataflöde med hjälp av webbgränssnittet för driftsmiljön, Azure CLI eller Azure Resource Manager mallar.

Du kan skriva konfigurationer för olika användningsfall, till exempel:

• Transformera data och skicka tillbaka dem till MQTT.
• Transformera data och skicka dem till molnet.
• Skicka data till molnet eller edge utan omvandling.

Dataflöden är inte begränsade till den region där du distribuerar IoT Operations-instansen. Du kan använda dataflöden för att skicka data till molnslutpunkter i olika regioner.

Nyckelfunktioner

I det här avsnittet beskrivs de viktigaste funktionerna i dataflöden.

Databearbetning och routning

Dataflöden möjliggör inmatning, bearbetning och routning av meddelanden till angivna mottagare. Du kan ange:

• Källor: Där du matar in meddelanden från.
• Mål: Dit du vidarebefordrar meddelanden, inklusive stöd för dynamisk ämnesstyrd routning baserat på meddelandeinnehåll för MQTT-slutpunkter.
• Transformeringar (valfritt): Konfiguration för databearbetningsåtgärder.

Transformeringsfunktioner

Du kan använda transformeringar på data under bearbetningsfasen för att utföra olika åtgärder. Dessa åtgärder kan omfatta:

• Beräkna nya egenskaper: Baserat på befintliga egenskaper i meddelandet.
• Byta namn på egenskaper: För att standardisera eller förtydliga data.
• Konvertera enheter: Konvertera värden till olika måttenheter.
• Standardisera värden: Skala egenskapsvärden till ett användardefinierat intervall.
• Kontextualisera data: Lägg till referensdata i meddelanden för berikande och drivande insikter.

Konfiguration och distribution

Ange konfigurationen med hjälp av webbgränssnittet för driftsmiljön, Azure CLI eller Azure Resource Manager mallar. Baserat på den här konfigurationen skapar dataflödesoperatorn dataflödesinstanser för att säkerställa hög tillgänglighet och tillförlitlighet.

Förmåner

• Förenklad konfiguration: Anslut enkelt datakällor och mål.
• Flexibla transformeringar: Utför en mängd olika dataåtgärder.
• Scalable configuration: Använd Azure verktyg för skalbara och hanterbara konfigurationer.
• Hög tillgänglighet: Kubernetes interna resurs garanterar tillförlitlighet.

Genom att använda dataflöden kan du effektivt hantera dina datasökvägar. Du kan se till att data skickas, transformeras och berikas korrekt för att uppfylla dina operativa behov.

Schemaregister

Schemaregister, en funktion som tillhandahålls av Azure Device Registry, är en synkroniserad lagringsplats i molnet och vid gränsen. Schemaregistret lagrar definitionerna av meddelanden som kommer från gränstillgångar och exponerar sedan ett API för åtkomst till dessa scheman vid gränsen. Sydgående kopplare som kopplaren för OPC UA kan skapa meddelandescheman och lägga till dem i schemaregistret, eller så kan du ladda upp scheman till driftswebbgränssnittet.

Dataflöden använder meddelandescheman för att omvandla meddelandet till det format som förväntas av målslutpunkten.

Mer information finns i Förstå meddelandescheman.

Databuffertning och diskpersistence

När ett dataflöde skickar meddelanden till en målslutpunkt kan målet eller nätverket bli otillgängligt. Om leveransen inte kan slutföras bekräftar dataflödet inte källmeddelandet. MQTT-brokern lagrar meddelandet i prenumerantens kö och dataflödet försöker leverera på nytt.

Information om beteende vid avbrott på målet, brokers prenumerantköer, diskstödd meddelandebuffert, brokerpersistens och dataflöden requestDiskPersistencefinns i Konfigurera databuffring och diskpersistens för dataflöden.

Relaterat innehåll

• Dataflöden jämfört med dataflödesdiagram
• Översikt över dataflödesdiagram
• Skapa ett dataflöde
• Konfigurera en dataflödeskälla
• Skapa en dataflödesslutpunkt
• Självstudie: Skicka meddelanden från tillgångar till molnet med hjälp av ett dataflöde