Pridanie zdroja CDC databázy MySQL do udalosťstreamu (Preview)

Poznámka

Tento článok obsahuje odkazy na výraz SLAVE, termín, ktorý už Microsoft nepoužíva. Po odstránení výrazu zo softvéru ho odstránime z tohto článku.

V tomto článku sa dozviete, ako pridať databázu Azure pre MySQL Zmeniť zdroj zachytenia údajov do eventstreamu. Zdrojový konektor pre udalosti Azure MySQL Database Change Data Capture (CDC) pre streamy udalostí služby Microsoft Fabric vám umožňuje zaznamenať snímku aktuálnych údajov v databáze Azure Database for MySQL.

Môžete zadať tabuľky, ktoré sa majú monitorovať, a udalosť eventstream zaznamenáva akékoľvek budúce zmeny tabuliek 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 službe 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.
• Prístup k inštancii databázy Azure pre MySQL – flexibilný server.
• Databáza MySQL musí byť verejne prístupná a nesmie byť za bránou firewall ani zabezpečená vo virtuálnej sieti.

Poznámka

Maximálny počet zdrojov a cieľov pre jeden eventstream je 11.

Nastavenie databázy MySQL

Konektor používa konektor Debezium MySQL na zachytenie zmien v databáze Azure Database for MySQL. Musíte definovať používateľa MySQL s príslušnými oprávneniami vo všetkých databázach, z ktorých môže konektor na odosielanie správ zaznamenávať zmeny. Správcu môžete použiť priamo na pripojenie k databáze, ktorá zvyčajne má príslušné oprávnenia, ako je uvedené nižšie. alebo môžete podľa nasledujúcich krokov vytvoriť nového používateľa.

Poznámka

Nové používateľské konto alebo konto správcu a zodpovedajúce heslo sa použijú na pripojenie k databáze neskôr v rámci eventstreamu.

1. V príkazovom mysql riadku vytvorte používateľa MySQL:

   mysql> CREATE USER 'user'@'%' IDENTIFIED BY 'password';
   

2. Udeľte používateľovi požadované oprávnenia:

   mysql> GRANT SELECT, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'user'@'%';
   

3. Dokončenie povolení používateľa:

   mysql> FLUSH PRIVILEGES;
   

Ak chcete overiť, či má používateľ alebo správca udelené požadované oprávnenia, spustite nižšie uvedený príkaz a potom sa zobrazia požadované oprávnenia uvedené vyššie v kroku č. 2.

SHOW GRANTS FOR user;

Ďalšie informácie o udelení požadovaných povolení používateľovi nájdete v téme Ladiaci konektor pre MySQL :: Dokumentácia k ladenia.

Povolenie binlog

Pre replikáciu MySQL musíte povoliť binárne zapisovanie do denníka. Binárne denníky zaznamenáva aktualizácie transakcií pre nástroje replikácie na šírenie zmien.

1. Na stránke portálu Azure pre vaše konto Azure Database for MySQL vyberte v ľavom navigačnom paneli položku Parametre servera v časti Nastavenia .

2. Na stránke Parametre servera nakonfigurujte nasledujúce vlastnosti a potom vyberte položku Uložiť.

   • V binlog_row_image vyberte plnú.

   • V binlog_expire_logs_seconds nastavte počet sekúnd čakania služby, kým sa binárny súbor denníka vymaže. Nastavte hodnotu tak, aby zodpovedala potrebám vášho prostredia, napríklad 86 400.

   

Pridanie databázy Azure MySQL DB (CDC) ako zdroja

1. V aplikácii Fabric v reálnom čase vyberte položku Eventstream , čím vytvoríte nový eventstream. Uistite sa, že je povolená možnosť Rozšírené možnosti (ukážka ).

   

2. Na ďalšej obrazovke vyberte položku Pridať externý zdroj.

   

Konfigurácia a pripojenie k databáze Azure MySQL (CDC)

1. Na obrazovke Vyberte zdroj údajov vyberte ako zdroj údajov azure MySQL DB (CDC ).

   

2. Na obrazovke Pripojiť v časti Pripojenie vyberte položku Nové pripojenie a vytvorte cloudové pripojenie.

3. Zadajte nasledujúce nastavenia pripojenia a poverenia na pripojenie pre databázu Azure MySQL a potom vyberte položku Pripojiť.

   • Server: Adresa servera databázy Azure pre databázu MySQL, napríklad my-mysql-server.mysql.database.azure.com.
   • Databáza: Názov databázy, napríklad my_database.
   • Názov pripojenia: Automaticky vygenerované alebo môžete zadať nový názov pre toto pripojenie.
   • Meno používateľa a heslo: zadajte poverenia pre databázu Azure Database for MySQL. Zadajte konto správcu servera alebo vytvorené používateľské konto s udelenými požadovanými oprávneniami.

   

4. Zadajte nasledujúce informácie na konfiguráciu zdroja údajov Azure MySQL DB CDC a potom vyberte položku Ďalej.

   • Table(s): Zadajte zoznam názvov tabuliek oddelených čiarkami. Každý názov tabuľky musí mať nasledujúci formát <database name>.<table name>, napríklad my_database.users.
   • ID servera: zadajte jedinečnú hodnotu pre každého klienta servera a replikácie v klastri MySQL. Predvolená hodnota je 1 000.
   • Port: Ponechajte predvolenú hodnotu nezmenenú.

   

   Poznámka

   Pre každú čítačku nastavte iné ID servera. Každý klient databázy MySQL na čítanie intervalov by mal mať jedinečné ID, ktoré sa nazýva ID servera. MySQL Server používa toto ID na zachovanie sieťového pripojenia a pozície binlog. Rôzne úlohy, ktoré zdieľajú rovnaké ID servera, môžu čítať zo zlej pozície binlog. Preto sa odporúča pre každú čítačku nastaviť iné ID servera.

5. Po kontrole súhrnu pre zdroj CDC databázy Azure MySQL vyberte položku Pridať , čím konfiguráciu dokončíte.

Zobrazí sa zdroj databázy Azure MySQL DB (CDC) pridaný do vášho eventstreamu v režime úprav.

Vyberte položku Publikovať a publikujte zmeny a začnite streamovať údaje CDC databázy Azure MySQL do streamu udalostí.

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
• PostgreSQL Database CDC
• Vzorové údaje
• Udalosti ukladacieho priestoru objektu BLOB platformy Azure
• Udalosť pracovného priestoru služby Fabric