PostgreSQL Database CDC hozzáadása forrásként a valós idejű központban (előzetes verzió)

Ez a cikk a PostgreSQL Database Change Data Capture (CDC) eseményforrásként való hozzáadását ismerteti a Fabric Valós idejű központban.

A PostgreSQL Database Change Data Capture (CDC) forrásösszekötője a Microsoft Fabric-eseménystreamekhez lehetővé teszi, hogy pillanatképet készítsen az aktuális adatokról egy PostgreSQL-adatbázisban. Az összekötő ezután figyeli és rögzíti az adatok későbbi sorszintű változásait.

Feljegyzés

A valós idejű központ jelenleg előzetes verzióban érhető el.

Előfeltételek

• Hozzáférés kérése a Fabric prémium szintű munkaterületéhez közreműködői vagy annál magasabb engedélyekkel.

• Regisztrált felhasználói hozzáférés a PostgreSQL-adatbázisban.

• A CDC engedélyezve van a PostgreSQL-adatbázisban.

  Ha rendelkezik Azure Database for PostgreSQL-sel, a CDC engedélyezéséhez kövesse a következő szakaszban leírt lépéseket. Részletes információkért lásd a logikai replikációt és a logikai dekódolást – Rugalmas Azure Database for PostgreSQL-kiszolgáló.

  Más PostgreSQL-adatbázisok esetén lásd a PostgreSQL Debezium-összekötőjének dokumentációját:: Debezium Documentation.

Feljegyzés

Több tábla CDC-je nem támogatott.

CDC engedélyezése az Azure Database for PostgreSQL-ben

Ha engedélyezni szeretné a CDC-t az Azure Database for PostgreSQL-ben, kövesse az alábbi lépéseket az üzembe helyezés típusától függően.

Önálló Azure Database for PostgreSQL-kiszolgáló

1. Nyissa meg az Azure Portal Replikáció lapját.

2. Módosítsa a replikációs szabályt logikaira.

   

Rugalmas Azure Database for PostgreSQL-kiszolgáló

1. Az Azure Portal rugalmas Azure Database for PostgreSQL-kiszolgálóoldalán válassza a kiszolgálóparamétereket a navigációs menüben.

2. A Kiszolgáló paraméterei lapon:

   • Állítsa a wal_level logikai értékre.

   • Frissítse a max_worker_processes legalább 16-ra.

     

3. Mentse a módosításokat, és indítsa újra a kiszolgálót.

4. Ellenőrizze, hogy a rugalmas Azure Database for PostgreSQL-kiszolgálópéldány engedélyezi-e a nyilvános hálózati forgalmat.

5. Adja meg a rendszergazdai felhasználói replikációs engedélyeket az alábbi SQL-utasítás futtatásával.

   ALTER ROLE <admin user> WITH REPLICATION;
   

Események lekérése felület indítása

1. Váltson a Valós idejű intelligencia felületre a Microsoft Fabricben. A bal oldali navigációs sávon válassza a Microsoft Fabric, majd a Valós idejű intelligencia lehetőséget.

   

2. Válassza a valós idejű központot a bal oldali navigációs sávon.

   

3. A Valós idejű központ lapon válassza a + Események lekérése lehetőséget a lap jobb felső sarkában.

   

Használja a PostgreSQL Database CDC hozzáadása forrásszakasz utasításait.

Microsoft-források lap

1. A Valós idejű központban váltson a Microsoft-források lapra .

2. A Forrás legördülő listában válassza a PostgreSQL (CDC) lehetőséget.

3. Előfizetés esetén válasszon ki egy Azure-előfizetést, amely rendelkezik az Azure MySQL Database-fiókkal rendelkező erőforráscsoporttal.

4. Erőforráscsoport esetén válasszon ki egy erőforráscsoportot, amely rendelkezik az adatbázissal.

5. Régió esetén válassza ki azt a helyet, ahol az adatbázis található.

6. Most vigye az egeret a PostgreSQL Database CDC-forrás nevére, amelyet valós idejű központhoz szeretne csatlakoztatni az adatbázisok listájában, és válassza a Csatlakozás gombot, vagy válassza a ... (három pont), majd válassza a Csatlakozás gombot.

   

   A kapcsolati adatok konfigurálásához használja az Azure MySQL DB CDC hozzáadása forrásszakasz lépéseit. Hagyja ki az Azure MySQL DB CDC forrástípusként való kiválasztásának első lépését az Események lekérése varázslóban.

Azure Database for PostgreSQL CDC hozzáadása forrásként

1. Az Adatforrás kiválasztása képernyőn válassza az Azure DB for PostgreSQL (CDC) lehetőséget.

   

2. A Csatlakozás lapon válassza az Erőforrás megnyitása lehetőséget az Azure PostgreSQL-adatbázishoz való navigáláshoz. Jegyezze fel a kiszolgáló nevét az Áttekintés lapon. A következő formátumban van: myazurepostgresqlserver.postgres.database.azure.com.

   

3. A Csatlakozás lapon válassza az Új kapcsolat lehetőséget.

   

4. A Csatlakozás ion beállításai szakaszban adja meg a következő adatokat.

   • Kiszolgáló: A PostgreSQL-adatbázis kiszolgálócíme, például my-pgsql-server.postgres.database.azure.com.

   • Adatbázis: Az adatbázis neve, például my_database.

     

5. Görgessen le, és a Csatlakozás ion hitelesítő adatai szakaszban kövesse az alábbi lépéseket.

   1. A Csatlakozás ion nevében adja meg a kapcsolat nevét.

   2. Hitelesítési típus esetén válassza az Alapszintű lehetőséget.

      Feljegyzés

      A Fabric-eseménystreamek jelenleg csak az alapszintű hitelesítést támogatják.

   3. Adja meg az adatbázis felhasználónevét és jelszavát .

   4. Válassza a Kapcsolódás lehetőséget.

      

6. Most a Csatlakozás lapon hajtsa végre az alábbi lépéseket:

   1. Táblázat esetén adja meg a tábla nevét.

   2. Port esetén adja meg a portszámot, vagy hagyja meg az alapértelmezett értéket: 5432.

   3. Az eseménystream neveként adja meg az eseménystream nevét. A varázsló létrehoz egy eseménystreamet a kiválasztott PostgreSQL Database CDC-vel forrásként.

   4. A stream neve automatikusan létrejön, ha hozzáfűzi a -streamet az eseménystream nevéhez. Ez a stream a valós idejű központ Adatfolyamok lapján jelenik meg, amikor a varázsló befejeződik.

   5. Válassza a Lap alján a Tovább gombot.

      

7. A Véleményezés és létrehozás képernyőn tekintse át az összegzést, majd válassza a Forrás létrehozása lehetőséget.

   

Adatfolyam részleteinek megtekintése

1. A Véleményezés és létrehozás lapon, ha az Eseményfolyam megnyitása lehetőséget választja, a varázsló megnyitja az Ön számára létrehozott eseménystreamet a kijelölt PostgreSQL Database CDC-vel forrásként. A varázsló bezárásához kattintson a Lap alján található Bezárás gombra.

   

2. A valós idejű hubon váltson a Valós idejű központ Adatfolyamok lapjára. Frissítse a lapot.. Az alábbi képen látható módon kell látnia az Ön számára létrehozott adatfolyamot.

   

Kapcsolódó tartalom

Az adatfolyamok felhasználásával kapcsolatos további információkért tekintse meg az alábbi cikkeket:

• Adatfolyamok feldolgozása
• Adatfolyamok elemzése
• Riasztások beállítása adatfolyamokon