Beskriva Realtidshubben för Microsoft Fabric

15 minuter

Hämta data till realtidshubben

Realtidshubben fungerar som din gateway för att upptäcka och kontrollera flödet av dina strömmande data. Det är en dynamisk katalog som innehåller:

Skärmbild av realtidshubbens roll i realtidsinformation.

Händelseströmmar: Få åtkomst till alla aktiva händelseströmmar i Infrastrukturresurser som du har behörighet att visa.
Microsoft-källor: Hitta och konfigurera snabbt tillgängliga strömningskällor, till exempel Azure Event Hubs, Azure IoT Hub och olika CDC-alternativ (Change Data Capture) från Azure SQL DB, Azure Cosmos DB och PostgreSQL DB.
Infrastrukturhändelser: Använd händelsedrivna funktioner för omedelbara meddelanden och datahantering. Håll koll på händelser från Infrastrukturarbetsyteobjekt till Azure Blob Storage, som kan initiera ytterligare processer eller arbetsflöden. Den här åtgärden kan innebära att starta en datapipeline eller skicka en e-postavisering. Dessutom har du flexibiliteten att dirigera dessa händelser till olika mål via händelseströmmar. Med aviseringar kan du interagera både inom din arbetsyta och utanför den från realtidshubben genom att välja knappen Ange avisering.

All den här informationen presenteras i ett lättsmält format, vilket säkerställer sömlös integrering med dina Fabric-arbetsbelastningar.

Hämta händelseströmmen

Funktionen för händelseströmmar i Microsoft Fabric Realtidsinformation möjliggör sömlös integrering av realtidshändelser i Fabric. Du kan skapa en händelseström, som är en instans i Fabric, lägga till källor för händelsedata, tillämpa valfria transformeringar på data och dirigera dem till olika mål, allt utan kodning. Den här metoden utan kod förenklar processen för att hantera händelsedata i Fabric.

Bearbeta händelser i händelseströmmar

Dra och släpp-gränssnittet erbjuder en enkel och användarvänlig metod för att konstruera dina arbetsflöden för händelsedata. Detta omfattar bearbetning, transformering och routning, allt utan kodning. Ett händelseströms dataflödesdiagram ger en tydlig visuell representation av datans resa och struktur. Dessutom gör händelseprocessorredigerarens no-code-miljö att du kan utforma logiken för bearbetning av händelsedata helt enkelt genom att dra och släppa element på plats.

Beskrivning av transformering

När du skapar en händelseström med utökade funktioner aktiverade stöder alla mål omvandlingsåtgärder. Utan förbättrade funktioner är transformeringar endast tillgängliga för Lakehouse- och KQL Database-mål, som hanterar händelsebearbetning före inmatning.

Filter: 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 is not null.
Hantera fält: Med den här omvandlingen kan du lägga till, ta bort, ändra datatyp eller byta namn på fält som kommer in från en indata eller en annan transformering.
Aggregering: Använd aggregeringstransformationen för att beräkna en aggregering (summa, minimum, maximum eller medelvärde) 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 och filtrera eller segmentera aggregeringen baserat på andra dimensioner i dina data. Du kan ha en eller flera sammansättningar i samma transformering.
Gruppera efter: Använd gruppen efter transformering för att beräkna aggregeringar för alla händelser inom ett visst tidsfönster. Du kan gruppera efter värden i ett eller flera fält. Det är som om aggregeringstransformeringen tillåter namnbyte av kolumner, men 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.
Union: Använd unionstransformeringen för att ansluta två eller flera noder och lägga till händelser med delade fält (med samma namn och datatyp) i en tabell. Fält som inte matchar tas bort och ingår inte i utdata.
Expandera: Använd den här matristransformeringen för att skapa en ny rad för varje värde i en matris.
Anslut: det här är en transformering för att kombinera data från två strömmar baserat på ett matchande villkor mellan dem.

Standardmålplatser

Vi kan se att våra destinationer är begränsade genom att inte välja de förbättrade funktionerna.

Mål	beskrivning
Anpassad app	Med den här funktionen kan du sömlöst dirigera din realtidshändelsetrafik till ett anpassat program. Det möjliggör integrering av dina egna program med händelseströmmen, vilket möjliggör omedelbar förbrukning av händelsedata. Den här funktionen är fördelaktig när du vill överföra realtidsdata till ett oberoende system som inte finns i Microsoft Fabric.
Sjöhus	Det här målet ger dig möjlighet att förbearbeta dina realtidshändelser innan de matas in i ditt lakehouse. Händelserna omvandlas till Delta Lake-format och lagras senare i specifika lakehouse-tabeller, vilket underlättar dina datalagerbehov. Detaljerad vägledning om hur du använder händelseprocessorn för datahantering i realtid finns i avsnittet "Bearbeta händelsedata med händelseprocessorredigeraren".
KQL-databas	Det här målet erbjuder möjligheten att tratta dina realtidshändelsedata till en KQL-databas, vilket ger dig möjlighet att använda den robusta Kusto-frågespråk (KQL) för dataförhör och analys. Om du rymmer dina data i KQL-databasen kan du få bättre förståelse för dina händelsedata och skapa omfattande rapporter och instrumentpaneler. Du har flexibiliteten att välja någon av två datainmatningsmetoder: antingen direkt inmatning eller förbearbetning av händelser före inmatning.
Reflex	Det här målet underlättar en direkt länkning av dina realtidshändelsedata med en Reflex. En Reflex är en intelligent entitet som är utrustad med all nödvändig information för att upprätta dataanslutningar, övervaka specifika villkor och utföra åtgärder. När händelsedata uppfyller vissa fördefinierade kriterier eller identifierar specifika mönster initierar Reflex autonomt lämpliga svar, till exempel att meddela användare eller utlösa Power Automate-arbetsflöden.

Förbättrade målplatser

När du väljer de förbättrade funktionerna kan du använda standarddestinationerna tillsammans med härledd ström.

Mål	beskrivning
Härledd ström	Den härledda dataströmmen är ett specialiserat mål som skapats efter tillämpningen av strömåtgärder som Filter eller Hantera fält till en händelseström. Den representerar den ändrade standardströmmen efter bearbetningen, som kan dirigeras till olika mål i Infrastrukturresurser och övervakas i realtidshubben.

Du kan nu ansluta till flera mål i en händelseström samtidigt utan att påverka eller kollidera med varandra.