Megosztás a következőn keresztül:

MySQL Database CDC-forrás hozzáadása eseménystreamhez (előzetes verzió)

  • Cikk

Feljegyzés

Ez a cikk a Microsoft által már nem használt kifejezésre SLAVEmutató hivatkozásokat tartalmaz. Ha a kifejezés el lesz távolítva a szoftverből, eltávolítjuk ebből a cikkből.

Ez a cikk bemutatja, hogyan vehet fel Azure Database for MySQL Change Data Capture-forrást egy eseménystreambe. A Microsoft Fabric-eseménystreamekhez készült Azure MySQL Database Change Data Capture (CDC) forrásösszekötővel pillanatképet készíthet egy Azure Database for MySQL-adatbázis aktuális adatairól.

Megadhatja a monitorozni kívánt táblákat, és az eventstream rögzíti a táblák későbbi sorszintű változásait. Miután rögzítette a módosításokat az eseménystreamben, valós időben feldolgozhatja ezeket a CDC-adatokat, és elküldheti őket a Fabric különböző céljaira további feldolgozás vagy elemzés céljából.

Fontos

A Fabric-eseménystreamek továbbfejlesztett képességei jelenleg előzetes verzióban érhetők el.

Feljegyzés

Ez a forrás nem támogatott a munkaterület kapacitásának következő régióiban: USA3 nyugati régiója, Nyugat-Svájc.

Előfeltételek

  • Hozzáférés a Fabric prémium szintű munkaterületéhez közreműködői vagy magasabb engedélyekkel.
  • Hozzáférés a rugalmas Azure Database for MySQL-kiszolgáló egy példányához.
  • A MySQL-adatbázisnak nyilvánosan elérhetőnek kell lennie, és nem lehet tűzfal mögött vagy virtuális hálózaton keresztül biztonságos.

Feljegyzés

Egy eseményfolyam forrásainak és célhelyeinek maximális száma 11.

A MySQL DB beállítása

Az összekötő a Debezium MySQL-összekötőt használja az Azure Database for MySQL-adatbázis változásainak rögzítéséhez. Meg kell határoznia egy MySQL-felhasználót, aki megfelelő jogosultságokkal rendelkezik minden olyan adatbázisban, ahol az Üzenetkezelési összekötő rögzítheti a módosításokat. Közvetlenül használhatja a rendszergazda felhasználót az adatbázishoz való csatlakozáshoz, amely általában már az alábbiak szerint rendelkezik a megfelelő jogosultságokkal. vagy az alábbi lépéseket követve új felhasználót hozhat létre

Feljegyzés

Az új felhasználói vagy rendszergazdai fiók és a megfelelő jelszó használatával később csatlakozhat az adatbázishoz az Eventstreamben.

  1. A parancssorban mysql hozza létre a MySQL-felhasználót:

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

  2. Adja meg a szükséges jogosultságokat a felhasználónak:

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

  3. A felhasználó engedélyeinek véglegesítése:

    mysql> FLUSH PRIVILEGES;

Annak ellenőrzéséhez, hogy a felhasználó vagy a rendszergazda rendelkezik-e a szükséges jogosultságokkal, futtassa az alábbi parancsot, majd a fenti 2. lépésben meg kell jeleníteni a szükséges jogosultságokat.

SHOW GRANTS FOR user;

A szükséges engedélyek felhasználónak való megadásáról a MySQL-hez készült Debezium-összekötő :: Debezium dokumentációja című témakörben talál további információt.

A binlog engedélyezése

Engedélyeznie kell a bináris naplózást a MySQL-replikációhoz. A bináris naplók rögzítik a replikációs eszközök tranzakciófrissítéseit a módosítások propagálása érdekében.

  1. Az Azure Database for MySQL-fiók Azure Portal lapján válassza a Kiszolgálóparamétereklehetőséget a Bal oldali navigációs sáv Beállítások területén.

  2. A Kiszolgáló paraméterei lapon konfigurálja a következő tulajdonságokat, majd válassza a Mentés lehetőséget.

    • A binlog_row_image válassza a teljes lehetőséget.

    • A binlog_expire_logs_seconds adja meg, hogy a szolgáltatás hány másodpercig várjon a bináris naplófájl kiürítése előtt. Állítsa be az értéket úgy, hogy megfeleljen a környezet igényeinek, például a 86400-nak.

    Képernyőkép a kiszolgálóparaméterek alatti replikáció binlog-beállításairól.

Azure MySQL DB (CDC) hozzáadása forrásként

  1. A Fabric valós idejű intelligenciájában válassza az Eventstream lehetőséget egy új eseménystream létrehozásához. Győződjön meg arról, hogy a Bővített képességek (előzetes verzió) lehetőség engedélyezve van.

    Képernyőkép egy új eseménystream létrehozásáról.

  2. A következő képernyőn válassza a Külső forrás hozzáadása lehetőséget.

    Képernyőkép a Külső forrás hozzáadása lehetőség kiválasztásáról.

Az Azure MySQL DB (CDC) konfigurálása és csatlakoztatása

  1. Az Adatforrás kiválasztása képernyőn válassza az Azure MySQL DB (CDC) lehetőséget adatforrásként.

    Képernyőkép az Azure MySQL DB (CDC) kiválasztásáról.

  2. A Csatlakozás képernyőn a Kapcsolat területen válassza az Új kapcsolat lehetőséget a felhőkapcsolat létrehozásához.

  3. Adja meg a következő kapcsolatbeállításokat és kapcsolati hitelesítő adatokat az Azure MySQL DB-hez, majd válassza a Csatlakozás lehetőséget.

    • Kiszolgáló: Az Azure Database for MySQL-adatbázis kiszolgálócíme, például my-mysql-server.mysql.database.azure.com.
    • Adatbázis: Az adatbázis neve, például my_database.
    • Kapcsolat neve: Automatikusan létrejön, vagy megadhat egy új nevet ennek a kapcsolatnak.
    • Felhasználónév és jelszó: Adja meg az Azure Database for MySQL-adatbázis hitelesítő adatait. Győződjön meg arról, hogy megadja a kiszolgálói rendszergazdai fiókot vagy a szükséges jogosultságokkal létrehozott felhasználói fiókot.

    Képernyőkép az Azure MySQL DB (CDC) kapcsolati beállításairól.

  4. Adja meg az alábbi adatokat az Azure MySQL DB CDC-adatforrás konfigurálásához, majd válassza a Tovább gombot.

    • Táblázat(ok): Adja meg a táblázatnevek vesszővel elválasztott listáját. Minden táblanévnek a formátumot <database name>.<table name>kell követnie, például my_database.users.
    • Kiszolgálóazonosító: Adjon meg egy egyedi értéket a MySQL-fürt minden kiszolgáló- és replikációs ügyfele számára. Az alapértelmezett érték 1000.
    • Port: Hagyja változatlanul az alapértelmezett értéket.

    Képernyőkép az Azure MySQL DB (CDC) kapcsolat tábláinak, kiszolgálóazonosítójának és portjának kiválasztásáról.

    Feljegyzés

    Állítson be egy másik kiszolgálóazonosítót minden olvasóhoz. Minden, a binlog olvasására szolgáló MySQL-adatbázis-ügyfélnek rendelkeznie kell egy egyedi azonosítóval, az úgynevezett kiszolgálóazonosítóval. A MySQL-kiszolgáló ezt az azonosítót használja a hálózati kapcsolat és a binlog pozíciójának fenntartásához. Az azonos kiszolgálóazonosítóval azonos feladatokat használó különböző feladatok helytelen binlog pozícióból való olvasást eredményezhetnek. Ezért ajánlott minden olvasóhoz másik kiszolgálóazonosítót beállítani.

  5. Az Azure MySQL DB CDC-forrás összegzésének áttekintése után válassza a Hozzáadás lehetőséget a konfiguráció befejezéséhez.

Az eseménystreamhez hozzáadott Azure MySQL DB (CDC) forrás szerkesztési módban jelenik meg.

Képernyőkép a hozzáadott Azure MySQL DB CDC-forrásról Szerkesztés módban, kiemelt Közzététel gombbal.

A módosítások közzétételéhez és az Azure MySQL DB CDC-adatok eseménystreambe való streameléséhez válassza a Közzététel lehetőséget.

Képernyőkép a közzétett eseménystreamről az Azure MySQL DB CDC-forrással Élő nézetben.

Kapcsolódó tartalom

Egyéb összekötők: