Dela via

Bearbeta händelsedata med hjälp av redigeringsprogrammet för händelsebearbetning

Redigeringsprogrammet för händelsebearbetning är en kodfri upplevelse där du drar objekt för att utforma bearbetningslogik för händelsedata. Den här artikeln beskriver hur du använder redigeraren för att utforma bearbetningslogik.

Anteckning

Förbättrade funktioner aktiveras som standard när du skapar eventstreams. Om du har eventstreams som du har skapat via standardfunktioner fortsätter dessa händelseströmmar att fungera. Du kan fortfarande redigera och använda dem som vanligt. Vi rekommenderar att du skapar en ny händelseström för att ersätta standardhändelseströmmar så att du kan dra nytta av ytterligare funktioner och fördelar med förbättrade eventstreams.

Förutsättningar

  • Åtkomst till en arbetsyta i licensläget för Microsoft Fabric-kapacitet eller utvärderingslicensläget med Medverkande eller högre behörighet.

Utforma händelsebearbetning med hjälp av redigeraren

Följ dessa steg för att utföra bearbetningsåtgärder på dina dataströmmar med hjälp av ett redigeringsprogram utan kod:

  1. Välj Redigera i menyfliksområdet om du inte redan är i redigeringsläge . Kontrollera att den överordnade noden för de anslutna åtgärderna har ett schema.

    Skärmbild som visar redigeraren för händelsebearbetning i redigeringsläge.

  2. Om du vill infoga en händelsebearbetningsoperator mellan strömnoden och målet i redigeringsläge kan du använda någon av följande två metoder:

    • Infoga operatorn direkt från anslutningslinjen. Hovra över anslutningslinjen och välj sedan +-knappen. En nedrullningsbar meny visas på anslutningslinjen och du kan välja en operator från denna meny.

      Skärmbild som visar valet av plusknappen på anslutningslinjen.

    • Infoga operatorn från menyfliksområdet eller arbetsytan:

      1. I menyfliksområdet kan du välja en operator från menyn Transformera händelser .

        Skärmbild som visar valet av operatorn Hantera fält i menyfliksområdet.

        Du kan också hovra över en av noderna och sedan välja + knappen om du har tagit bort anslutningslinjen. En nedrullningsbar meny visas bredvid noden och du kan välja en operator i den här menyn.

        Skärmbild som visar plusknappen på anslutningslinjen.

      2. När du har infogat operatorn måste du återansluta dessa noder. Hovra över den vänstra kanten av strömnoden och dra sedan den gröna cirkeln för att ansluta den till operatornoden Hantera fält . Följ samma process för att ansluta operatornoden Hantera fält till målet.

        Skärmbild som visar hur du ansluter strömnoden till operatornoden.

  3. Välj operatornoden Hantera fält . I konfigurationsfönstret Hantera fält väljer du de fält som du vill använda för utdata. 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 hjälp av de inbyggda funktionerna för att aggregera data från uppströms. För närvarande är de inbyggda funktionerna som stöds strängfunktioner, datum- och tidsfunktioner och matematiska funktioner. Sök efter inbyggda för att hitta dem.

    Skärmbild som visar hur du väljer fält för utdata.

  4. När du har konfigurerat operatorn Hantera fält väljer du Uppdatera för att verifiera testresultatet som operatören producerar.

    Skärmbild som visar en uppdaterad sida.

  5. Om du har några konfigurationsfel visas de på fliken Redigeringsfel i det nedre fönstret.

    Skärmbild som visar fliken för redigeringsfel.

  6. Om testresultatet ser korrekt ut väljer du Publicera för att spara logiken för händelsebearbetning och återgå till livevyn .

    Skärmbild som visar knappen Publicera i menyfliksområdet.

  7. När du har slutfört föregående steg kan du visualisera hur händelseströmmen börjar strömma och bearbeta data i livevyn .

    Skärmbild som visar livevyn.

Transformera data med hjälp av redigeraren

Du kan använda redigeringsprogrammet för händelsebearbetning (arbetsytan i redigeringsläge ) för att omvandla data till olika mål. Ange Redigeringsläge för att utforma dataströmbearbetningsåtgärder för dina dataströmmar.

Skärmbild som visar redigeringsprogrammet för händelsebearbetning för en händelseström med förbättrade funktioner.

