Dodawanie źródła cdC bazy danych MySQL do strumienia zdarzeń (wersja zapoznawcza)

Uwaga

Ten artykuł zawiera odwołania do terminu SLAVE, termin, którego firma Microsoft już nie używa. Po usunięciu terminu z oprogramowania usuniemy go z tego artykułu.

W tym artykule pokazano, jak dodać źródło przechwytywania zmian danych usługi Azure Database for MySQL do strumienia zdarzeń. Łącznik źródła przechwytywania zmian danych (CDC) usługi Azure MySQL dla strumieni zdarzeń usługi Microsoft Fabric umożliwia przechwycenie migawki bieżących danych w bazie danych usługi Azure Database for MySQL.

Możesz określić tabele do monitorowania, a strumień zdarzeń rejestruje wszelkie przyszłe zmiany na poziomie wiersza w tabelach. Po przechwyceniu zmian w strumieniu zdarzeń można przetwarzać te dane CDC w czasie rzeczywistym i wysyłać je do różnych miejsc docelowych w sieci szkieletowej w celu dalszego przetwarzania lub analizy.

Ważne

Ulepszone możliwości strumieni zdarzeń sieci Szkieletowej są obecnie dostępne w wersji zapoznawczej.

Uwaga

To źródło nie jest obsługiwane w następujących regionach pojemności obszaru roboczego: Zachodnie stany USA3, Szwajcaria Zachodnia.

Wymagania wstępne

• Dostęp do obszaru roboczego Sieć szkieletowa Premium z uprawnieniami współautora lub wyższymi uprawnieniami.
• Dostęp do wystąpienia usługi Azure Database for MySQL — serwer elastyczny.
• Baza danych MySQL musi być publicznie dostępna i nie musi znajdować się za zaporą lub być zabezpieczona w sieci wirtualnej.

Uwaga

Maksymalna liczba źródeł i miejsc docelowych dla jednego strumienia zdarzeń wynosi 11.

Konfigurowanie bazy danych MySQL

Łącznik używa łącznika Debezium MySQL do przechwytywania zmian w bazie danych usługi Azure Database for MySQL. Należy zdefiniować użytkownika mySQL z odpowiednimi uprawnieniami we wszystkich bazach danych, z których łącznik obsługi komunikatów może przechwytywać zmiany. Możesz bezpośrednio użyć użytkownika administratora, aby nawiązać połączenie z bazą danych, która zwykle ma odpowiednie uprawnienia już poniżej. możesz też wykonać poniższe kroki, aby utworzyć nowego użytkownika

Uwaga

Nowe konto użytkownika lub administratora i odpowiednie hasło będą używane do nawiązywania połączenia z bazą danych później wewnątrz strumienia zdarzeń.

1. mysql W wierszu polecenia utwórz użytkownika mySQL:

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

2. Przyznaj użytkownikowi wymagane uprawnienia:

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

3. Finalizuj uprawnienia użytkownika:

   mysql> FLUSH PRIVILEGES;
   

Aby sprawdzić, czy użytkownik lub administrator ma przyznane wymagane uprawnienia, uruchom poniższe polecenie, a następnie należy wyświetlić wymagane uprawnienia w kroku 2 powyżej.

SHOW GRANTS FOR user;

Aby uzyskać więcej informacji na temat udzielania wymaganych uprawnień użytkownikowi, zobacz Debezium connector for MySQL :: Debezium Documentation (Łącznik debezium dla bazy danych MySQL:: Dokumentacja rozwiązania Debezium).

Włączanie dziennika binlog

Należy włączyć rejestrowanie binarne na potrzeby replikacji bazy danych MySQL. Dzienniki binarne rejestrują aktualizacje transakcji dla narzędzi replikacji w celu propagowania zmian.

1. Na stronie witryny Azure Portal dla konta usługi Azure Database for MySQL wybierz pozycję Parametry serwera w obszarze Ustawienia w obszarze nawigacji po lewej stronie.

