Bearbeta händelsedata med redigeringsprogrammet för händelseprocessorn
Med händelseprocessorn i Lakehouse-målet kan du bearbeta dina data innan de matas in i Lakehouse-målet. Händelseprocessorredigeraren är en kodfri upplevelse som ger dig dra och släpp-upplevelsen för att utforma logiken för händelsedatabearbetning. Den här artikeln beskriver hur du använder redigeringsprogrammet för händelseprocessorn för att utforma bearbetningslogik.
Viktigt
Microsoft Fabric är för närvarande i förhandsversion. Den här informationen gäller en förhandsversionsprodukt som kan ändras avsevärt innan den släpps. Microsoft lämnar inga garantier, uttryckta eller underförstådda, med avseende på den information som tillhandahålls här.
Förutsättningar
För att komma igång måste du uppfylla följande krav:
- Få åtkomst till en premiumarbetsyta med deltagarbehörigheter eller högre behörigheter där din eventstream finns.
- Få åtkomst till en premiumarbetsyta med deltagarbehörigheter eller högre behörigheter där ditt lakehouse finns.
Utforma händelsebearbetningen med redigeraren
Följ stegen för att öppna redigeraren för händelseprocessorn och använda den för att utforma händelsebearbetningen.
Skapa ett Lakehouse-mål och ange nödvändiga parametrar i den högra rutan.
Välj Öppna händelseprocessorn för att öppna redigeraren för händelseprocessorn i den högra rutan.
I redigeraren för händelseprocessorn kan du välja noden eventstream för att förhandsgranska dess dataschema, byta namn på kolumnen eller ändra datatypen i det högra fönstret.
Välj operatorn från menyn Åtgärder i menyfliksområdet för att lägga till logiken för händelsebearbetning. Till exempel Hantera fält.
Välj linjen mellan eventstream och lakehouse och tryck på borttagningsnyckeln för att ta bort anslutningen mellan dem för att infoga operatorn Hantera fält mellan dem.
Välj den gröna cirkeln på den vänstra kanten av händelseströmsnoden och håll ned och flytta musen för att ansluta den till operatornoden Hantera fält. På samma sätt ansluter du operatornoden Hantera fält till Lakehouse-noden.
Välj operatornoden Hantera fält . I konfigurationspanelen Hantera fält väljer du de fält som du vill mata ut. Om du vill lägga till alla fält väljer du Lägg till alla fält. Du kan också lägga till ett nytt fält med Build-in Functions för att aggregera data från överordnad. För närvarande är de inbyggda funktioner som vi stöder vissa funktioner i String Functions, Date and Time Functions, Mathematical Functions.
När fälten Hantera har konfigurerats kan du förhandsgranska de data som ska skapas med den här operatorn genom att klicka på Uppdatera statisk förhandsversion.
Om det uppstår något konfigurationsfel meddelas du av fliken Redigeringsfel i det nedre fönstret.
Om allt är som förväntat när du har förhandsgranskat data kan du välja Klar för att slutföra händelsebearbetningsdesignen och återgå till konfigurationsfönstret för Lakehouse-målet för att skapa ditt Lakehouse-mål.
Redigerare för händelseprocessor
Med händelseprocessorn kan du transformera de data som matas in till målet. Det är tillgängligt för Lakehouse-typen av destination. När du konfigurerar ditt Lakehouse-mål hittar du avsnittet "Händelsebearbetning" i mitten av den högra panelen. Därifrån kan du öppna redigeraren för händelseprocessorn för att definiera datatransformeringslogik med dra och släpp-upplevelsen.
Händelseprocessorredigeraren innehåller en arbetsyta och ett nederkant fönster så att du kan:
Skapa logiken för händelsedatatransformering med dra och släpp-upplevelsen.
Förhandsgranska data i var och en av bearbetningsnoderna från början till slutet.
Identifiera redigeringsfelen i dessa bearbetningsnoder.
Hela vylayouten liknar huvudredigeraren. Den består av:
- Arbetsyta med diagramvy: det är den plats där du kan utforma datatransformeringslogiken genom att välja operatorn från menyn "Åtgärder" i menyfliksområdet. Sedan kan du ansluta eventstream-noden, operatornoderna och målnoden genom att dra raden. Om du vill ta bort anslutningen mellan två noder kan du välja raden mellan de två noderna och trycka på borttagningsnyckeln.
- Höger redigeringsfönster: det är den plats där du kan konfigurera den valda åtgärdsnoden eller visa schemat för händelseströmmen och målet.
- Det nedre fönstret med flikarna dataförhandsgranskning och redigeringsfel: det är den plats där du kan förhandsgranska data i den valda noden med fliken Dataförhandsgranskning. Det ger dig upplevelsen av "vad du ser är vad du får". Du kan också identifiera redigeringsfelen när något inte har konfigurerats korrekt eller helt i åtgärdsnoderna.
Mer information om hur du använder redigeraren för händelseprocessorn för att definiera datatransformeringslogik finns i Bearbeta händelsedata med redigeraren för händelseprocessor.
Transformeringsoperatorer
Händelseprocessorn tillhandahåller sex operatorer som du kan använda för att transformera dina händelsedata enligt dina affärsbehov.
Aggregera
Du kan använda aggregeringstransformeringen för att beräkna en aggregering (Summa, Minimum, Maximum eller Average) varje gång en ny händelse inträffar under en tidsperiod. Med den här åtgärden kan du också filtrera eller segmentera aggregeringen baserat på andra dimensioner i dina data. Du kan ha en eller flera sammansättningar i samma transformering.
Visa
Använd Expand array transformation ( Expandera matristransformering) för att skapa en ny rad för varje värde i en matris.
Filtrera
Använd filtertransformeringen för att filtrera händelser baserat på värdet för ett fält i indata. Beroende på datatypen (tal eller text) behåller omvandlingen de värden som matchar det valda villkoret.
Gruppera efter
Använd Gruppera efter transformering för att beräkna aggregeringar för alla händelser inom ett visst tidsfönster. Du kan gruppera efter värdena i ett eller flera fält. Det är som aggregeringstransformeringen men innehåller fler alternativ för aggregering. Den innehåller också mer komplexa alternativ för tidsfönster. Precis som Med aggregering kan du lägga till mer än en aggregering per transformering.
De aggregeringar som är tillgängliga i omvandlingen är:
- Genomsnitt
- Antal
- Maximal
- Minimum
- Percentil (kontinuerlig och diskret)
- Standardavvikelse
- Sum
- Varians
I tidsströmningsscenarier är det vanligt att utföra åtgärder på data som finns i temporala fönster. Fönsterfunktionerna stöds i händelseprocessorn och integreras med Group by-operatorn. Du kan definiera det i inställningen för den här operatorn.
Hantera fält
Med transformeringen Hantera fält kan du lägga till, ta bort eller byta namn på fält som kommer in från en indata eller en annan transformering. Inställningarna i sidofönstret ger dig möjlighet att lägga till ett nytt genom att välja Lägg till fält eller lägga till alla fält samtidigt.
Du kan också lägga till ett nytt fält med Build-in Functions för att aggregera data från överordnad. De inbyggda funktioner som vi stöder är för närvarande några funktioner i String Functions, Date and Time Functions och Mathematical Functions.
Union
Använd uniontransformeringen för att ansluta två eller flera noder för att lägga till händelser som har delade fält (med samma namn och datatyp) i en tabell. Fält som inte matchar tas bort och ingår inte i utdata.