Lägg till PostgreSQL Database CDC-källa i en händelseström

Den här artikeln visar hur du lägger till en Källa för PostgreSQL Database Change Data Capture (CDC) i en händelseström.

Med källanslutningsappen PostgreSQL Database Change Data Capture (CDC) för Microsoft Fabric-händelseströmmar kan du samla in en ögonblicksbild av aktuella data i en PostgreSQL-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.

Förutsättningar

• Åtkomst till en arbetsyta i infrastrukturkapacitetslicensläget (eller) utvärderingslicensläget med deltagare eller högre behörigheter.

• Registrerad användaråtkomst i PostgreSQL-databasen.

• PostgreSQL-databasen måste vara offentligt tillgänglig och inte vara bakom en brandvägg eller skyddas i ett virtuellt nätverk.

• CDC aktiverat i PostgreSQL-databasen och tabellerna.

  Om du har Azure Database for PostgreSQL följer du stegen i nästa avsnitt för att aktivera CDC. Detaljerad information finns i Logisk replikering och logisk avkodning – Azure Database for PostgreSQL – flexibel server.

  För andra PostgreSQL-databaser, se Debezium Connector för PostgreSQL :: Debezium Documentation.

• Om du inte har en händelseström skapar du en händelseström.

Aktivera CDC i din Azure Database for PostgreSQL

Följ dessa steg för att aktivera CDC i din flexibla Azure Database for PostgreSQL-server:

1. På sidan Azure Database for PostgreSQL – flexibel server i Azure Portal väljer du Serverparametrar i navigeringsmenyn.

2. På sidan Serverparametrar :

   • Ange wal_level till logisk.
   • Uppdatera max_worker_processes till minst 16.

   

3. Spara ändringarna och starta om servern.

4. Bekräfta att din Azure Database for PostgreSQL – flexibel server-instans tillåter offentlig nätverkstrafik.

5. Ge administratörsanvändaren replikeringsbehörigheter genom att köra följande SQL-instruktion. Om du vill använda ett annat användarkonto för att ansluta din PostgreSQL DB för att hämta CDC kontrollerar du att användaren är tabellägare.

   ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
   

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 .

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.

På sidan Välj en datakälla söker du efter och väljer Anslut på panelen Azure DB for PostgreSQL (CDC).

Konfigurera och ansluta till Azure Database for PostgreSQL CDC

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

   

2. I avsnittet Anslutningsinställningar anger du följande information.

   • Server: Serveradressen för postgreSQL-databasen, till exempel my-pgsql-server.postgres.database.azure.com.

   • Databas: Databasnamnet, till exempel my_database.

     

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

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

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

      Kommentar

      För närvarande stöder Fabric-händelseströmmar endast grundläggande autentisering.

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

   4. Välj Anslut.

      

4. Gör nu följande på sidan Anslut :

   1. För tabell anger du ett tabellnamn.

   2. För Port anger du portnumret eller lämnar standardvärdet: 5432.

   3. Välj Nästa längst ned på sidan.

      

5. På sidan Granska + anslut granskar du sammanfattningen och väljer sedan Lägg till.

   

Visa uppdaterad händelseström

1. Du kan se att PostgreSQL Database CDC-källan har lagts till i din händelseström i redigeringsläge.

   

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

   

Relaterat innehåll

Andra anslutningsappar:

• 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
• Anpassad slutpunkt
• Google Cloud Pub/Sub
• MySQL Database CDC
• PostgreSQL Database CDC
• Exempeldata
• Azure Blob Storage-händelser
• Fabric-arbetsytehändelse