2. Na stronie Parametry serwera skonfiguruj następujące właściwości, a następnie wybierz pozycję Zapisz.

   • W przypadku binlog_row_image wybierz pozycję pełne.

   • W przypadku binlog_expire_logs_seconds ustaw liczbę sekund oczekiwania usługi przed przeczyszczeniem pliku dziennika binarnego. Ustaw wartość tak, aby odpowiadała potrzebom środowiska, na przykład 86400.

   

Dodawanie usługi Azure MySQL DB (CDC) jako źródła

1. W obszarze Analiza w czasie rzeczywistym w sieci szkieletowej wybierz pozycję Eventstream , aby utworzyć nowy strumień zdarzeń. Upewnij się, że opcja Rozszerzone możliwości (wersja zapoznawcza) jest włączona.

   

2. Na następnym ekranie wybierz pozycję Dodaj źródło zewnętrzne.

   

Konfigurowanie i nawiązywanie połączenia z usługą Azure MySQL DB (CDC)

1. Na ekranie Wybieranie źródła danych wybierz pozycję Azure MySQL DB (CDC) jako źródło danych.

   

2. Na ekranie Połącz w obszarze Połączenie wybierz pozycję Nowe połączenie, aby utworzyć połączenie w chmurze.

3. Wprowadź następujące ustawienia połączenia i poświadczenia połączenia dla bazy danych Azure MySQL, a następnie wybierz pozycję Połącz.

   • Serwer: adres serwera bazy danych usługi Azure Database for MySQL, na przykład my-mysql-server.mysql.database.azure.com.
   • Baza danych: nazwa bazy danych, na przykład my_database.
   • Nazwa połączenia: wygenerowana automatycznie lub możesz wprowadzić nową nazwę dla tego połączenia.
   • Nazwa użytkownika i hasło: wprowadź poświadczenia dla bazy danych usługi Azure Database for MySQL. Upewnij się, że wprowadzono konto administratora serwera lub konto użytkownika utworzone z przyznanymi wymaganymi uprawnieniami.

   

4. Wprowadź następujące informacje, aby skonfigurować źródło danych CDC usługi Azure MySQL DB, a następnie wybierz przycisk Dalej.

   • Tabele: wprowadź listę nazw tabel rozdzielonych przecinkami. Każda nazwa tabeli musi być zgodna z formatem <database name>.<table name>, na przykład my_database.users.
   • Identyfikator serwera: wprowadź unikatową wartość dla każdego serwera i klienta replikacji w klastrze MySQL. Wartość domyślna to 1000.
   • Port: pozostaw wartość domyślną bez zmian.

   

   Uwaga

   Ustaw inny identyfikator serwera dla każdego czytnika. Każdy klient bazy danych MySQL do odczytu dziennika binlog powinien mieć unikatowy identyfikator o nazwie Identyfikator serwera. Serwer MySQL używa tego identyfikatora do obsługi połączenia sieciowego i pozycji dziennika binlog. Różne zadania współużytkowania tego samego identyfikatora serwera mogą spowodować odczytanie nieprawidłowej pozycji dziennika binlogu. W związku z tym zaleca się ustawienie innego identyfikatora serwera dla każdego czytelnika.

5. Po przejrzeniu podsumowania źródła cdC usługi Azure MySQL DB wybierz pozycję Dodaj , aby ukończyć konfigurację.

Zobaczysz źródło usługi Azure MySQL DB (CDC) dodane do strumienia zdarzeń w trybie edycji.

Wybierz pozycję Publikuj, aby opublikować zmiany i rozpocząć przesyłanie strumieniowe danych CDC usługi Azure MySQL DB do strumienia zdarzeń.

Powiązana zawartość

Inne łączniki:

• Strumienie danych Amazon Kinesis
• Azure Cosmos DB
• Azure Event Hubs
• Azure IoT Hub
• Przechwytywanie zmian danych w usłudze Azure SQL Database (CDC)
• Confluent Kafka
• Niestandardowy punkt końcowy
• Google Cloud Pub/Sub
• CdC bazy danych PostgreSQL
• Dane przykładowe
• Zdarzenia usługi Azure Blob Storage
• Zdarzenie obszaru roboczego sieci szkieletowej