Přidání zdroje CDC databáze PostgreSQL do streamu událostí
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.
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 v režimu licence kapacity Fabric (nebo) zkušebním režimu licence 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.
Pokud nemáte stream událostí, vytvořte stream událostí.
Povolení CDC ve službě Azure Database for PostgreSQL
Pokud chcete povolit CDC na flexibilním serveru Azure Database for PostgreSQL, postupujte takto:
Na stránce flexibilního serveru Azure Database for PostgreSQL na webu Azure Portal vyberte parametry serveru v navigační nabídce.
Na stránce Parametry serveru:
- Nastavte wal_level na logickou hodnotu.
- Aktualizujte max_worker_processes alespoň na 16.
Uložte změny a restartujte server.
Ověřte, že vaše instance flexibilního serveru Azure Database for PostgreSQL umožňuje veřejný síťový provoz.
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;
Spusťte průvodce výběrem zdroje dat.
Pokud jste do streamu událostí ještě nepřidali žádný zdroj, vyberte Použít dlaždici externího zdroje .
Pokud přidáváte zdroj do již publikovaného streamu událostí, přepněte do režimu úprav , na pásu karet vyberte Přidat zdroj a pak vyberte Externí zdroje.
Na stránce Vybrat zdroj dat vyhledejte a vyberte Připojit na dlaždici Azure DB for PostgreSQL (CDC).
Konfigurace a připojení ke službě Azure Database for PostgreSQL CDC
Na stránce Připojit vyberte Nové připojení.
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.
Posuňte se dolů a v části Přihlašovací údaje připojení postupujte takto.
Jako název připojení zadejte název připojení.
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í.
Zadejte uživatelské jméno a heslo pro databázi.
Vyberte Připojit.
Teď na stránce Připojit proveďte následující kroky:
Na stránce Zkontrolovat a připojit zkontrolujte souhrn a pak vyberte Přidat.
Poznámka:
Maximální počet zdrojů a cílů pro jeden stream událostí je 11.
Zobrazení aktualizovaného streamu událostí
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 Service Bus
- 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