Olay akışına My SQL Veritabanı CDC kaynağı ekleme (önizleme)

Not

Bu makale, Microsoft'un SLAVEartık kullanmadığını ifade eden terimine başvurular içerir. Terim yazılımdan kaldırıldığında, bu makaleden kaldıracağız.

Bu makalede, bir olay akışına MySQL için Azure Veritabanı Değişiklik Veri Yakalama kaynağı ekleme adımları gösterilmektedir. Microsoft Fabric olay akışları için Azure My SQL Veritabanı Change Data Capture (CDC) Kaynak bağlayıcısı, MySQL için Azure Veritabanı veritabanındaki geçerli verilerin anlık görüntüsünü yakalamanızı sağlar.

İzlenecek tabloları belirtebilirsiniz ve olay akışı tablolarda gelecekteki satır düzeyi değişiklikleri kaydeder. Değişiklikler olay akışında yakalandıktan sonra, bu CDC verilerini gerçek zamanlı olarak işleyebilir ve daha fazla işleme veya analiz için Doku'daki farklı hedeflere gönderebilirsiniz.

Önemli

Doku olay akışlarının gelişmiş özellikleri şu anda önizleme aşamasındadır.

Not

Bu kaynak, çalışma alanı kapasitenizin şu bölgelerinde desteklenmez: Batı ABD3, Batı İsviçre.

Önkoşullar

• Katkıda Bulunan veya daha yüksek izinlere sahip Doku premium çalışma alanına erişim.
• MySQL için Azure Veritabanı - Esnek Sunucu örneğine erişim.
• MySQL veritabanınızın genel olarak erişilebilir olması ve bir güvenlik duvarının arkasında veya sanal ağda güvenliği sağlanmaması gerekir.

Not

Bir olay akışı için kaynak ve hedef sayısı üst sınırı 11'dir.

MySQL DB'i ayarlama

Bağlayıcı, MySQL için Azure Veritabanı veritabanınızdaki değişiklikleri yakalamak için Debezium MySQL bağlayıcısını kullanır. Mesajlaşma Bağlayıcısı'nın değişiklikleri yakalayabileceği tüm veritabanlarında uygun ayrıcalıklara sahip bir MySQL kullanıcısı tanımlamanız gerekir. Normalde aşağıdaki gibi uygun ayrıcalıklara sahip olan veritabanına bağlanmak için yönetici kullanıcıyı doğrudan kullanabilirsiniz. veya yeni kullanıcı oluşturmak için aşağıdaki adımları izleyebilirsiniz

Not

Yeni kullanıcı veya yönetici hesabı ve buna karşılık gelen parola daha sonra Eventstream içinde veritabanına bağlanmak için kullanılacaktır.

1. Komut isteminde mysql MySQL kullanıcısını oluşturun:

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

2. Kullanıcıya gerekli ayrıcalıkları verin:

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

3. Kullanıcının izinlerini sonlandırın:

   mysql> FLUSH PRIVILEGES;
   

Kullanıcı veya yöneticinin verilen gerekli ayrıcalıklara sahip olup olmadığını onaylamak için aşağıdaki komutu çalıştırın ve yukarıdaki 2. adımda gerekli ayrıcalıklar gösterilmelidir.

SHOW GRANTS FOR user;

Kullanıcıya gerekli izinleri verme hakkında daha fazla bilgi için bkz . MySQL için Debezium bağlayıcısı :: Debezium Belgeleri.

Binlog'un etkinleştirilmesi

MySQL çoğaltması için ikili günlüğü etkinleştirmeniz gerekir. İkili günlükler, değişiklikleri yaymak için çoğaltma araçları için işlem güncelleştirmelerini kaydeder.

1. MySQL için Azure Veritabanı hesabınızın Azure portalı sayfasında, sol gezinti bölmesindeki Ayarlar'ın altında Sunucu parametreleri'ni seçin.

2. Sunucu parametreleri sayfasında aşağıdaki özellikleri yapılandırın ve kaydet'i seçin.

   • binlog_row_image için Tam'ı seçin.

   • binlog_expire_logs_seconds için, ikili günlük dosyası temizlenmeden önce hizmetin bekleyeceği saniye sayısını ayarlayın. Değeri ortamınızın gereksinimlerine uyacak şekilde ayarlayın, örneğin 86400.

   

Azure MySQL DB'yi (CDC) kaynak olarak ekleme

1. Doku Gerçek Zamanlı Zeka bölümünde Eventstream'i seçerek yeni bir olay akışı oluşturun. Gelişmiş Özellikler (önizleme) seçeneğinin etkinleştirildiğinden emin olun.

   

2. Sonraki ekranda Dış kaynak ekle'yi seçin.

   

Azure MySQL DB'yi (CDC) yapılandırma ve bağlama

1. Veri kaynağı seçin ekranında veri kaynağı olarak Azure MySQL DB (CDC) seçeneğini belirleyin.

   

2. Bağlan ekranındaki Bağlantı'nın altında Yeni bağlantı'yı seçerek bulut bağlantısı oluşturun.

3. Azure MySQL DB'niz için aşağıdaki Bağlantı ayarlarını ve Bağlantı kimlik bilgilerini girin ve bağlan'ı seçin.

   • Sunucu: MySQL için Azure Veritabanı veritabanınızın sunucu adresi, örneğin my-mysql-server.mysql.database.azure.com.
   • Veritabanı: Veritabanı adı, örneğin my_database.
   • Bağlantı adı: Otomatik olarak oluşturulur veya bu bağlantı için yeni bir ad girebilirsiniz.
   • Kullanıcı adı ve Parola: MySQL için Azure Veritabanı veritabanınızın kimlik bilgilerini girin. Sunucu yönetici hesabını veya verilen gerekli ayrıcalıklarla oluşturulan kullanıcı hesabını girdiğinizden emin olun.

   

4. Azure MySQL DB CDC veri kaynağını yapılandırmak için aşağıdaki bilgileri girin ve İleri'yi seçin.

   • Tablolar: Virgülle ayrılmış tablo adlarının listesini girin. Her tablo adı biçiminde <database name>.<table name>olmalıdır, örneğin my_database.users.
   • Sunucu Kimliği: MySQL kümesindeki her sunucu ve çoğaltma istemcisi için benzersiz bir değer girin. Varsayılan değer 1000'dir.
   • Bağlantı noktası: Varsayılan değeri değiştirmeden bırakın.

   

   Not

   Her okuyucu için farklı bir Sunucu Kimliği ayarlayın. Binlog okumak için her MySQL veritabanı istemcisinin Sunucu Kimliği adlı benzersiz bir kimliği olmalıdır. MySQL Sunucusu, ağ bağlantısını ve binlog konumunu korumak için bu kimliği kullanır. Aynı Sunucu Kimliğini paylaşan farklı işler yanlış binlog konumundan okumayla sonuçlanabilir. Bu nedenle, her okuyucu için farklı bir Sunucu Kimliği ayarlamanız önerilir.

5. Azure MySQL DB CDC kaynağının özetini gözden geçirdikten sonra, yapılandırmayı tamamlamak için Ekle'yi seçin.

Azure MySQL DB (CDC) kaynağının Düzenleme modunda olay akışınıza eklendiğini görürsünüz.

Değişiklikleri yayımlamak ve Azure MySQL DB CDC verilerini olay akışına akışla aktarmaya başlamak için Yayımla'yı seçin.

İlgili içerik

Diğer bağlayıcılar:

• Amazon Kinesis Veri Akışları
• Azure Cosmos DB
• Azure Event Hubs
• Azure IoT Hub
• Azure SQL Veritabanı Veri Yakalamayı Değiştir (CDC)
• Confluent Kafka
• Özel uç nokta
• Google Cloud Pub/Sub
• Postgre SQL Veritabanı CDC
• Örnek veriler
• olayları Azure Blob Depolama
• Doku çalışma alanı olayı