Redigeringsläget innehåller en arbetsyta och ett nedre fönster där du kan:

  • Skapa omvandlingslogik för händelsedata genom att dra.
  • Förhandsgranska testresultatet i var och en av bearbetningsnoderna från början till slut.
  • Identifiera eventuella redigeringsfel i bearbetningsnoderna.

Redigeringslayout

Redigeringsprogrammet för händelsebearbetning består av tre avsnitt numrerade i följande bild.

Skärmbild som visar layouten för redigeringsprogrammet för händelsebearbetning för en händelseström med förbättrade funktioner.

  1. I fönstret som innehåller menyfliksområdet och arbetsytan utformar du datatransformeringslogiken genom att välja en operator (från menyn Transformera händelser ) och ansluta strömmen och målnoderna via den nyligen skapade operatornoden. Du kan dra anslutningslinjer eller välja och ta bort anslutningar.

  2. I det högra redigeringsfönstret konfigurerar du den valda noden eller visar strömnamnet.

  3. I den nedre rutan förhandsgranskar du testresultatet i en vald nod med hjälp av fliken Testresultat . Fliken Redigeringsfel visar en lista över ofullständiga eller felaktiga konfigurationer i åtgärdsnoderna.

Nodtyper och exempel som stöds

Här är de destinationstyper som har stöd för att lägga till operatorer före datainsamling:

  • Sjöhus
  • Eventhouse (händelsebearbetning före inmatning)
  • Härlett flöde
  • Aktivare

Anteckning

För mål som inte stöder tillägg av en förinmatningsoperator kan du först lägga till en deriverad ström som utdata för operatorn. Lägg sedan till ditt avsedda mål i den här härledda dataströmmen.

Skärmbild som visar layouten för redigeringsprogrammet för händelsebearbetning med ett filter som skickar utdata till ett mål som inte stöds.

Händelseprocessorn i ett lakehouse och en KQL-databas låter dig bearbeta din data innan den matas in i din destination.

Förutsättningar

  • Åtkomst till en arbetsyta i licensläget för Microsoft Fabric-kapacitet eller utvärderingslicensläget med Medverkande eller högre behörighet.
  • Åtkomst till en arbetsyta med deltagare eller högre behörigheter där din lakehouse- eller KQL-databas finns.

Utforma händelsebearbetning med hjälp av redigeraren

  1. I den högra rutan lägger du till ett Lakehouse-mål och anger nödvändiga parametrar. Detaljerade instruktioner finns i Lägga till och hantera ett mål i en händelseström.

  2. Välj Öppna händelseprocessor.

    Skärmbild som visar knappen för att öppna händelseprocessorn i fönstret för att lägga till information om ett lakehouse-mål.

  3. På arbetsytan i redigeringsprogrammet för händelsebearbetning väljer du noden eventstream. Du kan förhandsgranska dataschemat eller ändra datatypen i fönstret Händelseström .

    Skärmbild som visar dataschemat i den högra rutan i redigeringsprogrammet för händelsebearbetning.

  4. Om du vill infoga en händelsebearbetningsoperator mellan den här händelseströmmen och målet i redigeringsprogrammet för händelsebearbetning kan du använda någon av följande två metoder:

    • Infoga operatorn direkt från anslutningslinjen. Hovra över anslutningslinjen och välj sedan +-knappen. En nedrullningsbar meny visas på anslutningslinjen och du kan välja en operator från denna meny.

      Skärmbild som visar var du ska hovra över anslutningslinjen för att infoga en nod.

    • Infoga operatorn från menyfliksområdet eller arbetsytan:

      1. I menyfliksområdet kan du välja en operator på menyn Åtgärder .

        Skärmbild som visar var du väljer en operator på menyn Åtgärder.

        Du kan också hovra över en av noderna och sedan välja + knappen om du har tagit bort anslutningslinjen. En nedrullningsbar meny visas bredvid noden och du kan välja en operator i den här menyn.

        Skärmbild som visar var du ska hovra över noder för att infoga en nod.

      2. Du måste återansluta noderna. Hovra över den vänstra kanten av händelseströmsnoden och dra sedan den gröna cirkeln för att ansluta den till operatornoden Hantera fält . Följ samma process för att ansluta operatornoden Hantera fält till Lakehouse-noden .

        Skärmbild som visar var noderna ska anslutas.

  5. Välj operatornoden Hantera fält . I konfigurationsfönstret Hantera fält väljer du de fält som du vill använda för utdata. 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 hjälp av de inbyggda funktionerna för att aggregera data från uppströms. För närvarande är de inbyggda funktionerna som stöds strängfunktioner, datum- och tidsfunktioner och matematiska funktioner. Sök efter inbyggda för att hitta dem.

    Skärmbild som visar hur du väljer fält för att konfigurera en operator.

  6. När du har konfigurerat operatorn Hantera fält väljer du Uppdatera statisk förhandsversion för att förhandsgranska de data som operatören skapar.

    Skärmbild som visar hur du förhandsgranskar data i redigeringsprogrammet för händelsebearbetning.

  7. Om du har några konfigurationsfel visas de på fliken Redigeringsfel i det nedre fönstret.

    Skärmbild som visar fliken för redigeringsfel i redigeringsredigeraren för händelsebearbetning.

  8. Om dina förhandsgranskningsdata ser korrekta ut väljer du Klar för att spara logiken för händelsebearbetning och återgå till konfigurationsinformationen för lakehouse-målet.

  9. Välj Lägg till för att slutföra skapandet av lakehouse-målet.

Transformera data med hjälp av redigeraren

Du kan använda redigeringsprogrammet för händelsebearbetning för att omvandla data som du matar in till ett lakehouse-mål. När du konfigurerar lakehouse-målet hittar du knappen Öppna händelseprocessor i fönstret för att konfigurera ett Lakehouse-mål .

Skärmbild som visar knappen för att öppna händelseprocessorn i fönstret för att konfigurera ett lakehouse-mål.

Om du väljer Öppna händelseprocessor öppnas redigeraren för händelsebearbetning. Redigeraren innehåller en arbetsyta och ett nedre fönster där du kan:

  • Skapa omvandlingslogik för händelsedata genom att dra.
  • Förhandsgranska data i var och en av bearbetningsnoderna från början till slut.
  • Identifiera eventuella redigeringsfel i bearbetningsnoderna.

Fönstrets layout är liknande huvudredigeraren. Den består av tre avsnitt numrerade i följande bild.

Skärmbild av redigeringsprogrammet för händelsebearbetning med de tre huvudavsnitten numrerade.

  1. I fönstret som innehåller arbetsytan med diagramvyn kan du utforma datatransformeringslogiken genom att välja en operator på menyn Åtgärder . Anslut sedan händelseströmmen och målnoderna via den nyligen skapade operatornoden. Du kan dra anslutningslinjer eller välja och ta bort anslutningar.

  2. I det högra redigeringsfönstret konfigurerar du den valda åtgärdsnoden eller visar schemat för händelseströmmen och målet.

  3. I den nedre rutan förhandsgranskar du data i en vald nod med hjälp av fliken Dataförhandsgranskning . Fliken Redigeringsfel visar en lista över ofullständiga eller felaktiga konfigurationer i åtgärdsnoderna.

Författarfel

Redigeringsfel är fel som uppstår i redigeringsprogrammet för händelsebearbetning på grund av ofullständig eller felaktig konfiguration av åtgärdsnoderna. De hjälper dig att hitta och åtgärda potentiella problem.

Varje redigeringsfel har fyra kolumner:

  • Nod-ID: Anger ID för åtgärdsnoden där redigeringsfelet inträffade.
  • Nodtyp: Anger typen av åtgärdsnod där redigeringsfelet inträffade.
  • Nivå: Anger allvarlighetsgraden för redigeringsfelet. Det finns två nivåer, Fatal och Information. Ett redigeringsfel på dödlig nivå innebär att redigeringsprogrammet för händelsebearbetning har allvarliga problem och inte kan sparas eller köras. Ett redigeringsfel på informationsnivå innebär att redigeringsprogrammet för händelsebearbetning har några tips eller förslag som kan hjälpa dig att optimera eller förbättra det.
  • Fel: Beskriver kort orsaken till och effekten av redigeringsfelet. Du kan välja fliken Visa information för att visa information.

Eftersom en händelseström och ett eventhouse stöder olika datatyper kan processen med att konvertera en datatyp generera redigeringsfel.

I följande tabell visas resultatet av datatypskonvertering från en händelseström till ett händelsehus. Kolumnerna representerar de datatyper som eventstream stöder. Raderna representerar de datatyper som eventhouse stöder. Cellerna visar konverteringsresultatet, som kan vara en av dessa tre symboler:

  • ✔️ Anger lyckad konvertering utan fel eller varningar.

  • ❌ Anger att konverteringen är omöjlig, vilket genererar ett redigeringsfel på dödlig nivå. Felmeddelandet liknar: "Datatypen "{1}" för kolumnen "{0}" matchar inte den förväntade typen "{2}" i den valda KQL-tabellen och kan inte konverteras automatiskt.

  • ⚠️ Anger att konverteringen är möjlig men felaktig, vilket genererar ett redigeringsfel på informationsnivå. Felmeddelandet liknar: "Datatypen "{1}" för kolumnen "{0}" matchar inte exakt den förväntade typen "{2}" i den valda KQL-tabellen. Den omvandlas automatiskt till "{2}".

sträng Bool datum och tid dynamisk riktlinje Int lång verklig / äkta tidsintervall decimaltecken
Int64 ❌ ❌ ❌ ✔️ ❌ ⚠️ ✔️ ⚠️ ❌ ✔️
Dubbel ❌ ❌ ❌ ✔️ ❌ ❌ ❌ ⚠️ ❌ ⚠️
Sträng ✔️ ❌ ❌ ✔️ ❌ ❌ ❌ ❌ ❌ ❌
DatumTid ⚠️ ❌ ✔️ ✔️ ❌ ❌ ❌ ❌ ❌ ❌
Register ⚠️ ❌ ❌ ✔️ ❌ ❌ ❌ ❌ ❌ ❌
Array ⚠️ ❌ ❌ ✔️ ❌ ❌ ❌ ❌ ❌ ❌

Som du ser i tabellen lyckas vissa datatypkonverteringar, till exempel sträng till sträng. Dessa konverteringar genererar inga redigeringsfel och de påverkar inte hur händelsebearbetningsredigeraren fungerar.

Vissa datatypkonverteringar är omöjliga, till exempel heltal till sträng. Dessa konverteringar genererar redigeringsfel på dödlig nivå och gör att redigeringsprogrammet för händelsebearbetning misslyckas med att spara. För att undvika dessa fel måste du ändra datatypen i din händelseström eller i KQL-tabellen.

Vissa datatypkonverteringar är möjliga men inte exakta, till exempel heltal till verkliga. Dessa konverteringar genererar redigeringsfel på informationsnivå som indikerar matchningsfel mellan datatyper och automatiska konverteringsresultat. Dessa konverteringar kan leda till att dina data förlorar precision eller struktur. Du kan välja om du vill ignorera dessa fel eller ändra datatypen (i din eventstream- eller KQL-tabell) för att optimera redigeringsprogrammet för händelsebearbetning.

Transformera händelsedata med hjälp av operatorer

Händelsebearbetningsredigeraren innehåller sju transformeringsoperatorer som du kan använda för att transformera dina händelsedata enligt dina affärsbehov.

Skärmbild som visar de transformeringsoperatorer som är tillgängliga på menyn med åtgärder.

Sammanställning

Använd 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. Den här åtgärden gör det också möjligt att byta namn på dessa beräknade kolumner, tillsammans med filtrering eller segmentering av aggregeringen baserat på andra dimensioner i dina data. Du kan ha en eller flera sammansättningar i samma transformering.

Om du väljer den här operatortypen anger du följande information:

  • Operatornamn: Ange namnet på aggregeringsåtgärden.
  • Lägg till aggregeringsfunktion: Lägg till en eller flera aggregeringar i aggregeringsåtgärden.
  • Typ: Välj en aggregeringstyp. Alternativen är Sum, Minimum, Maximum och Average.
  • Fält: Välj den kolumn som ska bearbetas.
  • Namn: Definiera ett namn för den här aggregeringsfunktionen.
  • Partitionera efter: Välj en kolumn för att gruppera aggregeringen.
  • Aggregerade värden inom den senaste: Ange ett tidsfönster för att aggregera. Standardvärdet är 5 sekunder.

Skärmbild som visar aggregerade operatorns konfigurations- och testresultat.

