Sdílet prostřednictvím


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:

  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.

    Snímek obrazovky s povolením CDC pro flexibilní nasazení serveru

  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;
    

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 .

Snímek obrazovky znázorňující výběr dlaždice Použít externí zdroj

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.

Snímek obrazovky znázorňující výběr nabídky Přidat zdroj do externích zdrojů

Na stránce Vybrat zdroj dat vyhledejte a vyberte Připojit na dlaždici Azure DB for PostgreSQL (CDC).

Snímek obrazovky znázorňující výběr Azure DB for PostgreSQL (CDC) jako typu zdroje v průvodci získáním událostí

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

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

    Snímek obrazovky znázorňující stránku Připojit pro databázi Azure PostgreSQL se zvýrazněným odkazem na nové připojení

  2. 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.

      Snímek obrazovky znázorňující část Nastavení připojení pro konektor databáze Azure PostgreSQL

  3. 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.

      Snímek obrazovky znázorňující část Přihlašovací údaje připojení pro konektor databáze Azure PostgreSQL

  4. 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ší .

      Snímek obrazovky znázorňující stránku Připojení vyplněnou pro konektor databáze Azure PostgreSQL

  5. Na stránce Zkontrolovat a připojit zkontrolujte souhrn a pak vyberte Přidat.

    Snímek obrazovky znázorňující stránku Kontrola a vytvoření vyplněné konektoru databáze Azure PostgreSQL

Poznámka:

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

Zobrazení aktualizovaného streamu událostí

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

    Snímek obrazovky se zdrojem CDC streamované databáze PostgreSQL v zobrazení pro úpravy

  2. 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í.

    Snímek obrazovky se zdrojem CDC streamované databáze PostgreSQL v živém zobrazení

Další konektory: