MySQL-tietokannan CDC-lähteen lisääminen tapahtumavirtaan (esikatselu)

Artikkeli
06/09/2024

Muistiinpano

Tässä artikkelissa on viittauksia termiin SLAVE, jota Microsoft ei enää käytä. Kun termi poistetaan ohjelmistosta, poistamme sen tästä artikkelista.

Tässä artikkelissa kerrotaan, miten voit lisätä Azure Database for MySQL Change Data Capture -lähteen tapahtumavirtaan. Microsoft Fabric -tapahtumavirtojen Azure MySQL -tietokannan Change Data Capture (CDC) -lähdeliittimen avulla voit tallentaa tilannevedoksen nykyisistä tiedoista Azure Database for MySQL -tietokantaan.

Voit määrittää valvottavat taulukot, ja tapahtumavirta kirjaa mahdolliset tulevat rivitason muutokset taulukoihin. Kun muutokset on saatu tapahtumavirtaan, voit käsitellä nämä CDC:n tiedot reaaliaikaisesti ja lähettää ne Fabricissa eri kohteisiin jatkokäsittelyä tai analyysia varten.

Tärkeä

Fabric-tapahtumavirtojen parannetut ominaisuudet ovat tällä hetkellä esiversiotilassa.

Muistiinpano

Tätä lähdettä ei tueta seuraavilla työtilakapasiteettisi alueilla: Länsi-YHDYSVALLAT3, Sveitsi, läntinen.

Edellytykset

Fabric Premium -työtilan käyttöoikeus Osallistuja-oikeudella tai korkeammilla käyttöoikeuksilla.
Pääsy Azure-tietokannan esiintymään MySQL:lle – Joustava palvelin.
MySQL-tietokantasi on oltava julkisesti käytettävissä, eikä se saa olla palomuurin takana tai suojattu näennäisverkossa.

Muistiinpano

Yhden tapahtumavirran lähteiden ja kohteiden enimmäismäärä on 11.

MySQL DB:n määrittäminen

Liitin tallentaa Debezium MySQL -liittimen avulla muutokset Azure Database for MySQL -tietokantaan. Sinun on määritettävä MySQL-käyttäjä, jolla on asianmukaiset oikeudet kaikkiin tietokantoihin, joista Messaging Connector voi siepata muutokset. Voit muodostaa yhteyden suoraan järjestelmänvalvojakäyttäjän avulla tietokantaan, johon tavallisesti liittyvät oikeudet ovat jo alla. tai voit luoda uuden käyttäjän alla annettujen ohjeiden mukaisesti.

Muistiinpano

Uutta käyttäjä- tai järjestelmänvalvojatiliä ja vastaavaa salasanaa käytetään tietokantaan yhdistämiseen myöhemmin Eventstreamin sisällä.

Luo komentokehotteessa mysql MySQL-käyttäjä:

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

Myönnä tarvittavat oikeudet käyttäjälle:

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

Viimeistele käyttäjän oikeudet:
```
mysql> FLUSH PRIVILEGES;
```

Jos haluat vahvistaa, onko käyttäjällä tai järjestelmänvalvojalla tarvittavat oikeudet, suorita alla oleva komento, niin vaiheen 2 tarvittavat oikeudet näytetään.

SHOW GRANTS FOR user;

Lisätietoja vaadittujen käyttöoikeuksien myöntämisestä käyttäjälle on mySQL:: Debezium-dokumentaation kohdassa Debezium-yhdistin.

Ota binlog käyttöön

Sinun on otettava binaarikirjaus käyttöön MySQL-replikointia varten. Binaarilokit tallentavat tapahtumapäivitykset replikointityökaluille muutosten levittämiseksi.

Valitse Azure-tietokannan MySQL-tilin Azure-portaalisivulla palvelinparametrit vasemman siirtymisruudun Asetuksissa .
Määritä Palvelimen parametrit -sivulla seuraavat ominaisuudet ja valitse sitten Tallenna.
- Valitse binlog_row_image täydet.
- Määritä binlog_expire_logs_seconds määrä sekunteina, jonka palvelu odottaa, ennen kuin binaarilokitiedosto puhdistetaan. Määritä arvo vastaamaan ympäristösi tarpeita, esimerkiksi 86400.

Azure MySQL DB (CDC) -tietokannan lisääminen lähteeksi

Luo uusi tapahtumavirta valitsemalla Fabric Real-Time Intelligence -kohdassa Eventstream . Varmista, että Parannetut ominaisuudet (esikatselu) -asetus on käytössä.
Valitse seuraavassa näytössä Lisää ulkoinen lähde.

Azure MySQL DB:n (CDC) määrittäminen ja siihen yhdistäminen

Valitse Valitse tietolähde -näytössä Azure MySQL DB (CDC) tietolähteeksi.
Valitse Yhdistä-näytön Yhteys-kohdassa Uusi yhteys luodaksesi pilviyhteyden.
Anna Seuraavat Azure MySQL DB:n yhteysasetukset ja yhteyden tunnistetiedot ja valitse sitten Yhdistä.
- Palvelin: Esimerkiksi Azure Database for MySQL -tietokannan palvelinosoite my-mysql-server.mysql.database.azure.com.
- Tietokanta: Tietokannan nimi, esimerkiksi my_database.
- Yhteyden nimi: Luodaan automaattisesti, tai voit antaa tälle yhteydelle uuden nimen.
- Käyttäjänimi ja salasana: Anna Azure Database for MySQL -tietokannan tunnistetiedot. Varmista, että annat palvelimen järjestelmänvalvojatilin tai luodun käyttäjätilin, jolle on myönnetty tarvittavat oikeudet.
Anna seuraavat tiedot Azure MySQL DB CDC -tietolähteen määrittämiseksi ja valitse sitten Seuraava.
- Taulukko:: Kirjoita luettelo taulukoiden nimistä pilkuilla eroteltuna. Kunkin taulukon nimen on noudatettava muotoa <database name>.<table name>, esimerkiksi my_database.users.
- Palvelintunnus: Anna yksilöllinen arvo kullekin palvelin- ja replikointiasiakkaalle MySQL-klusterissa. Oletusarvo on 1 000.
- Portti: Jätä oletusarvo muuttumatta.
Muistiinpano

Määritä kullekin lukijalle eri palvelintunnus. Jokaisella MySQL-tietokantaasiakkaalla binlogin lukemista varten tulisi olla yksilöivä tunnus, jota kutsutaan palvelintunnuksi. MySQL-palvelin käyttää tätä tunnusta verkkoyhteyden ja binlog-sijainnin ylläpitämiseen. Eri työt, jotka jakavat saman palvelintunnuksen, voivat johtaa lukemiseen väärästä binlog-sijainnista. Siksi on suositeltavaa määrittää eri palvelintunnus kullekin lukijalle.
Kun olet tarkistanut Azure MySQL DB CDC -lähteen yhteenvedon, viimeistele määritys valitsemalla Lisää .