Přidání zdroje CDC databáze MySQL do eventstreamu
Poznámka:
Tento článek obsahuje odkazy na termín SLAVE
, termín, který už Microsoft nepoužívá. Když se termín odebere ze softwaru, odebereme ho z tohoto článku.
V tomto článku se dozvíte, jak do eventstreamu přidat zdroj Change Data Capture služby Azure Database for MySQL. Zdrojový konektor Azure MySQL Database Change Data Capture (CDC) pro streamy událostí Microsoft Fabric umožňuje zachytit snímek aktuálních dat v databázi Azure Database for MySQL.
Můžete určit tabulky, které se mají monitorovat, a eventstream zaznamenává všechny budoucí změny na úrovni řádků v tabulkách. Jakmile se změny zachytí v eventstreamu, můžete tato data CDC zpracovat v reálném čase a odeslat je do různých cílů v prostředcích infrastruktury pro další zpracování nebo analýzu.
Poznámka:
Tento zdroj není podporován v následujících oblastech kapacity pracovního prostoru: USA – západ 3, Švýcarsko – západ.
Požadavky
- Přístup k pracovnímu prostoru v režimu licence kapacity Fabric (nebo) zkušebním režimu licence s oprávněními Přispěvatel nebo vyšší.
- Přístup k instanci flexibilního serveru Azure Database for MySQL
- Vaše databáze MySQL musí být veřejně přístupná a nesmí být za bránou firewall nebo zabezpečená ve virtuální síti.
- Pokud nemáte stream událostí, vytvořte stream událostí.
Nastavení databáze MySQL
Konektor používá konektor Debezium MySQL k zachycení změn v databázi Azure Database for MySQL. Musíte definovat uživatele MySQL s odpovídajícími oprávněními pro všechny databáze, ze kterých může konektor zasílání zpráv zachytit změny. Uživatele správce můžete přímo použít k připojení k databázi, která má obvykle odpovídající oprávnění, jak je uvedeno níže. nebo můžete podle následujících kroků vytvořit nového uživatele.
Poznámka:
Nový účet uživatele nebo správce a odpovídající heslo se použijí k připojení k databázi později uvnitř eventstreamu.
Na příkazovém
mysql
řádku vytvořte uživatele MySQL:mysql> CREATE USER 'user'@'%' IDENTIFIED BY 'password';
Uživateli udělte požadovaná oprávnění:
mysql> GRANT SELECT, SHOW DATABASES, REPLICATION SLAVE, REPLICATION CLIENT ON *.* TO 'user'@'%';
Dokončete oprávnění uživatele:
mysql> FLUSH PRIVILEGES;
Pokud chcete ověřit, jestli má uživatel nebo správce udělená požadovaná oprávnění, spusťte následující příkaz a potom by se měla zobrazit požadovaná oprávnění v kroku 2 výše.
SHOW GRANTS FOR user;
Další informace o udělení požadovaných oprávnění uživateli najdete v tématu Debezium Connector for MySQL: Debezium Documentation.
Povolení binlogu
Pro replikaci MySQL musíte povolit binární protokolování. Binární protokoly zaznamenávají aktualizace transakcí pro nástroje replikace pro šíření změn.
Na stránce webu Azure Portal pro váš účet Azure Database for MySQL vyberte parametry serveru v části Nastavení v levém navigačním panelu.
Na stránce Parametry serveru nakonfigurujte následující vlastnosti a pak vyberte Uložit.
Jako binlog_row_image vyberte úplné.
Pro binlog_expire_logs_seconds nastavte počet sekund, po které služba čeká, než se vyprázdní soubor binárního protokolu. Nastavte hodnotu tak, aby odpovídala potřebám vašeho prostředí, například 86400.
Přidání databáze Azure MySQL (CDC) jako zdroje
Pokud jste do streamu událostí ještě nepřidali žádný zdroj, vyberte Použít dlaždici externího zdroje .
Pokud přidáváte zdroj do již publikovaného streamu událostí, přepněte do režimu úprav , na pásu karet vyberte Přidat zdroj a pak vyberte Externí zdroje.
Na stránce Vybrat zdroj dat vyhledejte a vyberte Připojit na dlaždici MySQL DB (CDC).
Konfigurace a připojení k Azure MySQL DB (CDC)
Na obrazovce Připojit v části Připojení vyberte Nové připojení a vytvořte cloudové připojení.
Zadejte následující nastavení připojení a přihlašovací údaje pro připojení pro vaši databázi Azure MySQL a pak vyberte Připojit.
Server: Adresa serveru vaší databáze Azure Database for MySQL, například my-mysql-server.mysql.database.azure.com.
Databáze: Název databáze, například my_database.
Název připojení: Automaticky vygenerováno nebo můžete zadat nový název tohoto připojení.
Uživatelské jméno a heslo: Zadejte přihlašovací údaje pro vaši databázi Azure Database for MySQL. Ujistěte se, že jste zadali účet správce serveru nebo uživatelský účet vytvořený s požadovanými oprávněními.
Zadejte následující informace, abyste nakonfigurovali zdroj dat CDC služby Azure MySQL DB, a pak vyberte Další.
Tabulky: Zadejte seznam názvů tabulek oddělených čárkami. Každý název tabulky musí odpovídat formátu
<database name>.<table name>
, například my_database.users.ID serveru: Zadejte jedinečnou hodnotu pro každý server a klienta replikace v clusteru MySQL. Výchozí hodnota je 1000.
Port: Ponechte výchozí hodnotu beze změny.
Název zdroje můžete také upravit tak, že v části Podrobnosti streamu vpravo vyberete tlačítko Tužka pro název zdroje.
Poznámka:
Pro každou čtečku nastavte jiné ID serveru. Každý databázový klient MySQL pro čtení binlogu by měl mít jedinečné ID označované jako ID serveru. MySQL Server používá toto ID k údržbě síťového připojení a pozice binlogu. Různé úlohy sdílející stejné ID serveru můžou vést ke čtení z nesprávné pozice binlogu. Proto se doporučuje pro každou čtečce nastavit jiné ID serveru.
Na stránce Zkontrolovat a připojit po kontrole souhrnu zdroje CDC služby Azure MySQL db vyberte Přidat a dokončete konfiguraci.
Poznámka:
Maximální počet zdrojů a cílů pro jeden stream událostí je 11.
Zobrazení aktualizovaného streamu událostí
V režimu úprav se zobrazí zdroj Azure MySQL DB (CDC) přidaný do vašeho eventstreamu.
Výběrem možnosti Publikovat publikujte změny a začněte streamovat data CDC databáze Azure MySQL do streamu událostí.
Související obsah
Další konektory: