MySQL-tietokannan CDC-lähteen lisääminen tapahtumavirtaan
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.
Muistiinpano
Tätä lähdettä ei tueta seuraavilla työtilakapasiteettisi alueilla: Länsi-YHDYSVALLAT3, Sveitsi, läntinen.
Edellytykset
- Työtilan käyttöoikeus Fabric-kapasiteetin käyttöoikeustilassa (tai) kokeiluversion käyttöoikeustilassa 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.
- Jos sinulla ei ole tapahtumastreamia, luo tapahtumavirta.
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
mysqlMySQL-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:n Debezium-liittimen kohdassa Debezium-dokumentaatio.
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 Database for MySQL -tilisi Azure-portaali-sivulla palvelimen parametrit vasemman reunan 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
Jos et ole vielä lisännyt lähdettä tapahtumavirtaan, valitse Käytä ulkoista lähderuutua .
Jos lisäät lähteen jo julkaistuun tapahtumavirtaan, vaihda Muokkaa-tilaan , valitse valintanauhasta Lisää lähde ja valitse sitten Ulkoiset lähteet.
Etsi Ja valitse Valitse tietolähde -sivulla Yhdistä MySQL DB (CDC) -ruudussa.
Azure MySQL DB:n (CDC) määrittäminen ja siihen yhdistäminen
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.
Voit muokata lähteen nimeä myös valitsemalla Lähteen nimi -kynäpainikkeen oikealla puolella Streamin tiedot -osassa.
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 Tarkista + yhdistä -sivulla tarkistanut Azure MySQL DB CDC -lähteen yhteenvedon, viimeistele määritys valitsemalla Lisää.
Muistiinpano
Yhden tapahtumavirran lähteiden ja kohteiden enimmäismäärä on 11.
Näytä päivitetty tapahtumavirta
Näet Azure MySQL DB (CDC) -lähteen lisättynä tapahtumavirtaasi Muokkaa-tilassa.
Julkaise muutokset valitsemalla Julkaise ja aloita Azure MySQL DB CDC -tietojen suoratoisto tapahtumavirtaan.
Liittyvä sisältö
Muut liittimet: