Dela via


Lägg till MySQL Database CDC-källa i en händelseström (förhandsversion)

Kommentar

Den här artikeln innehåller referenser till termen SLAVE, en term som Microsoft inte längre använder. När termen tas bort från programvaran tar vi bort den från den här artikeln.

Den här artikeln visar hur du lägger till en Azure Database for MySQL Change Data Capture-källa i en händelseström. Med Azure MySQL Database Change Data Capture -källanslutningen (CDC) för Microsoft Fabric-händelseströmmar kan du samla in en ögonblicksbild av aktuella data i en Azure Database for MySQL-databas.

Du kan ange de tabeller som ska övervakas och händelseströmmen registrerar eventuella framtida ändringar på radnivå i tabellerna. När ändringarna har registrerats i händelseströmmen kan du bearbeta CDC-data i realtid och skicka dem till olika mål i Infrastrukturresurser för vidare bearbetning eller analys.

Viktigt!

Förbättrade funktioner i Fabric-händelseströmmar är för närvarande i förhandsversion.

Kommentar

Den här källan stöds inte i följande regioner i din arbetsytekapacitet: USA, västra 3, Schweiz, västra.

Förutsättningar

  • Åtkomst till Fabric Premium-arbetsytan med deltagarbehörighet eller högre behörigheter.
  • Åtkomst till en instans av Azure Database for MySQL – flexibel server.
  • MySQL-databasen måste vara offentligt tillgänglig och inte finnas bakom en brandvägg eller skyddas i ett virtuellt nätverk.

Kommentar

Det maximala antalet källor och mål för en händelseström är 11.

Konfigurera MySQL DB

Anslutningsappen använder Debezium MySQL-anslutningsappen för att samla in ändringar i din Azure Database for MySQL-databas. Du måste definiera en MySQL-användare med lämpliga behörigheter för alla databaser där Messaging Connector kan samla in ändringarna från. Du kan använda administratörsanvändaren direkt för att ansluta till databasen som normalt har rätt behörigheter redan enligt nedan. eller så kan du följa stegen nedan för att skapa en ny användare

Kommentar

Det nya användar- eller administratörskontot och motsvarande lösenord används för att ansluta till databasen senare i Eventstream.

  1. mysql I kommandotolken skapar du MySQL-användaren:

    mysql> CREATE USER 'user'@'%' IDENTIFIED BY 'password';
    
  2. Bevilja användaren de behörigheter som krävs:

    mysql> GRANT SELECT, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'user'@'%';
    
  3. Slutför användarens behörigheter:

    mysql> FLUSH PRIVILEGES;
    

Kontrollera om användaren eller administratören har de behörigheter som krävs genom att köra kommandot nedan och sedan ska de behörigheter som krävs i steg 2 ovan visas.

SHOW GRANTS FOR user;

Mer information om hur du beviljar nödvändiga behörigheter till användaren finns i Debezium Connector for MySQL :: Debezium Documentation.

Aktivera binlog

Du måste aktivera binär loggning för MySQL-replikering. Binärloggarna registrerar transaktionsuppdateringar för replikeringsverktyg för att sprida ändringar.

  1. På sidan Azure-portalen för ditt Azure Database for MySQL-konto väljer du Serverparametrar under Inställningar i det vänstra navigeringsfältet.

  2. På sidan Serverparametrar konfigurerar du följande egenskaper och väljer sedan Spara.

    • För binlog_row_image väljer du fullständig.

    • För binlog_expire_logs_seconds anger du hur många sekunder tjänsten väntar innan den binära loggfilen rensas. Ange värdet för att matcha behoven i din miljö, till exempel 86400.

    En skärmbild av binloginställningarna för replikering under Serverparametrar.

Lägga till Azure MySQL DB (CDC) som källa

  1. I Fabric Realtidsinformation väljer du Eventstream för att skapa en ny händelseström. Kontrollera att alternativet Förbättrade funktioner (förhandsversion) är aktiverat.

    En skärmbild av hur du skapar en ny händelseström.

  2. På nästa skärm väljer du Lägg till extern källa.

    En skärmbild av att välja Lägg till extern källa.

Konfigurera och ansluta till Azure MySQL DB (CDC)

  1. På skärmen Välj en datakälla väljer du Azure MySQL DB (CDC) som datakälla.

    En skärmbild av att välja Azure MySQL DB (CDC).

  2. På skärmen Anslut går du till Anslutning och väljer Ny anslutning för att skapa en molnanslutning.

  3. Ange följande anslutningsinställningar och autentiseringsuppgifter för anslutning för Azure MySQL DB och välj sedan Anslut.

    • Server: Serveradressen för din Azure Database for MySQL-databas, till exempel my-mysql-server.mysql.database.azure.com.
    • Databas: Databasnamnet, till exempel my_database.
    • Anslutningsnamn: Genereras automatiskt, eller så kan du ange ett nytt namn för den här anslutningen.
    • Användarnamn och lösenord: Ange autentiseringsuppgifterna för din Azure Database for MySQL-databas. Kontrollera att du anger serveradministratörskontot eller användarkontot som skapats med nödvändiga behörigheter.

    En skärmbild av anslutningsinställningarna för Azure MySQL DB (CDC).

  4. Ange följande information för att konfigurera Azure MySQL DB CDC-datakällan och välj sedan Nästa.

    • Tabell(er): Ange en lista med tabellnamn avgränsade med kommatecken. Varje tabellnamn måste följa formatet <database name>.<table name>, till exempel my_database.users.
    • Server-ID: Ange ett unikt värde för varje server och replikeringsklient i MySQL-klustret. Standardvärdet är 1000.
    • Port: Lämna standardvärdet oförändrat.

    En skärmbild av att välja Tabeller, Server-ID och Port för Azure MySQL DB-anslutningen (CDC).

    Kommentar

    Ange ett annat server-ID för varje läsare. Varje MySQL-databasklient för att läsa binlog bör ha ett unikt ID, kallat Server-ID. MySQL Server använder det här ID:t för att underhålla nätverksanslutningen och binlogpositionen. Olika jobb som delar samma server-ID kan resultera i läsning från fel binlogposition. Därför rekommenderar vi att du anger ett annat server-ID för varje läsare.

  5. När du har granskat sammanfattningen för Azure MySQL DB CDC-källan väljer du Lägg till för att slutföra konfigurationen.

Du ser azure MySQL DB-källan (CDC) som lagts till i din händelseström i redigeringsläge.

En skärmbild av den tillagda AZURE MySQL DB CDC-källan i redigeringsläge med knappen Publicera markerad.

Välj Publicera för att publicera ändringarna och börja strömma Azure MySQL DB CDC-data till händelseströmmen.

En skärmbild av den publicerade händelseströmmen med Azure MySQL DB CDC-källan i Live View.

Andra anslutningsappar: