Delen via

MySQL Database CDC-bron toevoegen aan een eventstream

  • Artikel

Notitie

Dit artikel bevat verwijzingen naar de term SLAVE, een term die Microsoft niet meer gebruikt. Zodra de term uit de software wordt verwijderd, verwijderen we deze uit dit artikel.

In dit artikel leest u hoe u een Azure Database for MySQL Change Data Capture-bron toevoegt aan een eventstream. Met de Bronconnector azure MySQL Database Change Data Capture (CDC) voor Microsoft Fabric-gebeurtenisstromen kunt u een momentopname van de huidige gegevens vastleggen in een Azure Database for MySQL-database.

U kunt de tabellen opgeven die moeten worden bewaakt en de eventstream registreert toekomstige wijzigingen op rijniveau in de tabellen. Zodra de wijzigingen zijn vastgelegd in de eventstream, kunt u deze CDC-gegevens in realtime verwerken en verzenden naar verschillende bestemmingen in Fabric voor verdere verwerking of analyse.

Notitie

Deze bron wordt niet ondersteund in de volgende regio's van uw werkruimtecapaciteit: VS - west 3, Zwitserland - west.

Vereisten

  • Toegang tot een werkruimte in de licentiemodus voor infrastructuurcapaciteit (of) de modus Voor proeflicenties met inzender- of hogere machtigingen.
  • Toegang tot een exemplaar van Azure Database for MySQL - Flexible Server.
  • Uw MySQL-database moet openbaar toegankelijk zijn en zich niet achter een firewall bevinden of zijn beveiligd in een virtueel netwerk.
  • Als u geen eventstream hebt, maakt u een eventstream.

MySQL-database instellen

De connector maakt gebruik van de Debezium MySQL-connector om wijzigingen vast te leggen in uw Azure Database for MySQL-database. U moet een MySQL-gebruiker met de juiste bevoegdheden definiëren voor alle databases waaruit de Berichtenconnector de wijzigingen kan vastleggen. U kunt de gebruiker van de beheerder rechtstreeks gebruiken om verbinding te maken met de database die normaal gesproken de juiste bevoegdheden al heeft, zoals hieronder. of u kunt de onderstaande stappen volgen om een nieuwe gebruiker te maken

Notitie

Het nieuwe gebruikers- of beheerdersaccount en het bijbehorende wachtwoord worden gebruikt om later in Eventstream verbinding te maken met de database.

  1. Maak bij de mysql opdrachtprompt de MySQL-gebruiker:

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

  2. Verdeel de vereiste bevoegdheden aan de gebruiker:

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

  3. Voltooi de machtigingen van de gebruiker:

    mysql> FLUSH PRIVILEGES;

Als u wilt controleren of de gebruiker of beheerder de vereiste bevoegdheden heeft verleend, voert u de onderstaande opdracht uit en moet de vereiste bevoegdheden in stap 2 hierboven worden weergegeven.

SHOW GRANTS FOR user;

Zie de Debezium-connector voor MySQL: Debezium-documentatie voor meer informatie over het verlenen van de vereiste machtigingen aan de gebruiker.

Het binlog inschakelen

U moet binaire logboekregistratie inschakelen voor MySQL-replicatie. De binaire logboeken registreren transactie-updates voor replicatiehulpprogramma's om wijzigingen door te geven.

  1. Selecteer op de azure-portalpagina voor uw Azure Database for MySQL-account serverparameters onder Instellingen in het linkernavigatievenster.

  2. Configureer op de pagina Serverparameters de volgende eigenschappen en selecteer Opslaan.

    Een schermopname van de binlog-instellingen voor replicatie onder Serverparameters.

Azure MySQL DB (CDC) toevoegen als bron

Als u nog geen bron aan uw eventstream hebt toegevoegd, selecteert u De tegel Externe bron gebruiken.

Schermopname van de selectie van de tegel Externe bron gebruiken.

Als u de bron toevoegt aan een al gepubliceerde gebeurtenisstroom, schakelt u over naar de bewerkingsmodus, selecteert u Bron toevoegen op het lint en selecteert u Vervolgens Externe bronnen.

Schermopname van de selectie van het menu Bron toevoegen aan externe bronnen.  

Zoek en selecteer verbinding maken op de tegel MySQL DB (CDC) op de pagina Een gegevensbron selecteren.

Schermopname van de selectie van MySQL DB (CDC) als brontype in de wizard Gebeurtenissen ophalen.

Configureren en verbinding maken met Azure MySQL DB (CDC)

  1. Selecteer in het scherm Verbinding maken onder Verbinding de optie Nieuwe verbinding om een cloudverbinding te maken.

    Schermopname van de pagina Verbinding maken.

  2. Voer de volgende verbindingsinstellingen en verbindingsreferenties in voor uw Azure MySQL-database en selecteer Vervolgens Verbinding maken.

    • Server: het serveradres van uw Azure Database for MySQL-database, bijvoorbeeld my-mysql-server.mysql.database.azure.com.

    • Database: de naam van de database, bijvoorbeeld my_database.

    • Verbindingsnaam: automatisch gegenereerd of u kunt een nieuwe naam voor deze verbinding invoeren.

    • Gebruikersnaam en wachtwoord: voer de referenties in voor uw Azure Database for MySQL-database. Zorg ervoor dat u het beheerdersaccount van de server of het gebruikersaccount invoert dat is gemaakt met de vereiste bevoegdheden die zijn verleend.

      Een schermopname van de verbindingsinstellingen voor Azure MySQL DB (CDC).

  3. Voer de volgende informatie in om de CDC-gegevensbron van Azure MySQL DB te configureren en selecteer vervolgens Volgende.

    • Tabel(en): Voer een lijst met tabelnamen in, gescheiden door komma's. Elke tabelnaam moet de notatie <database name>.<table name>volgen, bijvoorbeeld my_database.users.

    • Server-id: Voer een unieke waarde in voor elke server en replicatieclient in het MySQL-cluster. De standaardwaarde is 1000.

    • Poort: laat de standaardwaarde ongewijzigd.

      Een schermopname van het selecteren van tabellen, server-id en poort voor de Azure MySQL DB-verbinding (CDC).

    U kunt ook de bronnaam bewerken door de knop Potlood voor bronnaam te selecteren in de sectie Details van stream aan de rechterkant.

    Notitie

    Stel een andere server-id in voor elke lezer. Elke MySQL-databaseclient voor het lezen van binlog moet een unieke id hebben, server-id genoemd. MySQL Server gebruikt deze id om de netwerkverbinding en de binlog-positie te behouden. Verschillende taken die dezelfde server-id delen, kunnen leiden tot het lezen van de verkeerde binlogpositie. Daarom is het raadzaam om voor elke lezer een andere server-id in te stellen.

  4. Selecteer op de pagina Controleren en verbinden, nadat u de samenvatting voor de CDC-bron van Azure MySQL DB hebt bekeken, toevoegen om de configuratie te voltooien.

    Schermopname van de pagina Controleren en verbinden met de knop Toevoegen geselecteerd.

Notitie

Het maximum aantal bronnen en bestemmingen voor één eventstream is 11.

Bijgewerkte eventstream weergeven

  1. U ziet dat de Azure MySQL DB-bron (CDC) is toegevoegd aan uw eventstream in de bewerkingsmodus.

    Een schermopname van de toegevoegde Azure MySQL DB CDC-bron in de bewerkingsmodus met de knop Publiceren gemarkeerd.

  2. Selecteer Publiceren om de wijzigingen te publiceren en te beginnen met het streamen van CDC-gegevens van Azure MySQL DB naar de eventstream.

    Een schermopname van de toegevoegde Azure MySQL DB CDC-bron in de livemodus.

Gerelateerde inhoud

Andere connectors: