Rutedatastrømme baseret på indhold i Fabric-hændelsesstrømme
I denne artikel kan du se, hvordan du distribuerer hændelser baseret på indhold i Microsoft Fabric-hændelsesstrømme.
Du kan nu bruge editoren uden kode på hovedlærredet for Fabric-hændelsesstrømme til at oprette kompleks behandlingslogik for stream uden at skrive kode. Med denne funktion kan du nemmere skræddersy, transformere og administrere dine datastreams. Når du har angivet behandlingshandlinger for dine streams, kan du uden problemer sende dine datastrømme til forskellige destinationer i henhold til det specifikke skema og de specifikke streamdata.
Understøttede handlinger
Her er listen over de handlinger, der understøttes til databehandling i realtid:
Aggregering: Understøtter funktionerne SUM, AVG, MIN og MAX, der udfører beregninger på en kolonne med værdier og returnerer et enkelt resultat.
Udvid: Udvid en matrixværdi, og opret en ny række for hver værdi i en matrix.
Filter: Vælg eller filtrer bestemte rækker i datastrømmen baseret på en betingelse.
Gruppér efter: Aggreger alle hændelsesdata i et bestemt tidsrum med mulighed for at gruppere en eller flere kolonner.
Administrer felter: Tilføj, fjern eller skift datatype for et felt eller en kolonne i dine datastrømme.
Forening: Forbind to eller flere datastreams med delte felter med samme navn og datatype til én datastream. Felter, der ikke stemmer overens, fjernes.
Deltag: Kombiner data fra to streams baseret på en matchende betingelse mellem dem.
Understøttede destinationer
De understøttede destinationer er:
Lakehouse: Denne destination giver dig mulighed for at transformere dine begivenheder i realtid, før du indtages i dit lakehouse. Hændelser i realtid konverteres til Delta Lake-format og gemmes derefter i de angivne lakehouse-tabeller. Denne destination hjælper med datawarehousing-scenarier.
Eventhouse: Denne destination giver dig mulighed for at indtage dine hændelsesdata i realtid i Eventhouse, hvor du kan bruge det effektive KQL (Kusto Query Language) til at forespørge og analysere dataene. Med dataene i Eventhouse kan du få dybere indsigt i dine hændelsesdata og oprette omfattende rapporter og dashboards.
Fabric Activator: Denne destination giver dig mulighed for direkte at forbinde dine hændelsesdata i realtid til en Fabric Activator. Activator er en type intelligent agent, der indeholder alle de oplysninger, der er nødvendige for at oprette forbindelse til data, overvåge betingelser og handle. Når dataene når visse tærskler eller stemmer overens med andre mønstre, udfører Aktivator automatisk de nødvendige handlinger, f.eks. at advare brugerne eller starte Power Automate-arbejdsprocesser.
Brugerdefineret slutpunkt (tidligere brugerdefineret app): Med denne destination kan du nemt distribuere dine hændelser i realtid til et brugerdefineret program. Denne destination giver dig mulighed for at forbinde dine egne programmer til eventstream og forbruge hændelsesdataene i realtid. Det er nyttigt, når du vil overføre data i realtid til et eksternt system uden for Microsoft Fabric.
Stream: Denne destination repræsenterer den rå standardhændelsesstrøm, der transformeres af en række handlinger, også kaldet en afledt stream. Når den er oprettet, kan du få vist streamen fra hubben Realtid.
I følgende eksempel kan du se, hvordan tre særskilte Fabric-eventstream-destinationer kan fungere som separate funktioner for en enkelt datakilde. Et Eventhouse er udpeget til lagring af rådata, et andet Eventhouse er til opbevaring af filtrerede datastrømme, og Lakehouse bruges til lagring af aggregerede værdier.
Hvis du vil transformere og distribuere din datastream baseret på indhold, skal du følge trinnene i Rediger og publicere en hændelsesstream og begynde at designe streambehandlingslogik for din datastream.