Configura un database Azure SQL per CDC

Questa pagina descrive come configurare Change Data Capture (CDC) per trasmettere dati in streaming da un database Azure SQL a una destinazione supportata, come BigQuery o Cloud Storage.

Per configurare un database Azure SQL:

  1. Abilita Change Data Capture (CDC) per il database Azure SQL di origine. Per farlo, connettiti al database utilizzando Azure Data Studio o SQL Server Management Studio ed esegui questo comando:

    EXEC sys.sp_cdc_enable_db;
GO

  2. Abilita CDC nelle tabelle per le quali devi acquisire le modifiche:

    EXEC sys.sp_cdc_enable_table
@source_schema = N'SCHEMA_NAME',
@source_name = N'TABLE_NAME',
@role_name = NULL
GO

    Sostituisci quanto segue:

    • SCHEMA_NAME: il nome dello schema a cui appartengono le tabelle
    • TABLE_NAME: il nome della tabella per cui vuoi attivare CDC

  3. Abilita l'isolamento degli snapshot.

    Quando esegui il backfill dei dati dal database SQL Server, è importante assicurarsi che gli snapshot siano coerenti. Se non applichi le impostazioni descritte in questa sezione, le modifiche apportate al database durante il processo di backfill potrebbero generare duplicati o risultati errati, soprattutto per le tabelle senza chiavi primarie.

    L'abilitazione dell'isolamento dello snapshot crea una visualizzazione temporanea del database all'inizio del processo di backfill. Ciò garantisce che i dati copiati rimangano coerenti, anche se altri utenti apportano modifiche alle tabelle live contemporaneamente. L'attivazione dell'isolamento degli snapshot potrebbe avere un leggero impatto sulle prestazioni, ma è essenziale per un'estrazione affidabile dei dati.

    Per abilitare l'isolamento degli snapshot:

    1. Connettiti al database utilizzando un client SQL Server.
    2. Esegui questo comando:
    ALTER DATABASE DATABASE_NAME SET ALLOW_SNAPSHOT_ISOLATION ON;

    Sostituisci DATABASE_NAME con il nome del database.

  4. Crea un utente Datastream:

    1. Connettiti al database master e crea un accesso:

      USE master;
CREATE LOGIN YOUR_LOGIN WITH PASSWORD = 'PASSWORD';

    2. Connettiti al database di origine e crea un utente per il tuo accesso:

      USE DATABASE_NAME
CREATE USER USER_NAME FOR LOGIN YOUR_LOGIN;

    3. Assegna i ruoli db_owner e db_denydatawriter al tuo utente:

      EXEC sp_addrolemember 'db_owner', 'USER_NAME';
EXEC sp_addrolemember 'db_denydatawriter', 'USER_NAME';

    4. Concedi l'autorizzazione VIEW DATABASE STATE all'utente:

      GRANT VIEW DATABASE STATE TO USER_NAME;

Passaggi successivi