Dela via

Självstudie: Utforska och transformera exempel på cykeldelningsdata med Eventstream för KQL Database-integrering

  • Artikel

Eventstream är en strömningsplattform som gör att du kan mata in, transformera och dirigera dataströmmar till KQL Database med hjälp av ett redigeringsprogram utan kod. I den här självstudien utforskar vi exempel på cykeldelningsdata för att fastställa antalet cyklar som hyrs på gatorna minut för minut. Du lär dig att använda Eventstreams händelseprocessor för realtidsdatatransformeringar och sömlöst dirigera bearbetade data till din KQL-databas.

Förutsättningar

  • Åtkomst till en arbetsyta med behörigheter som deltagare eller högre där din Eventstream- och KQL-databas finns.
  • En KQL-databas som skapats på din arbetsyta.

Skapa en händelseström

Följ dessa steg för att skapa en händelseström på din arbetsyta:

  1. Gå till Fabricportalen.

  2. Välj Min arbetsyta i det vänstra navigeringsfältet.

  3. På sidan Min arbetsyta väljer du + Nytt objekt i kommandofältet.

  4. På sidan Nytt objekt söker du efter Eventstreamoch väljer sedan Eventstream.

    Skärmbild som visar sidan Nytt objekt med Eventstream markerat.

  5. I fönstret New Eventstream anger du ett namn för händelseströmmen och väljer sedan Skapa.

    Skärmbild som visar fönstret Ny händelseström.

  6. Det kan ta några sekunder att skapa den nya händelseströmmen på arbetsytan. När händelseströmmen har skapats dirigeras du till huvudredigeraren där du kan börja med att lägga till källor i händelseströmmen.

    Skärmbild som visar redigeraren.

Lägga till exempelcykeldata

  1. På Eventstream-arbetsytan expanderar du Ny källa och väljer Exempeldata. Ge källan ett namn och välj Cyklar som exempeldata.

    Skärmbild som visar var du lägger till exempeldata i eventstream.

  2. Du kan förhandsgranska data i eventstream för att kontrollera om exempelcykeldata har lagts till.

    Skärmbild som visar var data ska förhandsgranskas i händelseströmmen.

    Här är beskrivningen av kolumnerna:

    Kolumn beskrivning
    BikepointID ID för cykeldockningspunkten
    Gata Namnet på gatan där dockan finns
    Grannskap Område där dockan finns
    Latitud Latitud för dockningspunkten
    Longitud Longitud för dockningspunkten
    No_Bikes Antal cyklar som för närvarande hyrs
    No_Empty_Docks Antal tillgängliga tomma dockor vid dockningspunkten

Lägga till ett KQL-mål med händelseprocessor

  1. På Eventstream-arbetsytan expanderar du listrutan Nytt mål och väljer KQL-databas. Ange nödvändig information om din KQL-databas.

    Skärmbild som visar var du lägger till KQL Database i eventstream.

    • Datainmatningsläge. Det finns två sätt att mata in data i KQL Database:
      • Direkt inmatning: Mata in data direkt till en KQL-tabell utan transformering.
      • Händelsebearbetning före inmatning: Transformera data med händelseprocessorn innan de skickas till en KQL-tabell.

      Kommentar

      Du kan inte redigera inmatningsläget när KQL-databasmålet har lagts till i händelseströmmen.

    • Målnamn: Ange ett namn för det här Eventstream-målet, till exempel "kql-dest".
    • Arbetsyta: Där din KQL-databas finns.
    • KQL-databas: Namnet på din KQL-databas.
    • Måltabell: Namnet på KQL-tabellen. Du kan också ange ett namn för att skapa en ny tabell, till exempel "bike-count".
    • Indataformat: Välj JSON som dataformat för din KQL-tabell.

  2. Rulla nedåt i den högra rutan och välj Öppna händelseprocessor. Den här åtgärden öppnar en ny ram så att du kan lägga till realtidsåtgärder i dina dataströmmar med hjälp av ett redigeringsprogram utan kod.

    Skärmbild som visar var händelseprocessorn ska öppnas i Eventstream.

  3. I redigeraren för händelsebearbetning väljer du raden mellan Eventstream och KQL-databasen och lägger till en grupp efter åtgärd. Vårt mål är att beräkna antalet cyklar som hyrs varje minut på gatan. Under Sammansättning väljer du SUM för aggregering och No_Bikes för fältet.

    Skärmbild som visar var du vill gruppera efter åtgärd i Eventstream.

    Längre ned i avsnittet Inställningar anger du följande information och väljer Spara för att slutföra konfigurationen Gruppera efter.

    • Gruppera sammansättning efter: Gata
    • Tidsfönster: Rullande
    • Varaktighet: 1 minut

  4. Välj åtgärden Gruppera efter i redigeraren och förhandsgranska bearbetningsresultatet. Välj sedan Spara för att stänga händelseprocessorn.

    Skärmbild som visar var du kan förhandsgranska gruppera efter data i Eventstream.

  5. Välj slutligen Lägg till för att slutföra konfigurationen för KQL-databasmålet.

Visa resultatet i KQL-tabellen

Nu läggs KQL Database-målet till i din Eventstream. Nu ska vi se till att bearbetningsresultaten lagras korrekt i den avsedda KQL-tabellen. Följ de här stegen:

  1. På arbetsytan väljer du KQL-målet och väljer Öppna objekt för att komma åt din KQL-databas.

    Skärmbild som visar var du öppnar KQL Database i Eventstream.

  2. Leta upp tabellen bike-count i KQL-databasgränssnittet. Välj i Frågetabell och välj Visa 100 poster. Den här åtgärden öppnar den högra rutan så att du kan undersöka de sista 100 posterna i tabellen. Här kan du observera det detaljerade antalet cyklar som hyrs på varje gata, minut för minut.

    Skärmbild som visar var tabellens resultat visas i KQL-databasen.

Grattis!

Du har slutfört självstudien om att utforska och transformera cykeldelningsdata med Eventstream. Fortsätt utforska Eventstreams funktioner och fortsätt din resa med databearbetning i realtid.

Relaterat innehåll

Om du vill lära dig mer om att mata in och bearbeta dataströmmar med Eventstream kan du läsa följande resurser: