Jaa


MySQL-tietokannan CDC:n lisääminen lähteeksi reaaliaikaiseen keskittimeen (esikatselu)

Tässä artikkelissa kerrotaan, miten voit lisätä MySQL-tietokannan muutoksen tietokaappauksen (CDC) tapahtumalähteeksi Fabric Real-Time Hubissa.

Azure MySQL -tietokannan Change Data Capture (CDC) -liittimen avulla voit siepata tilannevedoksen nykyisistä tiedoista Azure MySQL -tietokannassa. Määrität taulukot, joita valvotaan, ja saat ilmoituksen, kun jokin seuraava rivitason muutos taulukoihin muuttuu. Kun muutokset on siepattu tietovirtaan, voit käsitellä nämä CDC-tiedot reaaliaikaisesti ja lähettää ne Fabricissa eri kohteisiin jatkokäsittelyä tai analyysia varten.

Muistiinpano

Reaaliaikainen keskus on tällä hetkellä esikatselussa.

Edellytykset

  • Hanki Fabric Premium -työtilan käyttöoikeus Osallistuja-oikeudella tai yllä-oikeuksilla.
  • Luotu Azure-tietokannan esiintymä MySQL:lle – Joustava palvelin.

MySQL-tietokannan määrittäminen

Azure MySQL -tietokantayhdistin tallentaa Debezium MySQL -liittimellä muutokset MySQL-tietokantaan. Sinun on määritettävä MySQL-käyttäjälle käyttöoikeudet kaikkiin tietokantoihin, joita liitin valvoo. Katso vaiheittaiset ohjeet artikkelista MySQL DB:n määrittäminen.

Ota binlog käyttöön

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

  1. Siirry Azure-portaali Azure MySQL -tietokantaan.

  2. Valitse vasemmasta siirtymisvalikosta Palvelinparametrit.

  3. Määritä MySQL-palvelimeen seuraavat ominaisuudet.

    • binlog_row_image: Määritä arvoksi täysi.
    • binlog_expire_logs_seconds: Automaattisen binlog-tiedoston poistamisen sekuntien määrä. Määritä arvo vastaamaan ympäristösi tarpeita. Esimerkiksi 86400.

    Näyttökuvassa näkyy Azure MySQL -tietokannan palvelinparametrisivu.

Tapahtumien hakeminen Azure MySQL -tietokannasta (CDC)

Voit saada tapahtumia Azure MySQL -tietokannan CDC:stä reaaliaikaiseen keskittimeen jollakin seuraavista tavoista:

Käynnistä Lisää lähde -käyttökokemus

  1. Kirjaudu sisään Microsoft Fabriciin.

  2. Valitse reaaliaikainen keskus vasemmasta siirtymispalkista.

  3. Valitse Reaaliaikainen keskus -sivulla + Lisää lähde sivun oikeasta yläkulmasta.

    Näyttökuvassa näytetään, miten voit käynnistää Reaaliaikaisen keskittimen Microsoft Fabricissa.

Lue ohjeet Azure MySQL -tietokannan CDC:n lisäämisohjeista lähdeosana .

Microsoftin lähteet -sivu

  1. Valitse Reaaliaikainen keskitys -kohdassa Microsoft-lähteet.

  2. Valitse avattavasta Lähde-luettelosta Azure MySQL DB (CDC).

  3. Valitse Tilaus-kohdassa Azure-tilaus, jossa on resurssiryhmä Azure MySQL -tietokantatilisi kanssa.

  4. Valitse Resurssiryhmä-kohdassa resurssiryhmä, jolla on tietokanta.

  5. Valitse Alue-kohdassa sijainti, jossa tietokanta sijaitsee.

  6. Siirrä nyt hiiri sen Azure MySQL DB CDC -lähteen nimen päälle, jonka haluat yhdistää reaaliaikaiseen keskittimeen tietokantojen luettelossa, ja valitse Yhdistä-painike tai valitse ... (kolme pistettä) ja valitse sitten Yhdistä-painike.

    Näyttökuvassa näkyy Microsoftin lähteiden sivu, jolla on suodattimia Azure MySQL CDC:n ja Yhdistä-painikkeen näyttämiseksi.

    Voit määrittää yhteyden tiedot käyttämällä Azure MySQL DB CDC:n lähdeosan vaiheita. Ohita ensimmäinen vaihe, kun valitset Azure MySQL DB CDC:n lähdetyypiksi ohjatussa lisäämistoiminnossa.

Azure MySQL -tietokannan CDC:n lisääminen lähteeksi

  1. Valitse Valitse tietolähde -näytössä MySQL DB (CDC).

    Näyttökuvassa näkyy Valitse tietolähde -sivu, jossa on valittuna Azure MySQL DB (CDC).

  2. Valitse Yhdistä-sivulla Siirry resurssiin, jotta voit siirtyä Azure PostgreSQL -tietokantaan. Kirjoita palvelimen nimi muistiin Yleiskatsaus-sivulla . Se on seuraavassa muodossa: mysqlserver.mysql.database.azure.com.

    Näyttökuvassa näkyy Yhdistä sivu ja Siirry resurssiin -linkki korostettuna.

  3. Valitse Yhdistä-sivulla Uusi yhteys.

    Näyttökuvassa näkyy ohjatun lähteen lisäämisen sivu, jossa on korostettuna **Uusi yhteys** -linkki.

  4. Tee Yhteysasetukset-osiossa seuraavat vaiheet:

    1. Anna Palvelimelle Azure MySQL -palvelimesi URI.

    2. Kirjoita Tietokanta-kohtaan tietokantasi nimi.

      Näyttökuvassa näkyy Yhteysasetukset-osio.

  5. Tee Yhteyden tunnistetiedot -osiossa seuraavat vaiheet:

    1. Valitse Yhteys-kohdassa, onko MySQL-tietokantaan aiemmin luotu yhteys. Jos näin ei ole, säilytä oletusarvo: Luo uusi yhteys.

    2. Valitse todennuslajiksi Perus. Tällä hetkellä vain perustodentamista tuetaan.

    3. Anna käyttäjänimen ja salasanan arvot.

    4. Määritä, haluatko käyttää salattua yhteyttä.

    5. Valitse Yhdistä.

      Näyttökuvassa näkyy Yhteyden tunnistetiedot -osio.

  6. Palaa Yhdistä-sivulle ja toimi seuraavasti:

    1. Anna taulukon nimi.
    2. Anna palvelimen tunnus.
    3. Anna portin numero tai säilytä oletusarvo.
  7. Voit tehdä seuraavat toimet oikealla olevan Streamin tiedot -osiossa:

    1. Valitse Fabric-työtila , johon haluat tallentaa tämän yhteyden ja ohjatun toiminnon luoma tapahtumavirran.

    2. Anna tapahtumavirran nimi.

    3. Tietovirran nimi reaaliaikaisessa keskuksessa luodaan automaattisesti puolestasi.

      Näyttökuvassa näkyy Yhdistä sivu, jossa on kaikki määritetyt pakolliset kentät.

  8. Valitse seuraavaksi sivun alareunasta.

  9. Tarkista ja luo -kohdassa asetukset ja valitse Luo lähde.

    Näyttökuvassa näkyy Tarkista ja luo -sivu, jossa on kaikki määritetyt pakolliset kentät.

Tietovirran tietojen tarkasteleminen

  1. Jos valitset Tarkista ja luo -sivulla Avaa tapahtumavirta, ohjattu toiminto avaa sen luoman tapahtumavirran sinulle valitun Azure MySQL DB CDC:n lähteeksi. Sulje ohjattu toiminto valitsemalla Sulje tai X* sivun oikeasta yläkulmasta.

    Näyttökuvassa näkyy Tarkista ja luo sivu onnistuneen lähteen luomisen jälkeen.

  2. Valitse reaaliaikaisessa keskuksessa Kaikki tietovirrat. Jos haluat nähdä uuden tietovirran, päivitä Kaikki tietovirrat -sivu. Katso yksityiskohtaiset ohjeet artikkelista Tietovirtojen tietojen tarkasteleminen Fabric Real-Time Hubissa.

Lisätietoja tietovirtojen kulutuksesta on seuraavissa artikkeleissa: