Legg til CDC-kilde for PostgreSQL-database i en hendelsesstrøm
Denne artikkelen viser deg hvordan du legger til en postgreSQL Database Change Data Capture (CDC)-kilde i en hendelsesstrøm.
PostgreSQL Database Change Data Capture (CDC)-kildekoblingen for Microsoft Fabric-hendelsesstrømmer gjør det mulig å registrere et øyeblikksbilde av gjeldende data i en PostgreSQL-database. PostgreSQL Database Change Data Capture (CDC) støttes for øyeblikket fra følgende tjenester der databasene kan åpnes offentlig:
- Azure Database for PostgreSQL
- Amazon RDS for PostgreSQL
- Amazon Aurora PostgreSQL
- Google Cloud SQL for PostgreSQL
Når CDC-kilden for PostgreSQL-database legges til i hendelsesstrømmen, registreres endringer på radnivå i de angitte tabellene. Disse endringene kan deretter behandles i sanntid og sendes til forskjellige mål for videre analyse.
Merk
Denne kilden støttes ikke i følgende områder av arbeidsområdets kapasitet: Vest-USA3, Sveits vest.
Forutsetning
Tilgang til et arbeidsområde i lisensmodus for stoffkapasitet (eller) prøveversjonslisensmodus med bidragsyter eller høyere tillatelser.
Registrert brukertilgang i PostgreSQL-databasen.
PostgreSQL-databasen må være offentlig tilgjengelig og ikke være bak en brannmur eller sikret i et virtuelt nettverk.
CDC aktivert i PostgreSQL-databasen og -tabellene.
Hvis du har Azure Database for PostgreSQL, følger du fremgangsmåten i neste del for å aktivere CDC. Hvis du vil ha detaljert informasjon, kan du se Logisk replikering og logisk dekoding – Azure Database for PostgreSQL – fleksibel server.
Hvis du vil ha andre PostgreSQL-databaser, kan du se Debezium-kobling for PostgreSQL :: Debezium-dokumentasjon.
Hvis du ikke har en hendelsesstrøm, oppretter du en hendelsesstrøm.
Aktiver CDC i PostgreSQL-databasen
Denne delen bruker Azure Database for PostgreSQL som et eksempel.
Følg disse trinnene for å aktivere CDC i Azure Database for PostgreSQL Flexible Server:
Velg Serverparametere i navigasjonsmenyen på Azure Database for PostgreSQL Flexible Server-siden i Azure-portalen.
På serverparametersiden:
- Angi wal_level til logisk.
- Oppdater max_worker_processes til minst 16.
Lagre endringene, og start serveren på nytt.
Bekreft at Azure Database for PostgreSQL Flexible Server-forekomsten tillater offentlig nettverkstrafikk.
Gi administratorbrukerreplikeringstillatelsene ved å kjøre følgende SQL-setning. Hvis du vil bruke en annen brukerkonto til å koble postgreSQL-DB-en til å hente CDC, må du kontrollere at brukeren er tabelleier.
ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
Starte veiviseren Velg en datakilde
Hvis du ikke har lagt til noen kilde i hendelsesstrømmen ennå, velger du Bruk ekstern kildeflis .
Hvis du legger til kilden i en allerede publisert hendelsesstrøm, bytter du til redigeringsmodus , velger Legg til kilde på båndet, og deretter velger du Eksterne kilder.
Søk etter og velg
Konfigurer og koble til PostgreSQL Database CDC
Velg Ny tilkobling på Koble til-siden.
Skriv inn følgende informasjon under Tilkoblingsinnstillinger.
Server: Serveradressen til PostgreSQL-databasen, for eksempel my-pgsql-server.postgres.database.azure.com.
Database: Databasenavnet, for eksempel my_database.
Rull nedover, og følg disse trinnene i delen Tilkoblingslegitimasjon .
Skriv inn et navn for tilkoblingen for tilkoblingsnavnet.
Velg Grunnleggende for godkjenningstype.
Merk
For øyeblikket støtter Fabric-hendelsesstrømmer bare enkel godkjenning.
Skriv inn brukernavn og passord for databasen.
Velg Koble til.
Gjør følgende på Koble til-siden :
Se gjennom sammendraget på siden Se gjennom + koble til, og velg deretter Legg til.
Merk
Maksimalt antall kilder og mål for én hendelsesstrøm er 11.
Vis oppdatert hendelsesstrøm
Du kan se POSTgreSQL Database CDC-kilden lagt til i eventstream i redigeringsmodus.
Hvis du vil implementere denne nylig tilføyde PostgreSQL DB CDC-kilden, velger du Publiser. Når du har fullført disse trinnene, er PostgreSQL DB CDC-kilden tilgjengelig for visualisering i Live-visningen.
Relatert innhold
Andre koblinger:
- Amazon Kinesis Data Streams
- Azure Cosmos DB
- Azure Event Hubs
- Azure Service Bus
- Azure IoT Hub
- Azure SQL Database Change Data Capture (CDC)
- Confluent Kafka
- Egendefinert endepunkt
- Google Cloud Pub/Sub
- MySQL Database CDC
- PostgreSQL Database CDC
- Eksempeldata
- Azure Blob Storage-hendelser
- Arrangement for stoffarbeidsområde