Aggiungere l'origine CDC del database MySQL a un eventstream (anteprima)

Articolo
10/15/2024

Nota

Questo articolo contiene riferimenti al termine SLAVE, che Microsoft non usa più. Quando il termine verrà rimosso dal software, verrà rimosso anche dall'articolo.

Questo articolo mostra come aggiungere l'origine Change Data Capture di Database di Azure per MySQL a un eventstream. Il connettore dell'origine Change Data Capture (CDC) di Database MySQL di Azure per i flussi di eventi di Microsoft Fabric consente di acquisire uno snapshot dei dati correnti in un database nel Database di Azure per MySQL.

È possibile specificare le tabelle da monitorare e il flusso di eventi registra eventuali modifiche future a livello di riga nelle tabelle. Dopo aver acquisito le modifiche nell’eventstream, è possibile elaborare questi dati CDC in tempo reale e inviarli a destinazioni diverse in Fabric per un'ulteriore elaborazione o analisi.

Importante

Le funzionalità avanzate dei flussi di eventi di Fabric sono attualmente in anteprima.

Nota

Questa sorgente non è supportata nelle seguenti regioni della capacità dell'area di lavoro: Stati Uniti occidentali 3, Svizzera occidentale.

Prerequisiti

Accesso a un’area di lavoro premium con autorizzazioni da Collaboratore o superiori.
Accesso a un'istanza di Database di Azure per MySQL - Server Flessibile.
Il database MySQL deve essere accessibile pubblicamente e non essere protetto da un firewall o in una rete virtuale.

Nota

Il numero massimo di fonti e destinazioni per un flusso di eventi è 11.

Configurare DB MySQL

Il connettore usa il connettore Debezium MySQL per acquisire le modifiche nel Database di Azure per MySQL. È necessario definire un utente MySQL con privilegi appropriati per tutti i database da cui Messaging Connector può acquisire le modifiche. È possibile usare direttamente l'utente amministratore per connettersi al database che normalmente dispone dei privilegi appropriati già come indicato di seguito. oppure è possibile seguire la procedura seguente per creare un nuovo utente

Nota

Il nuovo account utente o amministratore e la password corrispondente verranno usati per connettersi al database in un secondo momento all'interno di Eventstream.

Al mysql prompt dei comandi creare l'utente MySQL:

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

Concedere i privilegi necessari all'utente:

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

Finalizzare le autorizzazioni dell'utente:
```
mysql> FLUSH PRIVILEGES;
```

Per verificare se all'utente o all'amministratore sono concessi i privilegi necessari, eseguire il comando seguente che permette di visualizzare i privilegi necessari nel passaggio 2.

SHOW GRANTS FOR user;

Per altre informazioni sulla concessione delle autorizzazioni necessarie all'utente, vedere Connettore Debezium per MySQL: Documentazione Debezium.

Abilitare il binlog

È necessario abilitare la registrazione binaria per la replica MySQL. I log binari registrano gli aggiornamenti dei record per gli strumenti di replica per propagare le modifiche.

Nel portale di Azure, nella pagina del server del Database di Azure per MySQL, in Impostazioni selezionare Parametri del server a sinistra.
Nella pagina Parametri server, configurare le seguenti impostazioni, quindi selezionare Salva.
- Per binlog_row_image, selezionare completo.
- Per binlog_expire_logs_seconds, impostare il numero di secondi di attesa del servizio prima che il file di log binario venga rimosso definitivamente. Impostare il valore in base alle esigenze dell'ambiente, ad esempio 86400.

Aggiungere Database MySQL di Azure (CDC) come origine

Nell’Intelligence in tempo reale di Fabric selezionare Eventstream per creare un nuovo flusso di eventi. Assicurarsi che l'opzione Funzionalità Avanzate (anteprima) sia abilitata.
Nella schermata successiva selezionare Aggiungi origine esterna.

Configurare e connettersi al database MySQL di Azure (CDC)

Nella schermata Selezionare un'origine dati selezionare Database MySQL di Azure (CDC) come origine dati.
Nella schermata Connetti selezionare Nuova connessione in Connessione per creare una connessione cloud.
Immettere le Impostazioni di connessione seguenti e le credenziali di connessione per il database MySQL di Azure e quindi selezionare Connetti.
- Server: indirizzo del server del database Database di Azure per MySQL, ad esempio my-mysql-server.mysql.database.azure.com.
- Database: nome del database, ad esempio mio_database.
- Nome connessione: generato automaticamente oppure è possibile immettere un nuovo nome per questa connessione.
- Nome utente e Password: immettere le credenziali per il Database di Azure per MySQL. Assicurarsi di immettere l'account amministratore del server o l'account utente creato con privilegi necessari concessi.
Immettere le informazioni seguenti per configurare l'origine dati CDC del database MySQL di Azure e quindi selezionare Avanti.
- Tabella/e: immettere un elenco di nomi tabella separati da virgole. Ogni nome di tabella deve seguire il formato <database name>.<table name>, ad esempio my_database.users.
- ID server: immettere un valore univoco per ogni server e client di replica nel cluster MySQL. Il valore predefinito è 1000.
- Porta: lasciare invariato il valore predefinito.
Nota

Impostare un ID server diverso per ogni lettore. Ogni client di database MySQL per la lettura di binlog deve avere un ID univoco, denominato ID server. MySQL Server usa questo ID per mantenere la connessione di rete e la posizione binlog. Diversi processi che condividono lo stesso ID server possono causare la lettura dalla posizione binlog errata. È quindi consigliabile impostare un ID server diverso per ogni lettore.
Dopo aver esaminato il riepilogo per l'origine CDC del database MySQL di Azure, selezionare Aggiungi per completare la configurazione.