Přidání zdroje CDC databáze PostgreSQL do streamu událostí (Preview)

V tomto článku se dozvíte, jak do streamu událostí přidat zdroj CDC (Database Change Data Capture) PostgreSQL.

Zdrojový konektor PostgreSQL Database Change Data Capture (CDC) pro streamy událostí Microsoft Fabric umožňuje zachytit snímek aktuálních dat v databázi PostgreSQL. Konektor pak monitoruje a zaznamenává všechny budoucí změny na úrovni řádků na těchto datech. Jakmile se změny zachytí v streamu událostí, můžete tato data CDC zpracovat v reálném čase a odeslat je do různých cílů v rámci infrastruktury pro další zpracování nebo analýzu.

Důležité

Rozšířené možnosti streamů událostí Fabric jsou aktuálně ve verzi Preview.

Poznámka:

Tento zdroj není podporován v následujících oblastech kapacity pracovního prostoru: USA – západ 3, Švýcarsko – západ.

Požadavky

• Přístup k pracovnímu prostoru Fabric Premium s oprávněními Přispěvatel nebo vyšší.

• Registrovaný přístup uživatele v databázi PostgreSQL.

• Vaše databáze PostgreSQL musí být veřejně přístupná a nesmí být za bránou firewall nebo zabezpečená ve virtuální síti.

• Služba CDC je povolená v databázi a tabulkách PostgreSQL.

  Pokud máte Azure Database for PostgreSQL, povolte CDC podle kroků v další části. Podrobné informace najdete v tématu Logická replikace a logické dekódování – Flexibilní server Azure Database for PostgreSQL.

  Další databáze PostgreSQL najdete v tématu Konektor Debezium pro PostgreSQL :: Dokumentace k Debezium.

Poznámka:

Maximální počet zdrojů a cílů pro jeden stream událostí je 11.

Povolení CDC ve službě Azure Database for PostgreSQL

Pokud chcete povolit CDC na flexibilním serveru Azure Database for PostgreSQL, postupujte takto:

1. Na stránce flexibilního serveru Azure Database for PostgreSQL na webu Azure Portal vyberte parametry serveru v navigační nabídce.

2. Na stránce Parametry serveru:

   • Nastavte wal_level na logickou hodnotu.
   • Aktualizujte max_worker_processes alespoň na 16.

   

3. Uložte změny a restartujte server.

4. Ověřte, že vaše instance flexibilního serveru Azure Database for PostgreSQL umožňuje veřejný síťový provoz.

5. Spuštěním následujícího příkazu SQL udělte oprávnění k replikaci uživatele správce. Pokud chcete k načtení CDC použít jiný uživatelský účet, připojte databázi PostgreSQL, ujistěte se, že je uživatel vlastníkem tabulky.

   ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
   

Přidání azure Database for PostgreSQL CDC jako zdroje

1. Vyberte Eventstream a vytvořte nový eventstream. Ujistěte se, že je povolená možnost Rozšířené možnosti (Preview ).

   

2. Na další obrazovce vyberte Přidat externí zdroj.

   

Konfigurace a připojení ke službě Azure Database for PostgreSQL CDC

1. Na obrazovce Vybrat zdroj dat vyberte Azure DB for PostgreSQL (CDC).

   

2. Na stránce Připojit vyberte Nové připojení.

   

3. V části Nastavení připojení zadejte následující informace.

   • Server: Adresa serveru vaší databáze PostgreSQL, například my-pgsql-server.postgres.database.azure.com.

   • Databáze: Název databáze, například my_database.

     

4. Posuňte se dolů a v části Přihlašovací údaje připojení postupujte takto.

   1. Jako název připojení zadejte název připojení.

   2. Jako druh ověřování vyberte Základní.

      Poznámka:

      Streamy událostí Fabric v současné době podporují pouze základní ověřování.

   3. Zadejte uživatelské jméno a heslo pro databázi.

   4. Vyberte Připojit.

      

5. Teď na stránce Připojit proveďte následující kroky:

   1. Jako tabulku zadejte název tabulky.

   2. Jako port zadejte číslo portu nebo ponechte výchozí hodnotu: 5432.

   3. V dolní části stránky vyberte Další .

      

6. Na obrazovce Zkontrolovat a vytvořit si prohlédněte souhrn a pak vyberte Přidat.

   

Zdroj CDC databáze PostgreSQL přidaný do streamu událostí můžete zobrazit v režimu úprav.

Pokud chcete implementovat nově přidaný zdroj CDC databáze PostgreSQL, vyberte Publikovat. Po dokončení těchto kroků je zdroj CDC databáze PostgreSQL dostupný pro vizualizaci v živém zobrazení.

Související obsah

Další konektory:

• Datové proudy Amazon Kinesis
• Azure Cosmos DB
• Azure Event Hubs
• Azure IoT Hub
• Azure SQL Database Change Data Capture (CDC)
• Confluent Kafka
• Vlastní koncový bod
• Google Cloud Pub/Sub
• CdC databáze MySQL
• Databáze PostgreSQL – CDC
• Ukázková data
• Události služby Azure Blob Storage
• Událost pracovního prostoru Infrastruktury