Dela via


Lägga till Azure SQL Database CDC-källa i en händelseström

Den här artikeln visar hur du lägger till en Azure SQL Database Change Data Capture-källa (CDC) i en händelseström.

Med Azure SQL Database CDC-källanslutningsappen för Microsoft Fabric-händelseströmmar kan du samla in en ögonblicksbild av aktuella data i en Azure SQL-databas. Anslutningsappen övervakar och registrerar eventuella framtida ändringar på radnivå av dessa data. När ändringarna har registrerats i händelseströmmen kan du bearbeta CDC-data i realtid och skicka dem till olika mål i Infrastrukturresurser för vidare bearbetning eller analys.

Anteckning

Den här källan stöds inte i följande regioner i din arbetsytekapacitet: Västra USA 3, Schweiz västra.

Förutsättningar

  • Åtkomst till en arbetsyta i Fabric-kapacitetslicensläge eller utvärderingslicensläge med bidragsgivare eller högre behörigheter.
  • En Azure SQL-server som körs med en Azure SQL-databas.
  • Din Azure SQL-databas måste vara offentligt tillgänglig och inte ligga bakom en brandvägg eller skyddas i ett virtuellt nätverk.
  • Aktiverade CDC i din Azure SQL-databas genom att köra den lagrade proceduren sys.sp_cdc_enable_db. Mer information finns i Aktivera och inaktivera insamling av ändringsdata.
  • Om du inte har en händelseström, skapa en händelseström.

Observera att du inte får aktivera spegling i din Azure SQL-databas.

Aktivera CDC i din Azure SQL Database

  1. Gå till Azure Portal, öppna Din Azure SQL-databas och välj Frågeredigeraren. Välj en autentiseringsmetod för att logga in.

    En skärmbild av hur du öppnar Azure SQL-databasen.

  2. Kör följande SQL-kommandon för att aktivera CDC i databasen:

    -- Enable Database for CDC
    EXEC sys.sp_cdc_enable_db;
    
    -- Enable CDC for a table using a gating role option
    EXEC sys.sp_cdc_enable_table
        @source_schema = N'dbo',
        @source_name   = N'MyTable',
        @role_name     = NULL
    GO
    

Starta guiden Välj en datakälla

Om du inte har lagt till någon källa i händelseströmmen ännu väljer du Panelen Använd extern källa .

Skärmbild som visar valet av Använd extern källa-rutan.

Om du lägger till källan i en redan publicerad händelseström växlar du till Redigeringsläge , väljer Lägg till källa i menyfliksområdet och väljer sedan Externa källor.

Skärmbild som visar valet av Menyn Lägg till källa till externa källor.

På sidan Välj en datakälla söker du efter och väljer Anslutpanelen Azure SQL DB (CDC).

Skärmbild som visar valet av Azure SQL DB CDC som källtyp i guiden Hämta händelser.

Konfigurera och ansluta till Azure SQL Database CDC

  1. På sidan Anslut väljer du Ny anslutning.

    Skärmbild som visar sidan Anslut i guiden Hämta händelser med länken **Ny anslutning** markerad.

  2. I avsnittet Anslutningsinställningar anger du följande värden för din Azure SQL-databas:

    • Server: Ange Azure SQL-servernamnet från Azure Portal. Det är i det här formatet: mysqlservername.database.windows.net.

    • Databas: Ange Namnet på Azure SQL-databasen från Azure Portal.

      Skärmbild som visar avsnittet Anslutningsinställningar på sidan Ny anslutning.

  3. Rulla nedåt och följ de här stegen i avsnittet Anslutningsautentiseringsuppgifter .

    • Som Anslutningsnamn anger du ett namn för anslutningen.

    • För Typ av autentisering väljer du Grundläggande.

      Anteckning

      För närvarande stöder Fabric Eventstream endast grundläggande autentisering.

    • Ange användarnamn och lösenord för databasen.

  4. Välj Anslut.

    Skärmbild som visar avsnittet Anslutningsautentiseringsuppgifter på sidan Ny anslutning.

  5. På sidan Anslut väljer du Nu Alla tabeller eller Ange tabellnamn. Om du väljer det senare anger du tabeller med hjälp av en kommaavgränsad lista med fullständiga tabellidentifierare (schemaName.tableName) eller giltiga reguljära uttryck. Till exempel:

    • Använd dbo.test.* för att välja alla tabeller vars namn börjar med dbo.test.
    • Använd dbo\.(test1|test2) för att välja dbo.test1 och dbo.test2.

    Du kan blanda båda formaten med kommatecken. Den totala teckengränsen för hela posten är 102 400 tecken.

  6. Du kan expandera Avancerade inställningar för att konfigurera decimalhanteringsläget, som anger hur anslutningsappen hanterar DECIMAL och NUMERIC kolumnvärden:

    • Precise: Representerar värden med exakta decimaltyper (till exempel Java BigDecimal) för att säkerställa fullständig precision och noggrannhet i datarepresentationen.
    • Double: Konverterar värden till flyttal med dubbel precision. Den här inställningen förbättrar användbarhet och prestanda, men kan leda till att precisionen går förlorad.
    • String: Kodar värden som formaterade strängar. Den här inställningen gör det enkelt att använda i underordnade system men förlorar semantisk information om den ursprungliga numeriska typen.
  7. Välj Nästa.

    Skärmbild som visar sidan Anslut i guiden Hämta händelser ifylld.

  8. På skärmen Granska och skapa granskar du sammanfattningen och väljer sedan Lägg till.

    Skärmbild som visar den ifyllda sidan Granska och skapa i guiden Hämta händelser.

Mata in ändringsdata från Azure SQL-databaser med automatisk tabellschemaregistrering via CDC till Eventstream.

  1. På sidan Anslut väljer du Ny anslutning.

    Skärmbild som visar sidan Anslut i guiden Hämta händelser med länken Ny anslutning markerad.

  2. I avsnittet Anslutningsinställningar anger du följande värden för din Azure SQL-databas:

    • Server: Ange Azure SQL-servernamnet från Azure Portal. Det är i det här formatet: mysqlservername.database.windows.net.

    • Databas: Ange Namnet på Azure SQL-databasen från Azure Portal.

      Skärmbild som visar avsnittet Anslutningsinställningar på sidan Ny anslutning.

  3. Rulla nedåt och följ de här stegen i avsnittet Anslutningsautentiseringsuppgifter .

    • Som Anslutningsnamn anger du ett namn för anslutningen.

    • För Typ av autentisering väljer du Grundläggande.

      Anteckning

      För närvarande stöder Fabric Eventstream endast grundläggande autentisering.

    • Ange användarnamn och lösenord för databasen.

  4. Välj Anslut.

    Skärmbild som visar avsnittet Anslutningsautentiseringsuppgifter på sidan Ny anslutning.

  5. På sidan Anslut väljer du Nu Alla tabeller eller Ange tabellnamn. Om du väljer det senare anger du tabeller med hjälp av en kommaavgränsad lista med fullständiga tabellidentifierare (schemaName.tableName) eller giltiga reguljära uttryck. Till exempel:

    • Använd dbo.test.* för att välja alla tabeller vars namn börjar med dbo.test.
    • Använd dbo\.(test1|test2) för att välja dbo.test1 och dbo.test2.

    Du kan blanda båda formaten med kommatecken. Den totala teckengränsen för hela posten är 102 400 tecken.

  6. Du kan expandera Avancerade inställningar för att konfigurera decimalhanteringsläget, som anger hur anslutningsappen hanterar DECIMAL och NUMERIC kolumnvärden:

    • Precise: Representerar värden med exakta decimaltyper (till exempel Java BigDecimal) för att säkerställa fullständig precision och noggrannhet i datarepresentationen.
    • Double: Konverterar värden till flyttal med dubbel precision. Den här inställningen förbättrar användbarhet och prestanda, men kan leda till att precisionen går förlorad.
    • String: Kodar värden som formaterade strängar. Den här inställningen gör det enkelt att använda i underordnade system men förlorar semantisk information om den ursprungliga numeriska typen.
  7. Aktivera händelseschemaassociation.

  8. För Arbetsyta väljer du en Infrastrukturarbetsyta för schemauppsättningen.

  9. För Schemauppsättning är + Skapa valt som standard, vilket skapar en ny schemauppsättning. Du kan ändra den för att välja en befintlig händelseschemauppsättning.

  10. Om du valde alternativet + Skapa i föregående steg anger du ett namn för schemauppsättningen.

    Skärmbild som visar schemainställningen för en Azure SQL Database CDC-källa.

  11. På sidan Granska + anslut väljer du Lägg till.

    Skärmbild som visar sidan granska + ansluta för Azure SQL Database CDC-källan.

    För alla tabeller eller valda tabeller i Azure SQL-databasen kan anslutningsappen automatiskt identifiera och skapa scheman och registrera dem med schemaregistret.

  12. Välj noden eventstream i mitten och växla till fliken Associerade scheman i det nedre fönstret.

    Skärmbild som visar fönstret Associerat schema i den nedre rutan.

Schemauppsättning

  1. Gå till den arbetsyta som du valde i föregående steg. I följande exempel är det Min arbetsyta.

  2. Välj den schemauppsättning som azure SQL Database-anslutningsappen (CDC) skapade.

    Skärmbild som visar den genererade schemauppsättningen på sidan Min arbetsyta.

  3. Du ser scheman i schemauppsättningen enligt följande bild.

    Skärmbild som visar scheman i den genererade schemauppsättningen.

  4. Om du vill se JSON-versionen av schemat växlar du till JSON-schemavyn .

    Skärmbild som visar JSON-schemavyn.

    Ändra inte dessa identifierade scheman med den här redigeraren eftersom det blir icke-konfirmant med schemat för tabeller i Azure SQL-databaskällan.

Visa uppdaterad händelseström

  1. Du kan se azure SQL Database-källan (CDC) som lagts till i din händelseström i redigeringsläge.

    Skärmbild av strömmande Azure SQL Database CDC-källa i redigeringsvyn.

  2. Om du vill implementera den nya Azure SQL Database CDC-källan väljer du Publicera. När du har slutfört de här stegen är din Azure SQL Database CDC-källa tillgänglig för visualisering i livevyn.

    Skärmbild av strömmande Azure SQL Database CDC-källa i Live-visning.

Konfigurera eventstream-mål för att använda scheman

För närvarande stöds endast Eventhouse-mål, anpassade slutpunkter och härledda strömmar för eventstreams med aktiverade utökade funktioner (t.ex. schemastöd). Det här avsnittet visar hur du lägger till och konfigurerar ett Eventhouse-mål när utökade funktioner (till exempel schemastöd) aktiveras för händelseströmmen.

Konfigurera schema för ett anpassat slutpunktsmål

  1. Välj Transformera händelser eller lägg till mål och välj sedan Anpassad slutpunkt.

  2. I fönstret Anpassad slutpunkt anger du ett namn för målet som vanligt.

  3. För Indataschema väljer du schemat för händelser. Det här fältet är det extra fält som du fyller i när du aktiverar schemastöd för en händelseström.

    Skärmbild som visar konfigurationssidan för anpassad slutpunkt.

    Detaljerade anvisningar om hur du konfigurerar ett anpassat slutpunktsmål finns i Lägga till en anpassad slutpunkt eller ett anpassat appmål i en händelseström.

Konfigurera scheman för ett eventhouse-mål

  1. Välj Transformera händelser eller lägg till mål och välj sedan Eventhouse.
  2. På sidan Eventhouse konfigurerar du följande schemarelaterade inställningar:
    1. För Indataschema väljer du ett eller flera scheman i listrutan.

      Skärmbild som visar konfigurationssidan för Eventhouse med ett indataschema valt.

      Anteckning

      Om du valde alternativet Dynamiskt schema via rubriker när du konfigurerade en Händelsehubbkälla kan du ha konfigurerat flera scheman för källan och mappat dem till olika egenskaper och deras värden.

    2. För Metod för att skapa tabell väljer du ett av alternativen beroende på dina krav: En enskild tabell med alla kombinerade scheman eller Separata tabeller för varje schema.

      Skärmbild som visar konfigurationssidan för Eventhouse med metoder för att skapa tabeller.

    3. För Skriv data med väljer du något av följande alternativ:

      • Endast nyttolast: Skriva extraherade nyttolastdata till tabellen. Om det finns flera indatascheman skickas data till flera tabeller.

      • Metadata och nyttolast: Skriv metadata och nyttolastdata till en enda tabell. Exempelkolumner: source , subject, type, data, osv.

        Skärmbild som visar konfigurationssidan för Eventhouse med alternativen för skrivdata.

      Detaljerade anvisningar om hur du konfigurerar ett Eventhouse-mål finns i Lägga till ett Eventhouse-mål i en händelseström.

Andra anslutningsappar: