MySQL Database CDC-bron toevoegen aan een eventstream (preview)

Artikel
06/09/2024

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.

Belangrijk

Verbeterde mogelijkheden van Fabric-gebeurtenisstromen zijn momenteel beschikbaar als preview-versie.

Notitie

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

Vereisten

Toegang tot de Fabric Premium-werkruimte 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.

Notitie

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

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.

Maak bij de mysql opdrachtprompt de MySQL-gebruiker:

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

Verdeel de vereiste bevoegdheden aan de gebruiker:

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

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 voor meer informatie over het verlenen van de vereiste machtigingen aan de gebruiker : Debezium-documentatie.

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.

Selecteer op de azure-portalpagina voor uw Azure Database for MySQL-account serverparameters onder Instellingen in het linkernavigatievenster.
Configureer op de pagina Serverparameters de volgende eigenschappen en selecteer Opslaan.
- Selecteer voor binlog_row_image de optie Volledig.
- Stel voor binlog_expire_logs_seconds het aantal seconden in dat de service wacht voordat het binaire logboekbestand wordt opgeschoond. Stel de waarde in op basis van de behoeften van uw omgeving, bijvoorbeeld 86400.

Azure MySQL DB (CDC) toevoegen als bron

Selecteer eventstream in Fabric Real-Time Intelligence om een nieuwe eventstream te maken. Zorg ervoor dat de optie Verbeterde mogelijkheden (preview) is ingeschakeld.
Selecteer Externe bron toevoegen in het volgende scherm.

Configureren en verbinding maken met Azure MySQL DB (CDC)

Selecteer in het scherm Een gegevensbron selecteren Azure MySQL DB (CDC) als de gegevensbron.
Selecteer in het scherm Verbinding maken onder Verbinding de optie Nieuwe verbinding om een cloudverbinding te maken.
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.
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.
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.
Nadat u de samenvatting voor de CDC-bron van Azure MySQL DB hebt bekeken, selecteert u Toevoegen om de configuratie te voltooien.