ApsaraDB for SelectDB:MySQL verilerini geçirme

Yordam

1. ApsaraDB for SelectDB konsolu üzerinde oturum açın.

2. Sol üst köşede örneğinizin bulunduğu bölgeyi seçin.

3. Instances sayfasında hedef Instance ID değerini tıklayarak Instance Details sayfasına gidin.

4. Sol gezinme bölmesinde Data Pipeline seçeneğini tıklayın ve ardından Data Synchronization sekmesini seçin.

   Not

   DTS veri senkronizasyonu, tek seferlik aktarımlar için tarihsel veri geçişini gerçek zamanlı güncellemeler için artımlı veri senkronizasyonu ile birleştirir.

5. Create Synchronization Task seçeneğini tıklayın ve kaynak ile hedef veritabanlarını yapılandırın.

Kategori	Yapılandırma	Açıklama
Görev Bilgileri	Task Name	DTS otomatik olarak bir görev adı oluşturur. Kolay tanımlama için açıklayıcı bir ad belirtmenizi öneririz. Adın benzersiz olması gerekmez.
Kaynak Veritabanı	Database Type	MySQL seçin.
	Access Method	Alibaba Cloud Instance seçin.
	Instance Region	Kaynak ApsaraDB RDS for MySQL örneğinin bulunduğu bölgeyi seçin.
	RDS Instance ID	Kaynak ApsaraDB RDS for MySQL örneğinin kimliğini seçin. Örnek: rm-2z3m****.
	Database Account	Kaynak ApsaraDB RDS for MySQL örneğinin veritabanı hesabını girin. Gerekli izinler için bkz. Veritabanı hesapları için gerekli izinler.
	Database Password	Veritabanı hesabına karşılık gelen parolayı girin.
	Encryption	İhtiyaca göre Non-encrypted veya SSL-encrypted seçeneğini belirleyin. SSL-encrypted seçeneğini belirlerseniz RDS for MySQL örneğinde SSL şifrelemeyi önceden etkinleştirmeniz gerekir. Daha fazla bilgi için bkz. SSL şifrelemeyi hızlıca etkinleştirmek için cloud sertifikası kullanma.
Hedef Veritabanı	Database Type	SelectDB seçin.
	Access Method	Alibaba Cloud Instance seçin.
	Instance Region	Hedef SelectDB örneğinin bulunduğu bölgeyi seçin.
	Instance ID	Hedef SelectDB örneğinin kimliğini seçin.
	Database Account	Hedef SelectDB örneğinin veritabanı hesabını girin. Gerekli izinler için bkz. Veritabanı hesapları için gerekli izinler.
	Database Password	Veritabanı hesabına karşılık gelen parolayı girin.

6. Yapılandırmayı tamamladıktan sonra sayfanın alt kısmında Test Connection and Proceed seçeneğini tıklayın.

7. Görev nesnelerini ve gelişmiş ayarları yapılandırın.

Yapılandırma	Açıklama
Synchronization Types	Incremental Data Synchronization seçilidir. Varsayılan olarak ayrıca Schema Synchronization ve Full Data Synchronization seçeneklerini de belirlemeniz gerekir. Ön kontrol tamamlandıktan sonra DTS, seçilen nesnelerin tam veri senkronizasyonunu kaynak örneğinden hedef kümeye gerçekleştirir. Bu işlem, sonraki artımlı veri senkronizasyonu için temel veriler olarak işlev görür. Önemli Veriler MySQL'den SelectDB'ye senkronize edilirken veri türleri dönüştürülür. Schema Synchronization seçeneğini belirlemezseniz öncelikle hedef SelectDB örneğinde Unique Key modelini kullanan ve buna karşılık gelen şemaya sahip bir tablo oluşturmanız gerekir. Daha fazla bilgi için bkz. Veri türü eşlemeleri ve Veri modeli.
Source Objects	Source Objects kutusunda senkronize etmek istediğiniz nesneleri tıklayın ve ardından nesneleri Selected Objects kutusuna taşımak için simgesini tıklayın. Nesneleri veritabanı, tablo veya sütun düzeyinde seçebilirsiniz. Önemli Nesneleri veritabanı düzeyinde seçerseniz DTS görev başladıktan sonra oluşturulan tabloların verilerini senkronize etmez. Senkronizasyon sırasında tablo eklemeyi planlıyorsanız nesneleri tablo düzeyinde seçin. Seçimi daha sonra Modify Synchronized Objects özelliğini kullanarak değiştirebilirsiniz. Nesneleri tablo düzeyinde seçer ve tablo ya da sütun adlarını eşleme gibi düzenlemeler yapmanız gerekirse tek bir senkronizasyon görevi en fazla 1.000 tabloyu destekler. Bu sınır aşılırsa görevi gönderdiğinizde hata bildirilir. Bu durumda senkronize edilecek tabloları gruplara ayırıp birden çok görev yapılandırın veya veritabanı düzeyinde bir senkronizasyon görevi yapılandırın.
Selected Objects	Hedef örnekte tek bir senkronizasyon nesnesinin adını yeniden adlandırmak için Selected Objects kutusunda ilgili nesneye sağ tıklayın. Nesneleri yeniden adlandırma hakkında daha fazla bilgi için bkz. Tek bir veritabanı, tablo veya sütun eşleme. Hedef örnekte birden çok senkronizasyon nesnesinin adını toplu olarak değiştirmek için Selected Objects kutusunun sağ üst köşesindeki Batch Edit seçeneğini tıklayın. Daha fazla bilgi için bkz. Veritabanlarını, tabloları ve sütunları toplu olarak eşleme. Not Veritabanı veya tablo düzeyinde senkronize edilecek SQL işlemlerini seçmek için Selected Objects kutusunda senkronize edilecek nesneye sağ tıklayın ve ardından açılan iletişim kutusunda istediğiniz SQL işlemlerini seçin. Desteklenen işlemlerin listesi için bkz. Artımlı senkronizasyonu destekleyen SQL işlemleri. WHERE yan tümcesini kullanarak verileri filtrelemek için Selected Objects kutusunda senkronize edilecek tabloya sağ tıklayın ve ardından açılan iletişim kutusunda filtre koşulunu ayarlayın. Daha fazla bilgi için bkz. Filtre koşulları ayarlama. Nesne adı eşleme özelliğini kullanırsanız yeniden eşlenen nesneye bağımlı diğer nesneler senkronize edilemeyebilir.

8. İsteğe bağlı: Önceki yapılandırmaları tamamladıktan sonra hedef tablolar için Primary Key Column, Distribution Key ve Engine değerlerini ayarlamak üzere Next: Configure Database and Table Fields seçeneğini tıklayın.

Not

• Bu adım yalnızca görev nesnelerini yapılandırırken Synchronization Types altında Schema Synchronization seçeneğini belirlediğinizde kullanılabilir. Definition Status değerini All olarak ayarlayıp ardından ayarları değiştirebilirsiniz.

• Bileşik bir Primary Key Column oluşturmak için birden çok sütun seçebilir ve Primary Key Column içinden bir veya daha fazla sütunu Distribution Key olarak seçmeniz gerekir. Engine için yalnızca Unique desteklenir.

9. Görevi kaydedin ve ön kontrolü çalıştırın. Precheck Success Rate değeri %100 olduğunda Next: Purchase seçeneğini tıklayın.

10. Purchase sayfasında veri senkronizasyonu örneği için faturalama yöntemini ve bağlantı teknik özelliklerini seçin. Data Transmission Service (Pay-As-You-Go) Service Terms metnini okuyup kabul edin. Senkronizasyon görevini başlatmak için Purchase and Start seçeneğini tıklayın. Görev ilerlemesini veri senkronizasyonu sayfasında görüntüleyebilirsiniz.

Veri kaynakları ekleme

Bir veri senkronizasyonu görevi geliştirirken DataWorks'te bir MySQL veri kaynağı ve bir SelectDB veri kaynağı oluşturun.

1. MySQL veri kaynağı oluşturun. Daha fazla bilgi için bkz. MySQL veri kaynağı.

2. SelectDB veri kaynağı oluşturun. Daha fazla bilgi için bkz. Veri kaynağı yönetimi. Aşağıdaki tabloda SelectDB veri kaynağı için bazı yapılandırma parametreleri açıklanmıştır.

   Parametre	Açıklama
   Data Source Name	Veri kaynağının adı.
   MySQL Connection URL	jdbc:mysql://<ip>:<port>/<dbname> JDBC bağlantı dizesini girin. VPC Endpoint (veya Public Endpoint) ile MySQL Port değerlerini ApsaraDB for SelectDB konsolundaki Instance Details > Network Information sayfasından alabilirsiniz. Örnek: jdbc:mysql://selectdb-cn-4xl3jv1****.selectdbfe.rds.aliyuncs.com:9030/test_db
   HTTP Connection URL	<ip>:<port> biçiminde HTTP protokolü uç noktasını girin. VPC Endpoint (veya Public Endpoint) ile HTTP Port değerlerini ApsaraDB for SelectDB konsolundaki Instance Details > Network Information sayfasından alabilirsiniz. Örnek: selectdb-cn-4xl3jv1****.selectdbfe.rds.aliyuncs.com:8080
   Username	ApsaraDB for SelectDB örneği için kullanıcı adını girin.
   Password	ApsaraDB for SelectDB örneğinde belirtilen kullanıcı için parolayı girin.

Veri senkronizasyonunu yapılandırma

Bir veri geçişi görevini yapılandırmak için aşağıdaki belgelere bakın:

• MySQL veritabanındaki tüm verileri SelectDB'ye gerçek zamanlı olarak senkronize etme.

• Kodsuz arayüzü kullanarak toplu senkronizasyon görevi yapılandırma.

• Kod düzenleyiciyi kullanarak toplu senkronizasyon görevi yapılandırma.

Flink CDC ile veri geçişi yapma

Flink, verileri MySQL'den SelectDB'ye geçirmek için Flink SQL, Flink CDC ve DataStream olmak üzere üç yöntem sunar. Flink CDC tarihsel veri geçişi, artımlı veri senkronizasyonu, veritabanı ve tablo geçişi ile DDL senkronizasyonunu destekler. Aşağıdaki örnek Flink CDC kullanarak verileri MySQL'den ApsaraDB for SelectDB hizmetine senkronize etmeyi gösterir. Daha fazla bilgi için bkz. Flink kullanarak veri içe aktarma.

<FLINK_HOME>/bin/flink run \
    -Dexecution.checkpointing.interval=10s \
    -Dparallelism.default=1 \
    -c org.apache.doris.flink.tools.cdc.CdcTools \
    lib/flink-doris-connector-1.16-1.5.2.jar \
    mysql-sync-database \
    --database test_db \
    --including-tables "tbl1|test.*" \
    --mysql-conf hostname=127.0.0.1 \
    --mysql-conf username=root \
    --mysql-conf password=123456 \
    --mysql-conf database-name=mysql_db \
    --sink-conf fenodes=selectdb-cn-****.selectdbfe.rds.aliyuncs.com:8080 \
    --sink-conf username=admin \
    --sink-conf password=****

Katalog kullanarak veri geçişi yapma