Dela via

Dirigera dataströmmar baserat på innehåll i Fabric-händelseströmmar (förhandsversion)

  • Artikel

Den här artikeln visar hur du dirigerar händelser baserat på innehåll i Microsoft Fabric-händelseströmmar.

Nu kan du använda redigeringsprogrammet utan kod i huvudarbetsytan för infrastrukturhändelseströmmar för att skapa komplex dataströmbearbetningslogik utan att skriva någon kod. Med den här funktionen kan du skräddarsy, transformera och hantera dina dataströmmar enklare. När du har konfigurerat dataströmbearbetningsåtgärderna kan du smidigt skicka dina dataströmmar till olika mål enligt det specifika schemat och strömma data.

Viktigt!

Förbättrade funktioner i Fabric-händelseströmmar är för närvarande i förhandsversion.

Åtgärder som stöds

Här är listan över åtgärder som stöds för databearbetning i realtid:

  • Aggregering: Stöd för sum-, AVG-, MIN- och MAX-funktioner som utför beräkningar på en kolumn med värden och returnerar ett enda resultat.

  • Expandera: Expandera ett matrisvärde och skapa en ny rad för varje värde i en matris.

  • Filter: Välj eller filtrera specifika rader från dataströmmen baserat på ett villkor.

  • Gruppera efter: Aggregera alla händelsedata inom ett visst tidsfönster, med alternativet att gruppera en eller flera kolumner.

  • Hantera fält: Lägg till, ta bort eller ändra datatypen för ett fält eller en kolumn i dina dataströmmar.

  • Union: Anslut två eller flera dataströmmar med delade fält med samma namn och datatyp i en dataström. Fält som inte matchar tas bort.

  • Anslut: Kombinera data från två strömmar baserat på ett matchande villkor mellan dem.

Mål som stöds

De mål som stöds är:

  • Lakehouse: Det här målet ger dig möjlighet att omvandla dina realtidshändelser före inmatning till ditt sjöhus. Realtidshändelser konverteras till Delta Lake-format och lagras sedan i de avsedda lakehouse-tabellerna. Det här målet hjälper till med datalagerscenarier.

  • KQL-databas: Med det här målet kan du mata in dina realtidshändelsedata i KQL Database, där du kan använda den kraftfulla Kusto-frågespråk (KQL) för att fråga och analysera data. Med data i KQL Database kan du få djupare insikter om dina händelsedata och skapa omfattande rapporter och instrumentpaneler.

  • Reflex: Med det här målet kan du ansluta dina realtidshändelsedata direkt till en Reflex. Reflex är en typ av intelligent agent som innehåller all information som krävs för att ansluta till data, övervaka villkor och agera. När data når vissa tröskelvärden eller matchar andra mönster vidtar Reflex automatiskt lämpliga åtgärder, till exempel att varna användare eller starta Power Automate-arbetsflöden.

  • Anpassad slutpunkt (tidigare anpassad app): Med det här målet kan du enkelt dirigera dina realtidshändelser till ett anpassat program. Med det här målet kan du ansluta dina egna program till händelseströmmen och använda händelsedata i realtid. Det är användbart när du vill utgående realtidsdata till ett externt system utanför Microsoft Fabric.

  • Ström: Det här målet representerar standardhändelseströmmen som transformeras av en serie åtgärder, även kallat en härledd ström. När du har skapat den kan du visa strömmen från realtidshubben.

I följande exempel visas hur tre distinkta fabric-eventstream-mål kan hantera separata funktioner för en enda dataströmkälla. En KQL-databas är avsedd för lagring av rådata, en andra KQL-databas används för att behålla filtrerade dataströmmar och Lakehouse används för att lagra aggregerade värden.

En skärmbild av routningshändelser baserat på innehåll.

Om du vill transformera och dirigera dataströmmen baserat på innehåll följer du stegen i Redigera och publicera en händelseström och börja utforma dataströmbearbetningslogik för dataströmmen.

Relaterat innehåll