Extrahera ändringsdata med CDC-källan

Gäller för:SQL Server SSIS Integration Runtime i Azure Data Factory

Important

CDC Flow-komponenter, inklusive CDC Control Task, CDC Source och CDC Splitter, är inaktuella. Mer information finns i meddelandet.

För att lägga till och konfigurera en CDC-källkod måste paketet redan innehålla minst en Data Flow-uppgift och en CDC Control-uppgift.

För mer information om CDC Control Task, se CDC Control Task.

Mer information om CDC-källan finns i CDC-källa.

För att extrahera ändringsdata med hjälp av en CDC-källa

  1. I SQL Server Data Tools öppnar du projektet SQL Server 2019 Integration Services (SSIS) som innehåller det paket du vill ha.

  2. I Prieskumník riešení dubbelklickar du på paketet för att öppna det.

  3. Klicka på fliken Data Flow, och dra sedan CDC-källan från Toolbox till designytan.

  4. Dubbelklicka på CDC-källan.

  5. I dialogrutan CDC Source Editor, på sidan Správca pripojení, välj en befintlig ADO.NET connection manager från listan eller klicka på Ny för att skapa en ny anslutning. Anslutningen bör vara till en SQL Server-databas som innehåller ändringstabellerna att läsa.

  6. Välj CDC-tabellen där du vill behandla ändringar.

  7. Välj eller skriv in namnet på CDC-capture-instansen med CDC-tabellen som ska läsas.

    En samlad källtabell kan ha en eller två instanser som hanterar sömlös övergång av tabelldefinition via schemaändringar. Om mer än en avbildningsinstans har definierats för källtabellen som samlas in väljer du den avbildningsinstans som du vill använda här. Standardnamnet för insamlingsinstansen för en tabell [schema]. [table] är <schema>_<table> , men de faktiska avbildningsinstansnamnen som används kan vara annorlunda. Den faktiska tabellen som läss från är CDC-tabellen cdc .<capture-instance>_CT.

  8. Välj det bearbetningsläge som bäst hanterar dina bearbetningsbehov. Här är de möjliga alternativen:

    • Alla: Returnerar ändringarna i det aktuella CDC-intervallet utan värdena Före uppdatering .

    • Alla med gamla värden: Returnerar ändringarna i det aktuella CDC-bearbetningsintervallet, inklusive de gamla värdena (före uppdatering). För varje uppdateringsåtgärd finns det två rader, en med värdena före uppdateringen och en med värdet efter uppdateringen.

    • Net: Returnerar endast en ändringsrad per källrad som ändrats i det aktuella CDC-bearbetningsintervallet. Om en källrad uppdaterades flera gånger skapas den kombinerade ändringen (till exempel skapas insert+update som en enskild uppdatering och update+delete skapas som en enda borttagning). När du arbetar i läget För bearbetning av nettoändringar är det möjligt att dela upp ändringarna i ta bort, infoga och uppdatera utdata och hantera dem parallellt eftersom raden med en enda källa visas i fler än en utdata.

    • Net med uppdateringsmask: Det här läget liknar det vanliga Net-läget, men det lägger också till booleska kolumner med namnmönstret __$<column-name>__Changed som anger ändrade kolumner i den aktuella ändringsraden.

    • Net with merge: Det här läget liknar det vanliga Net-läget men med Insert- och Update-operationer som slås ihop till en enda sammanslagningsoperation (UPSERT).

  9. Välj den SSIS-strängpaketvariabel som underhåller CDC-tillståndet för den aktuella CDC-kontexten. Mer information om CDC-tillståndsvariabeln finns i Definiera en tillståndsvariabel.

  10. Välj rutan för att inkludera ombearbetningsindikatorn för att skapa en speciell utdatakolumn kallad __$reprocessing. Den här kolumnen har värdet true när CDC-bearbetningsintervallet överlappar det inledande bearbetningsintervallet (intervallet för LSN som motsvarar perioden för den inledande belastningen) eller när ett CDC-bearbetningsintervall bearbetas på nytt efter ett fel i en tidigare körning. Med den här indikatorkolumnen kan SSIS-utvecklaren hantera fel på olika sätt vid ombearbetning av ändringar (till exempel kan åtgärder som att ta bort en icke-befintlig rad och en infogning som misslyckades på en dubblettnyckel ignoreras).

    Mer information finns i Anpassade egenskaper för CDC-källa.

  11. För att uppdatera mappningen mellan externa och utdata kolumner, klicka på Kolumner och välj olika kolumner i listan Extern kolumn .

  12. Uppdatera eventuellt värdena i utdatakolumnerna genom att ta bort värden i listan över utdatakolumner .

  13. För att konfigurera felutmatningen klickar du på Felutmatning.

  14. Du kan klicka på Förhandsgranskning för att se upp till 200 rader data som extraherats av CDC-källan.

  15. Klicka på OK.