Pridanie zdroja CDC databázy PostgreSQL do eventstreamu (Preview)
V tomto článku sa dozviete, ako pridať zdroj cdc (Change Data Capture) databázy PostgreSQL do toku udalosti.
Zdrojový konektor pre streamy udalostí PostgreSQL Change Data Capture (CDC) pre streamy udalostí služby Microsoft Fabric vám umožňuje zaznamenať snímku aktuálnych údajov v databáze PostgreSQL. Konektor potom monitoruje a zaznamenáva všetky budúce zmeny týchto údajov na úrovni riadkov. Keď sa zmeny zaznamenajú v eventstreame, môžete spracovať tieto údaje CDC v reálnom čase a odoslať ich do rôznych cieľov v rámci služby Fabric na ďalšie spracovanie alebo analýzu.
Dôležité
Vylepšené možnosti streamov udalostí služby Fabric sú v súčasnosti v režime ukážky.
Poznámka
Tento zdroj nie je podporovaný v týchto oblastiach kapacity pracovného priestoru: Západ US3, Švajčiarsko Západ.
Požiadavky
Prístup k pracovnému priestoru služby Fabric Premium s povoleniami Prispievateľ alebo vyššími.
Registrovaný prístup používateľov v databáze PostgreSQL.
Databáza PostgreSQL musí byť verejne prístupná a nesmie byť za bránou firewall ani zabezpečená vo virtuálnej sieti.
Cdc povolené v databáze PostgreSQL a tabuľkách.
Ak máte databázu Azure Database for PostgreSQL, postupujte podľa krokov v ďalšej časti na povolenie cdc. Podrobné informácie nájdete v téme Logická replikácia a logické dekódovanie – databáza Azure pre PostgreSQL – flexibilný server.
Ďalšie databázy PostgreSQL nájdete v téme Debezium connector pre PostgreSQL :: Dokumentácia k debezium.
Poznámka
Maximálny počet zdrojov a cieľov pre jeden eventstream je 11.
Povolenie CDC vo vašej databáze Azure pre PostgreSQL
Ak chcete povoliť CDC v databáze Azure pre PostgreSQL Flexible Server, postupujte podľa týchto krokov:
Na stránke Databáza Azure Database for PostgreSQL Flexible Server na portáli Azure vyberte v navigačnej ponuke položku Parametre servera.
Na stránke s parametrami servera:
- Nastavte wal_level na logickú hodnotu.
- Aktualizujte max_worker_processes aspoň na 16.
Uložte zmeny a reštartujte server.
Skontrolujte, či databáza Azure pre inštanciu postgreSQL Flexible Servera umožňuje verejnú sieťovú prevádzku.
Spustením nasledujúceho príkazu SQL udeľte povolenia replikácie správcu používateľa . Ak chcete použiť iné používateľské konto na pripojenie databázy PostgreSQL, aby sa načítala cdc, uistite sa, že používateľ je vlastníkom tabuľky.
ALTER ROLE <admin_user_or_table_owner_user> WITH REPLICATION;
Ako zdroj pridajte databázu Azure pre PostgreSQL CDC
Ak chcete vytvoriť nový eventstream, vyberte položku Eventstream . Uistite sa, že je povolená možnosť Rozšírené možnosti (ukážka ).
Na ďalšej obrazovke vyberte položku Pridať externý zdroj.
Konfigurácia a pripojenie k databáze Azure pre PostgreSQL CDC
Na obrazovke Vyberte zdroj údajov vyberte možnosť Azure DB pre PostgreSQL (CDC).
Na stránke Pripojiť vyberte položku Nové pripojenie.
V časti Nastavenia pripojenia zadajte nasledujúce informácie.
Server: Adresa servera vašej databázy PostgreSQL, napríklad my-pgsql-server.postgres.database.azure.com.
Databáza: Názov databázy, napríklad my_database.
Posuňte sa nadol a v časti Poverenia na pripojenie postupujte podľa týchto krokov.
Do poľa Názov pripojenia zadajte názov pripojenia.
V časti Typ overenia vyberte možnosť Základné.
Poznámka
V súčasnosti streamy udalostí služby Fabric podporujú iba základné overovanie.
Do databázy zadajte položky Meno používateľa a Heslo .
Vyberte možnosť Pripojiť.
Teraz na stránke Pripojiť vykonajte tieto kroky:
Na obrazovke Skontrolovať a vytvoriť skontrolujte súhrn a potom vyberte položku Pridať.
Môžete si pozrieť zdroj databázy PostgreSQL CDC pridaný do vášho eventstreamu v režime úprav.
Ak chcete implementovať tento novopridaný zdroj CDC PostgreSQL, vyberte položku Publikovať. Po dokončení týchto krokov bude zdroj CDC postgreSQL k dispozícii na vizualizáciu v zobrazení Naživo.
Súvisiaci obsah
Iné konektory:
- Údajové streamy služby Amazon Kinesis
- Azure Cosmos DB
- Centrá udalostí Azure
- Azure IoT Hub
- Azure SQL Database Change Data Capture (CDC)
- Konfiškentný Kafka
- Vlastný koncový bod
- Google Cloud Pub/Sub
- Databáza MySQL CDC
- PostgreSQL Database CDC
- Vzorové údaje
- Udalosti ukladacieho priestoru objektu BLOB platformy Azure
- Udalosť pracovného priestoru služby Fabric