Pridanie databázy PostgreSQL CDC ako zdroja v centre v reálnom čase (ukážka)

Tento článok popisuje, ako pridať zdroj udalostí postgreSQL Database Change Data Capture (CDC) do centra v reálnom čase služby Fabric.

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.

Poznámka

Centrum v reálnom čase je aktuálne vo verzii Preview.

Požiadavky

• Získajte prístup do pracovného priestoru služby Fabric Premium s povoleniami prispievateľa alebo vyššie.

• Registrovaný prístup používateľov v databáze PostgreSQL.

• Povolené cdc v databáze PostgreSQL.

  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

Nepodporuje sa viacero tabuliek CDC.

Povolenie CDC vo vašej databáze Azure pre PostgreSQL

Ak chcete povoliť CDC vo svojej databáze Azure pre PostgreSQL, postupujte podľa týchto krokov na základe vášho typu nasadenia.

Databáza Azure pre jeden server PostgreSQL

1. Prejdite na stránku replikácie na portáli Azure.

2. Zmeňte pravidlo replikácie na logickú hodnotu.

   

Databáza Azure pre flexibilný server PostgreSQL

1. Na stránke s flexibilným serverom Azure Database for PostgreSQL na portáli Azure vyberte v navigačnej ponuke položku Parametre servera.

2. Na stránke s parametrami servera:

   • Nastavte wal_level na logickú hodnotu.

   • Aktualizujte max_worker_processes aspoň na 16.

     

3. Uložte zmeny a reštartujte server.

4. Potvrďte, že databáza Azure pre inštanciu flexibilného servera PostgreSQL umožňuje verejnú sieťovú prevádzku.

5. Spustením nasledujúceho príkazu SQL udeľte povolenia replikácie správcu používateľa.

   ALTER ROLE <admin user> WITH REPLICATION;
   

Spustenie prostredia Načítať udalosti

1. Prepnite na prostredie inteligencie v reálnom čase služby Microsoft Fabric. V ľavom navigačnom paneli vyberte položku Microsoft Fabric a vyberte položku Inteligencia v reálnom čase.

   

2. Na ľavom navigačnom paneli vyberte položku Centrum v reálnom čase.

   

3. Na stránke centra v reálnom čase vyberte položku + Načítať udalosti v pravom hornom rohu stránky.

   

Ako zdroj použite pokyny z časti Pridanie databázy PostgreSQL CDC.

Karta Zdroje od spoločnosti Microsoft

1. V centre v reálnom čase prepnite na kartu Zdroje spoločnosti Microsoft.

2. V rozbaľovacom zozname Zdroj vyberte položku PostgreSQL (CDC).

3. V časti Predplatné vyberte predplatné na Azure, ktoré má skupinu prostriedkov s kontom databázy Azure MySQL.

4. V časti Skupina zdrojov vyberte skupinu zdrojov, ktorá obsahuje databázu.

5. V časti Oblasť vyberte umiestnenie, kde sa vaša databáza nachádza.

6. Teraz presuňte kurzor myši nad názov zdroja CDC databázy PostgreSQL, ku ktorému sa chcete pripojiť v reálnom čase v zozname databáz, a vyberte tlačidlo Pripojenie, alebo vyberte ... (tri bodky) a potom vyberte tlačidlo Pripojenie.

   

   Ak chcete nakonfigurovať informácie o pripojení, použite kroky z časti Pridanie služby Azure MySQL DB CDC ako zdroja . Vynechajte prvý krok výberu položky Azure MySQL DB CDC ako typu zdroja v sprievodcovi získať udalosti.

Ako zdroj pridajte databázu Azure pre PostgreSQL CDC

1. Na obrazovke Vyberte zdroj údajov vyberte možnosť Azure DB pre PostgreSQL (CDC).

   

2. Na stránke Pripojenie výberom položky Prejsť na prostriedok prejdite do databázy Azure PostgreSQL. Zapíšte si názov servera na stránke Overview (Prehľad ). Je v nasledujúcom formáte: myazurepostgresqlserver.postgres.database.azure.com.

   

3. Na stránke Pripojenie vyberte položku Nové pripojenie.

   

4. V časti nastavenia Pripojenie ion 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.

     

5. Posuňte sa nadol a v časti poverenia Pripojenie ion postupujte podľa týchto krokov.

   1. Ako názov Pripojenie ion zadajte názov pripojenia.

   2. V časti Typ overenia vyberte možnosť Základné.

      Poznámka

      V súčasnosti streamy udalostí služby Fabric podporujú iba základné overovanie.

   3. Do databázy zadajte položky Meno používateľa a Heslo .

   4. Vyberte možnosť Pripojiť.

      

6. Teraz na stránke Pripojenie vykonajte tieto kroky:

   1. V prípade tabuľky zadajte názov tabuľky.

   2. Do poľa Port zadajte číslo portu alebo ponechajte predvolenú hodnotu: 5432.

   3. Ako názov eventstreamu zadajte názov pre udalosť eventstream. Sprievodca vytvorí udalosťstream s vybratou databázou PostgreSQL CDC ako zdrojom.

   4. Názov Streamu sa automaticky vygeneruje pripojením položky -stream k názvu udalosťového toku. Tento stream sa zobrazí na karte Streamy údajov v centre reálneho času po dokončení sprievodcu.

   5. Vyberte položku Ďalej v dolnej časti stránky.

      

7. Na obrazovke Skontrolovať a vytvoriť skontrolujte súhrn a potom vyberte položku Vytvoriť zdroj.

   

Zobrazenie podrobností streamu údajov

1. Ak na stránke Skontrolovať a vytvoriť vyberiete položku Otvoriť udalosťstream, sprievodca otvorí udalosťstream, ktorý ste vytvorili, s vybratou položkou CDC databázy PostgreSQL ako zdrojom. Sprievodcu zavriete výberom položky Zavrieť v dolnej časti stránky.

   

2. V centre v reálnom čase prepnite na kartu Streamy údajov centra v reálnom čase. Obnovte stránku. Mal by sa zobraziť stream údajov vytvorený za vás, ako je to znázornené na nasledujúcom obrázku.

   

Súvisiaci obsah

Ďalšie informácie o spotrebúvaní streamov údajov nájdete v nasledujúcich článkoch:

• Spracovanie streamov údajov
• Analýza streamov údajov
• Nastavenie upozornení v streamoch údajov