Expandera

Använd expanderingstransformeringen för att skapa en ny rad för varje värde i en matris. Du kan välja Skapa rad för matris som saknas/tom eller Skapa inte rad för matris som saknas/är tom.

Skärmbild som visar Expand-operatörens konfiguration och testresultat.

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, till exempel är null eller inte är null.

Gruppera efter

Använd Gruppera efter-transformeringen för att beräkna aggregeringar av alla händelser inom ett visst tidsfönster. Du kan gruppera efter värden i ett eller flera fält. Det är som aggregeringstransformeringen eftersom den tillåter namnbyte av kolumner, men det ger fler alternativ för aggregering och innehåller mer komplexa alternativ för tidsfönster. Precis som aggregering kan du lägga till mer än en aggregering per transformering.

De aggregeringar som är tillgängliga i omvandlingen är:

  • Medel
  • Räkna
  • Högsta
  • Minimi
  • Percentil (kontinuerlig och diskret)
  • Standardavvikelse
  • Summa
  • Varians

I scenarier med tidsuppspelning är det ett vanligt mönster att utföra åtgärder på data som finns i temporala fönster. Händelsebearbetningsredigeraren stöder fönsterfunktioner, som är integrerade med Gruppera efter-operatören. Du kan definiera dem i inställningarna för den här operatorn.

Skärmbild som visar

Hantera fält

Använd transformeringen Hantera fält för att lägga till, ta bort, ändra datatypen för eller byta namn på fält som kommer in från en indata eller en annan transformering. I fönstret för den här omvandlingens inställningar kan du lägga till ett nytt fält (genom att välja Lägg till fält), lägga till flera fält eller lägga till alla fält samtidigt.

Skärmbild som visar operatorn Hantera fält som är tillgänglig i redigeringsprogrammet för händelsebearbetning.

Du kan också lägga till ett nytt fält med hjälp av de inbyggda funktionerna för att aggregera data från uppströms. För närvarande är de inbyggda funktionerna som stöds strängfunktioner, datum- och tidsfunktioner och matematiska funktioner. Sök efter inbyggda för att hitta dem.

Skärmbild som visar fältoperatorns inbyggda funktioner.

I följande tabell visas resultatet av att ändra datatypen med hjälp av Hantera fält. Kolumnerna representerar ursprungliga datatyper och raderna representerar måldatatyper. I tabellen:

  • ✔️ Innebär att datatypen kan konverteras direkt. Alternativet för måldatatypen visas i listrutan.
  • ❌ Innebär att datatypen inte kan konverteras. Alternativet för måldatatypen visas inte i listrutan.
  • ⚠️ Innebär att datatypen kan konverteras, men den måste uppfylla vissa villkor. Ett villkor kan vara att strängformatet måste uppfylla kraven för måldatatypen. När du till exempel konverterar från en sträng till ett heltal måste strängen vara ett giltigt heltalsformulär, till exempel 123 (inte abc).
Int64 dubbel Sträng Datum och tid Rekord Array
Int64 ✔️ ✔️ ✔️ ❌ ❌ ❌
Dubbel ✔️ ✔️ ✔️ ❌ ❌ ❌
Sträng ⚠️ ⚠️ ✔️ ⚠️ ❌ ❌
DatumTid ❌ ❌ ✔️ ✔️ ❌ ❌
Register ❌ ❌ ✔️ ❌ ✔️ ❌
Array ❌ ❌ ✔️ ❌ ❌ ✔️

Förbund

Använd Unionstransformeringen för att ansluta två eller flera noder och 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.

Anslut

Använd kopplingstransformeringen för att kombinera händelser från två indata baserat på de fältpar som du väljer. Om du inte väljer ett fältpar baseras kopplingen som standard på tid. Standardvärdet är det som gör att den här omvandlingen skiljer sig från en batch.

Precis som med vanliga kopplingar har du alternativ för din kopplingslogik:

  • Inre koppling: Inkludera endast poster från båda tabellerna där paren stämmer överens.
  • Vänster yttre koppling: Inkludera alla poster från den första (vänstra) tabellen och endast posterna från den andra tabellen som matchar fältparet. Om det inte finns någon matchning är fälten från den andra inmatningen tomma.

Relaterat innehåll