Data Transmission Service:RDS for MySQL: Buat instans pelacakan perubahan

Catatan penggunaan

• Perubahan Online DDL yang dilakukan oleh alat seperti gh-ost atau pt-online-schema-change tidak dilacak. Akibatnya, klien mungkin gagal menulis data yang dikonsumsi ke tabel tujuan karena ketidaksesuaian skema.
• Jika database sumber merupakan bagian dari tugas lain, seperti tugas migrasi data yang sedang berjalan, data dari objek di luar cakupan langganan Anda mungkin ikut dilacak. Anda harus memfilter data yang tidak diinginkan secara manual di aplikasi klien Anda.

Prosedur

1. Beli instans pelacakan perubahan. Untuk informasi selengkapnya, lihat Purchase a change tracking task.
2. Masuk ke DTS console.
3. Di panel navigasi sebelah kiri, klik Change Tracking.
4. Di bagian atas halaman Change Tracking Tasks, pilih wilayah tempat instans pelacakan perubahan Anda berada.
5. Temukan instans pelacakan perubahan tersebut dan klik Configure Task.
6. Konfigurasikan informasi database sumber dan jenis jaringan.

   Category	Parameter	Description
   N/A	Task name	DTS secara otomatis menghasilkan nama tugas. Tentukan nama deskriptif agar tugas mudah dikenali. Nama tersebut tidak perlu unik.
   Source database	Instance type	Pilih tipe instans sumber. Pada contoh ini, pilih RDS Instance. Catatan Jika sumbernya adalah database yang dikelola sendiri, Anda harus melakukan langkah persiapan tambahan. Untuk informasi selengkapnya, lihat Preparation overview.
   	Database type	MySQL dan tidak dapat diubah.
   	Instance region	Region yang Anda pilih saat membeli instans. Pengaturan ini tidak dapat diubah.
   	RDS instance ID	Pilih ID instans ApsaraDB RDS for MySQL yang ingin Anda lacak. Catatan Anda tidak dapat menggunakan instansi hanya baca atau instansi temporary sebagai instans sumber untuk pelacakan perubahan.
   	Database account	Masukkan akun database untuk instans ApsaraDB RDS for MySQL sumber. Catatan Akun tersebut harus memiliki izin REPLICATION CLIENT, REPLICATION SLAVE, SHOW VIEW, dan SELECT pada objek langganan. MySQL 5.5MySQL 5.6Database AccountDatabase PasswordJika instans ApsaraDB RDS for MySQL sumber menjalankan atau , Anda tidak perlu mengonfigurasi parameter dan .
   	Database password	Masukkan password untuk akun database tersebut.
   Network type	Classic Network Proprietary Network	Catatan Jika client Anda ditempatkan di lingkungan on-premises, Anda dapat memilih Classic Network atau Proprietary Network. Jika client Anda ditempatkan pada instance ECS, kami menyarankan Anda memilih jenis jaringan yang sama dengan instance ECS tersebut. Misalnya, jika instance ECS berada dalam VPC, pilih VPC di sini dan tentukan Proprietary Network dan vSwitch yang sama dengan instance ECS tersebut. Menggunakan titik akhir internal untuk pelacakan perubahan memberikan latensi jaringan terendah. Classic Network Jika Anda memilih Classic Network, tidak diperlukan konfigurasi tambahan. Untuk informasi selengkapnya, lihat classic network. Proprietary Network Jika Anda memilih Proprietary Network, Anda juga harus menentukan Proprietary Network dan vSwitch. Untuk informasi selengkapnya, lihat VPC.

7. Setelah menyelesaikan pengaturan ini, klik Set Whitelist and Next.

   DTS secara otomatis menambahkan blok CIDR servernya ke konfigurasi database sumber. Untuk instans database Alibaba Cloud, seperti ApsaraDB RDS for MySQL atau ApsaraDB for MongoDB, blok CIDR tersebut ditambahkan ke daftar putih instans. Untuk database yang dikelola sendiri pada instance ECS, DTS menambahkan blok CIDR tersebut ke aturan grup keamanan, tetapi Anda juga harus menambahkannya secara manual ke daftar putih database. Untuk detail blok CIDR yang diperlukan dalam skenario lain, lihat CIDR blocks of DTS servers.

   Peringatan Menambahkan blok CIDR publik menimbulkan risiko keamanan. Kurangi risiko tersebut dengan tindakan pencegahan seperti menggunakan kata sandi yang kuat, membatasi port terbuka, mengotentikasi API internal, meninjau akses jaringan secara berkala, dan menggunakan koneksi jaringan pribadi melalui Express Connect, VPN Gateway, atau Smart Access Gateway.
8. Pada kotak dialog Create Change Tracking Account, tunggu hingga akun dibuat, lalu klik Next.
   Catatan MySQL 5.5MySQL 5.6Langkah ini hanya diperlukan jika instans ApsaraDB RDS for MySQL sumber menjalankan atau . Pada langkah ini, DTS membuat akun database khusus di instans sumber untuk pelacakan perubahan.
9. Konfigurasikan tipe data dan objek yang akan dilacak.

   Parameter	Description
   Required data types	Data Update Berlangganan perubahan data (operasi INSERT, DELETE, dan UPDATE) untuk objek yang dipilih. Schema Update Berlangganan perubahan skema (operasi CREATE, DROP, dan ALTER) untuk semua objek dalam instans. Anda harus memfilter data yang diperlukan di aplikasi client Anda. Catatan Jika Anda memilih seluruh database sebagai objek langganan, perubahan data pada objek baru yang ditambahkan ke database tersebut juga dilacak. Jika Anda memilih tabel tertentu sebagai objek langganan, hanya perubahan data pada tabel tersebut yang dilacak. Untuk melacak tabel baru, Anda harus menambahkannya ke objek langganan. Untuk informasi selengkapnya, lihat Modify the objects for change tracking.
   Required objects	Pada kotak Required Objects, pilih objek yang ingin Anda lacak dan klik ikon untuk memindahkannya ke kotak Selected Objects. Catatan Anda dapat memilih objek pada tingkat database atau tabel.

10. Setelah menyelesaikan konfigurasi, klik Save and Precheck di pojok kanan bawah halaman.
    Catatan

    • Tugas hanya dapat dimulai setelah lulus pemeriksaan awal.
    • Jika pemeriksaan awal gagal, klik ikon di samping item yang gagal untuk melihat detailnya. Setelah memperbaiki masalah tersebut, jalankan kembali pemeriksaan awal.
11. Saat pesan Precheck Passed muncul di kotak dialog Precheck, tutup kotak dialog Precheck.

Setelah mengonfigurasi tugas, instans pelacakan perubahan akan melakukan inisialisasi, yang memerlukan waktu sekitar satu menit. Setelah diinisialisasi, Anda dapat membuat kelompok konsumen dan mulai mengonsumsi data yang dilacak.

Langkah selanjutnya

1. Create consumer groups
2. Use a Kafka client to consume tracked data
3. Consume tracked data using SDK sample code