Tilføj Mirrored Database (Change Feed) kildekode til en eventstream

Denne artikel viser dig, hvordan du tilføjer en Mirrored Database (Change Feed) kilde til en eventstream.

Mirrored Database (Change Feed) kilde-connectoren til Microsoft Fabric hændelsesstrømme gør det muligt at indsamle realtidsændringsbegivenheder fra en Fabric Mirrored Database. Spejlede databaser i Fabric giver en næsten realtids, skrivebeskyttet kopi af dine eksterne databasedata. Med denne connector kan du fange indsættelser, opdateringer og sletninger, efterhånden som de sker i den spejlede database, og streame dem ind i en eventstream for realtidsbehandling, analyse og routing til forskellige Fabric-destinationer.

Denne connector understøtter alle spejlede databasetyper, der er tilgængelige i Fabric Mirroring, herunder:

  • Azure SQL Database
  • Azure Cosmos DB
  • Snowflake
  • Åbn spejling

Bemærkning

Denne connector er i øjeblikket i Forhåndsvisning. Connectoren modtager rå change feed-hændelser fra den spejlede database. DeltaFlow (analytics-klar event transformation) understøttes ikke i øjeblikket med denne connector.

Forudsætninger

  • Adgang til et arbejdsområde i Fabric-kapacitetslicenstilstand eller Prøvelicens-tilstand med bidragyder eller højere tilladelser.
  • En eksisterende spejlet database i dit Fabric-arbejdsområde, som aktivt synkroniserer data fra kildedatabasen.
  • Den spejlede database skal have ændringsfeed aktiveret.
  • Hvis du ikke har en eventstream, skal du oprette en eventstream.

Start Connect-datakildeguiden

Hvis du endnu ikke har tilføjet nogen kilde til din eventstream, vælg flisen Connect data sources . Du kan også vælge Tilføj kilde>Connect datakilder på båndet.

Skærmbillede, der viser valget af flisen til brug af en ekstern kilde.

Hvis du tilføjer kildekoden til en allerede offentliggjort eventstream, så skift til Rediger-tilstand . På båndet skal du vælge Tilføj kilde>Forbind datakilder.

Skærmbillede, der viser valg til tilføjelse af eksterne kilder.

På siden Vælg en datakilde søger du efter Spejlet database og vælger Connect på flisen Spejlet database (Skift Feed).

Skærmbillede, der viser valget af spejlet database (Change Feed) som kildetype i Get events-guiden.

Konfigurér og forbind til spejlet databaseændringsfeed

Indtast ændringsfeed-begivenheder til en Eventstream fra en Fabric Mirrored Database efter eget valg

  1. På siden Connect vælger du en spejlet database, du vil forbinde til.

    1. For Workspace skal du gå til og vælge Fabric workspace, der indeholder den spejlede database.

    2. For Spejlet database, vælg den spejlede database fra listen over tilgængelige databaser i det valgte arbejdsområde.

      Skærmbillede, der viser arbejdsområdet og spejlet databasevælger på Connect-siden.

  2. Vælg Alle tabeller, eller Indtast tabelnavn(er) for at angive, hvilke tabeller der skal overvåges for ændringer. Hvis du vælger sidstnævnte, skal du angive tabeller ved hjælp af en kommasepareret liste over komplette tabel-id'er (schemaName.tableName) eller gyldige regulære udtryk. Eksempel:

    • Brug dbo.Orders.* til at vælge alle tabeller, hvis navne starter med dbo.Orders.
    • Brug dbo\.(Orders|Customers) til at vælge dbo.Orders og dbo.Customers.

    Du kan blande begge formater ved hjælp af kommaer. Den samlede tegngrænse for hele posten er 102.400 tegn.

    Bemærkning

    I den nuværende Preview-udgivelse er kun muligheden Alle tabeller tilgængelig.

  3. På siden Gennemgå + forbind skal du gennemgå oversigten af indstillingerne, og derefter vælge Tilføje.

    Skærmbillede, der viser siden Review + connect for kilden til Mirrored Database Change Feed.

  4. Du kan se kildekoden til Mirrored Database (Change Feed) tilføjet til din eventstream, mens du stadig er i Redigeringstilstand.

Vis opdateret hændelsesstream

  1. For at implementere denne nyligt tilføjede kildekode til spejlet database (Change Feed), vælg Publicer. Når du har gennemført disse trin, er din kildekode til Mirrored Database (Change Feed) tilgængelig for visualisering i Live view.

    Skærmbillede af streamingkilde til ændring af mirrored database i Live View.

Konfigurer Eventstream-destinationer til at bruge skemaer

I øjeblikket understøttes kun Eventhouse, brugerdefineret endpoint og afledte strømdestinationer for Eventstreams med tilhørende skemaer. Dette afsnit viser, hvordan du tilføjer og konfigurerer en Eventhouse-destination, når udvidede funktioner (f.eks. understøttelse af skemaer) er aktiveret for eventstream.

Bemærkning

Når du bruger DeltaFlow (Preview) med en understøttet Change Data Capture (CDC)-kilde, oprettes og administreres destinationstabellerne i Eventhouse automatisk, så de matcher kildetabelstrukturen. Du behøver ikke manuelt konfigurere destinationstabellens skema. DeltaFlow håndterer også automatisk skemaudvikling, når kildetabeller ændres.

Konfigurer et skema til en brugerdefineret endpoint-destination

  1. Vælg Transformér begivenheder eller tilføj destination, og vælg derefter CustomEndpoint.

  2. I panelet Brugerdefineret endpoint skal du angive et navn til destinationen.

  3. Vælg skemaet for hændelser under Inputskema. Du vælger i denne boks, når du aktiverer skema-understøttelse for en eventstream.

Skærmbillede, der viser panelet til konfiguration af et brugerdefineret endpoint.

Du kan finde detaljerede trin til konfiguration af en brugerdefineret slutpunktsdestination under Føj et brugerdefineret slutpunkt eller en brugerdefineret appdestination til en eventstream.

Konfigurere skemaer for en eventhouse-destination

  1. Vælg Transformér begivenheder, eller tilføj destination, og vælg derefter Eventhouse.

  2. På Eventhouse-panelet konfigurerer du følgende skema-relaterede indstillinger:

    1. For Input-skema skal du vælge et eller flere skemaer fra rullemenuen.

      Skærmbillede, der viser eventhouse-konfigurationspanelet med et inputskema valgt.

      Bemærkning

      Hvis du valgte muligheden Dynamisk skema via headers , når du konfigurerede en Event Hubs-kilde, kunne det være, du havde konfigureret flere skemaer for kilden og kortlagt dem til forskellige egenskaber og deres værdier.

    2. For tabeloprettelsesmetoden vælg En enkelt tabel med alle skemaer kombineret eller separate tabeller for hvert skema, afhængigt af dine krav.

      Skærmbillede, der viser eventhouse-konfigurationspanelet med tabeloprettelsesmetoder.

    3. Vælg en af følgende indstillinger for Skriv data med:

      • Kun nyttelast: Skriv udtrukket nyttelastdata til tabellen. Hvis der er flere inputskemaer, sendes data til flere tabeller.
      • Metadata og nyttedata: Skriv metadata og data til data til en enkelt tabel. Eksempelkolonner inkluderer source , subject, , typeog data.

      Skærmbillede, der viser eventhouse-konfigurationspanelet med muligheder for at skrive data.

For detaljerede trin til at konfigurere en eventhouse-destination, se Tilføj en eventhouse-destination til en eventstream.

Relateret indhold

Andre connectors:

  • Last updated on