Data Transmission Service:Buat saluran pelacakan perubahan PolarDB for MySQL

Prasyarat

Fitur binary logging telah diaktifkan untuk kluster sumber PolarDB for MySQL. Untuk informasi selengkapnya, lihat Enable binary logging.

Catatan penggunaan

• Perubahan Online DDL yang dilakukan oleh alat seperti gh-ost atau pt-online-schema-change tidak dilacak. Klien mungkin gagal menulis data yang dikonsumsi ke tabel tujuan karena ketidaksesuaian skema.
• Jika database sumber digunakan dalam tugas lain seperti migrasi data, data di luar cakupan langganan Anda mungkin ikut dilacak. Filter data yang tidak diinginkan di aplikasi klien Anda.

Prosedur

1. Beli saluran pelacakan perubahan. Untuk informasi selengkapnya, lihat Purchase a change tracking task.
   Catatan Saat membeli saluran tersebut, atur Source database menjadi PolarDB dan pilih wilayah tempat kluster PolarDB for MySQL sumber berada.
2. Login ke DTS console.
3. Di panel navigasi sebelah kiri, klik Change Tracking.
4. Pada halaman Change Tracking Tasks, pilih wilayah instans pelacakan perubahan Anda.
5. Temukan saluran yang telah dibeli dan klik Configure channel.
6. Konfigurasikan informasi database sumber dan jenis jaringan.

   Bagian	Parameter	Deskripsi
   N/A	Task name	DTS secara otomatis menghasilkan nama tugas. Kami menyarankan agar Anda menentukan nama yang informatif agar mudah dikenali. Nama tersebut tidak harus unik.
   Source database	Instance type	Nilai ini diatur ke PolarDB instance dan tidak dapat diubah.
   	Database type	Nilai ini diatur ke PolarDB dan tidak dapat diubah.
   	Instance region	Wilayah sumber yang Anda pilih saat membeli saluran. Parameter ini tidak dapat diubah.
   	PolarDB instance ID	Pilih ID kluster sumber PolarDB for MySQL.
   	Database account	Masukkan akun database kluster sumber PolarDB for MySQL. Catatan Akun tersebut harus memiliki izin REPLICATION CLIENT, REPLICATION SLAVE, SHOW VIEW, dan SELECT pada objek langganan.
   	Database password	Masukkan password untuk akun database tersebut.
   Network type	N/A	Tentukan jenis jaringan untuk saluran tersebut. Classic Network Jika Anda mengatur jenis jaringan ke Classic Network, tidak diperlukan konfigurasi tambahan. What is a classic network?. Proprietary Network Jika Anda mengatur jenis jaringan ke Proprietary Network, Anda juga harus memilih Proprietary Network dan vSwitch. What is a VPC?. Catatan Pilih jenis jaringan yang sama dengan instance ECS tempat klien langganan Anda di-deploy. Misalnya, jika instance ECS berada di VPC, pilih VPC sebagai jenis jaringan dan tentukan Proprietary Network dan vSwitch. Koneksi jaringan privat meminimalkan latensi.

7. Klik Set whitelist and next.

   DTS secara otomatis menambahkan alamat IP server DTS di wilayah yang sesuai ke daftar putih instans database Alibaba Cloud. Untuk daftar alamat IP server DTS, lihat IP address ranges of DTS servers.

   Peringatan Menambahkan blok CIDR publik menimbulkan risiko keamanan. Gunakan kata sandi yang kuat, batasi port terbuka, terapkan autentikasi API internal, tinjau akses jaringan secara berkala, dan gunakan koneksi privat melalui Express Connect, VPN Gateway, atau Smart Access Gateway.
8. Konfigurasikan tipe data dan objek yang akan dilacak.

   Parameter	Deskripsi
   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. Filter data yang diperlukan di aplikasi klien Anda. Catatan Memilih seluruh database juga melacak perubahan pada objek yang ditambahkan kemudian. Memilih tabel tertentu hanya melacak tabel tersebut. Untuk melacak tabel baru, tambahkan tabel tersebut ke objek langganan. Modify the objects for change tracking.
   Required objects	Pada kotak Required Objects, pilih objek yang akan dilacak dan klik ikon untuk memindahkannya ke kotak Selected Objects. Catatan Anda dapat memilih objek pada tingkat database atau tabel.

9. Klik Save and Precheck.
   Catatan

   • Tugas hanya dapat dimulai setelah lulus pemeriksaan awal.
   • Jika pemeriksaan awal gagal, klik di samping item yang gagal untuk melihat detailnya. Perbaiki masalah tersebut dan jalankan ulang pemeriksaan awal.
10. Saat pesan Precheck Passed muncul di kotak dialog Precheck, tutup kotak dialog Precheck.

Langkah selanjutnya

Setelah dikonfigurasi, saluran menjalani inisialisasi selama sekitar satu menit. Setelah inisialisasi selesai, Anda dapat melakukan operasi berikut:

1. Create a consumer group
2. Consume subscribed data by using a Kafka client
3. Consume subscribed data by using SDK sample code