Dela via

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

  • Artikel

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. För närvarande stöds PostgreSQL Database Change Data Capture (CDC) från följande tjänster där databaserna kan nås offentligt:

  • Azure-databas för PostgreSQL
  • Amazon RDS för PostgreSQL
  • Amazon Aurora PostgreSQL
  • Google Cloud SQL för PostgreSQL

När PostgreSQL Database CDC-källan har lagts till i händelseströmmen avbildas ändringar på radnivå i de angivna tabellerna. Dessa ändringar kan sedan bearbetas i realtid och skickas till olika mål för ytterligare analys.

Anteckning

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

Förutsättningar

Aktivera CDC i din PostgreSQL-databas

I det här avsnittet används Azure Database for PostgreSQL- som exempel.

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.

    En skärmbild av att aktivera CDC för en flexibel serverdistribution.

  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 .

Skärmbild som visar valet av rutan 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.

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 Anslut på PostgreSQL DB (CDC)-rutan.

Skärmbild som visar valet av Azure DB for PostgreSQL (CDC) som källtyp i guiden Hämta händelser.

Konfigurera och ansluta till PostgreSQL Database CDC

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

    Skärmbild som visar sidan Anslut för en Azure PostgreSQL-databas med länken Ny anslutning markerad.

  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.

      Skärmbild som visar avsnittet Anslutningsinställningar för Azure PostgreSQL-databasanslutningsappen.

  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.

      Anteckning

      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.

      Skärmbild som visar avsnittet Anslutningsautentiseringsuppgifter för Azure PostgreSQL-databasanslutningsappen.

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

    1. För Port anger du portnumret eller lämnar standardvärdet: 5432. Om den valda molnanslutningen har konfigurerats i Hantera anslutningar och gatewayerkontrollerar du att portnumret matchar den som anges där. Om de inte matchar kommer portnumret i molnanslutningen i Hantera anslutningar och gatewayer att ha företräde.

    2. För tabellväljer du 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 ange upp till 100 tabeller och varje tabellnamn (inklusive schemat) kan vara upp till 128 tecken.

      Du kan blanda båda formaten med kommatecken. Upp till 100 tabeller kan anges, med varje tabellnamn (inklusive schemanamnet) begränsat till 128 tecken om du använder fullständiga tabellidentifierare direkt.

    3. Slottnamn(valfritt): Ange namnet på den PostgreSQL-logiska slot för avkodning som skapades för att strömma ändringar från ett visst plugin för en specifik databas/schema. Servern använder det här facket för att strömma händelser till Eventstream Streaming Connector. Det får endast innehålla små bokstäver, siffror och understreck.

      • Om inget anges används ett GUID för att skapa utrymmet, vilket kräver lämpliga databasbehörigheter.
      • Om det finns ett angivet facknamn använder anslutningsappen det direkt.

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

      Skärmbild som visar sidan Anslut ifylld för Azure PostgreSQL-databasanslutningsappen.

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

    Skärmbild som visar sidan Granska och skapa fylld för Azure PostgreSQL-databasanslutningsappen.

Anteckning

Det maximala antalet källor och mål för en händelseström är 11.

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.

    En skärmbild av strömmande PostgreSQL DB CDC-källa i redigeringsvyn.

  2. Om du vill implementera den nya PostgreSQL DB CDC-källan väljer du Publicera. När du har slutfört dessa steg är din PostgreSQL DB CDC-källa tillgänglig för visualisering i Live View-funktionen.

    En skärmbild av strömmande PostgreSQL DB CDC-källa i live-vy.

Relaterat innehåll

Andra anslutningsappar: