Data Transmission Service：Track perubahan data dari instans ApsaraDB RDS for MySQL

Prasyarat

Sebelum memulai, pastikan Anda telah memiliki:

• Instans ApsaraDB RDS for MySQL (sumber)
• Akun database dengan izin SELECT pada objek yang diperlukan serta izin REPLICATION CLIENT, REPLICATION SLAVE, dan SHOW VIEW
• Instans pelacakan perubahan yang telah dibeli. Untuk detailnya, lihat Beli instans pelacakan perubahan

Perhatian

• DTS tidak melacak operasi DDL yang dilakukan oleh gh-ost atau pt-online-schema-change. Klien pelacakan perubahan mungkin gagal menulis data yang dikonsumsi ke tabel tujuan karena konflik skema.
• Jika database sumber terlibat dalam tugas lain, seperti tugas migrasi data yang sedang berjalan, DTS mungkin melacak perubahan data dari objek tambahan. Filter data yang dilacak secara manual pada klien pelacakan perubahan.

Konfigurasikan tugas pelacakan perubahan

1. Masuk ke Konsol DTS.
2. Pada panel navigasi sebelah kiri, klik Change Tracking.
3. Di bagian atas halaman Change Tracking Tasks, pilih wilayah tempat instans pelacakan perubahan berada.
4. Temukan instans pelacakan perubahan dan klik Configure Task pada kolom Actions.
5. Konfigurasikan database sumber dan jenis jaringan.

   Kategori	Konfigurasi	Deskripsi
   Pengaturan tugas	Task Name	DTS menghasilkan nama tugas secara otomatis. Tentukan nama deskriptif untuk mengidentifikasi tugas tersebut. Nama tugas tidak harus unik.
   Pengaturan database sumber	Instance Type	Pilih RDS Instance. Catatan Jika database sumber Anda adalah database yang dikelola sendiri, siapkan lingkungan jaringan terlebih dahulu. Untuk detailnya, lihat Ikhtisar persiapan.
   	Database Type	Atur ke MySQL. Nilai ini tidak dapat diubah.
   	Instance Region	Menampilkan wilayah sumber yang dipilih pada halaman pembelian. Nilai ini tidak dapat diubah.
   	RDS Instance ID	Pilih ID instans ApsaraDB RDS for MySQL tempat perubahan data akan dilacak. Instans hanya baca atau instans temporary tidak dapat digunakan sebagai sumber.
   	Database Account	Masukkan akun database dari instans sumber. Akun tersebut harus memiliki izin SELECT pada objek yang diperlukan serta izin REPLICATION CLIENT, REPLICATION SLAVE, dan SHOW VIEW.
   	Database Password	Masukkan password untuk akun database tersebut.
   Network Type	Classic VPC	Pilih jenis jaringan untuk instans pelacakan perubahan: Classic atau VPC. Catatan Jika klien pelacakan perubahan dijalankan pada server lokal, pilih Classic atau VPC. Jika klien pelacakan perubahan dijalankan pada instans ECS, pilih jaringan yang sesuai dengan instans ECS tersebut. Misalnya, jika instans ECS berada dalam VPC, pilih VPC dan tentukan parameter VPC dan vSwitch. Melacak perubahan data melalui jaringan internal meminimalkan latensi jaringan. Classic Tidak diperlukan konfigurasi tambahan. Untuk detailnya, lihat Jenis jaringan. VPC Tentukan parameter VPC dan vSwitch. Untuk detailnya, lihat Jenis jaringan.

6. Di pojok kanan bawah halaman, klik Test Connectivity and Proceed.

   Jika database sumber adalah instans database Alibaba Cloud (seperti ApsaraDB RDS for MySQL atau ApsaraDB for MongoDB) atau database yang dikelola sendiri yang dihosting di ECS, DTS secara otomatis menambahkan blok CIDR server DTS ke daftar putih instans database atau aturan security group ECS. Untuk detailnya, lihat Tambahkan blok CIDR server DTS ke pengaturan keamanan database on-premises. Jika database sumber adalah database yang dikelola sendiri di pusat data atau penyedia cloud lain, tambahkan blok CIDR server DTS secara manual untuk mengizinkan akses.

   Peringatan Menambahkan blok CIDR server DTS ke daftar putih atau aturan security group ECS dapat menimbulkan risiko keamanan. Sebelum menggunakan DTS, pahami dan akui risiko tersebut. Ambil langkah pencegahan, seperti memperkuat keamanan akun dan kata sandi, membatasi port yang terbuka, mengautentikasi panggilan API, meninjau secara berkala daftar putih atau aturan security group, menghapus blok CIDR yang tidak sah, atau menghubungkan database ke DTS melalui Express Connect, VPN Gateway, atau Smart Access Gateway.

   Setelah tugas DTS Anda selesai atau dirilis, periksa dan hapus blok CIDR yang ditambahkan dari daftar putih atau aturan security group ECS secara manual.

7. Pilih jenis dan objek perubahan data.

   Konfigurasi	Deskripsi
   Required Data Types	Pilih satu atau kedua jenis perubahan data: Data Updates Melacak operasi INSERT, DELETE, dan UPDATE pada objek yang dipilih. Schema Updates Melacak operasi pembuatan, penghapusan, dan modifikasi pada semua skema objek dari instans sumber. Filter data yang diperlukan menggunakan klien pelacakan perubahan. Catatan Memilih database akan melacak perubahan data semua objek dalam database tersebut, termasuk objek yang ditambahkan kemudian. Memilih tabel hanya melacak perubahan data pada tabel tersebut. Untuk melacak perubahan pada tabel tambahan, ubah objek yang dipilih. Untuk detailnya, lihat Ubah objek untuk pelacakan perubahan.
   Required Objects	Pilih objek dari bagian Required Objects dan klik ikon untuk memindahkannya ke bagian Selected. Catatan Pilih tabel atau database sebagai objek untuk pelacakan perubahan.

8. Di pojok kanan bawah halaman, klik Save and Precheck.
   Catatan

   • DTS melakukan Pemeriksaan Awal sebelum memulai tugas pelacakan perubahan. Tugas hanya akan dimulai setelah Pemeriksaan Awal berhasil.
   • Jika ada item Pemeriksaan Awal yang gagal, klik ikon di samping item yang gagal untuk melihat detailnya. Perbaiki masalah tersebut dan jalankan Pemeriksaan Awal lagi.
9. Setelah muncul pesan The precheck is passed, tutup kotak dialog Precheck.

Setelah konfigurasi selesai, DTS melakukan pelacakan perubahan awal. Proses ini memerlukan waktu sekitar satu menit. Setelah pelacakan perubahan awal selesai, buat satu atau beberapa kelompok konsumen untuk mengonsumsi data yang dilacak.

Langkah selanjutnya

1. Buat kelompok konsumen
2. Gunakan klien Kafka untuk mengonsumsi data yang dilacak
3. Gunakan demo SDK untuk mengonsumsi data yang dilacak