全部产品
Search
文档中心

Data Transmission Service:Melacak perubahan data dari instance ApsaraDB RDS for MySQL

更新时间:Jul 06, 2025

Anda dapat menggunakan Data Transmission Service (DTS) untuk melacak perubahan data dari database secara real-time. Fitur pelacakan perubahan ini dapat digunakan dalam skenario seperti pembaruan cache ringan, penguraian bisnis, pemrosesan data asinkron, serta sinkronisasi operasi ekstraksi, transformasi, dan pemuatan (ETL). Topik ini menjelaskan cara melacak perubahan data dari instance ApsaraDB RDS for MySQL.

Tindakan pencegahan

  • DTS tidak melacak operasi DDL yang dilakukan dengan menggunakan gh-ost atau pt-online-schema-change. Akibatnya, klien pelacakan perubahan mungkin gagal menulis data yang dikonsumsi ke tabel tujuan karena konflik skema.

  • Jika database sumber terlibat dalam tugas lain seperti migrasi data yang sedang berjalan, DTS mungkin melacak perubahan data dari objek lain. Dalam hal ini, Anda harus menyaring data yang dilacak secara manual di klien pelacakan perubahan.

Prosedur

  1. Buat instance pelacakan perubahan. Untuk informasi lebih lanjut, lihat Beli Instance Pelacakan Perubahan.

  2. Masuk ke Konsol DTS.

  3. Di panel navigasi sebelah kiri, klik Change Tracking.

  4. Di bagian atas halaman Change Tracking Tasks, pilih wilayah tempat instance pelacakan perubahan berada.

  5. Temukan instance pelacakan perubahan dan klik Configure Task di kolom Aksi.

  6. Konfigurasikan database sumber dan tipe jaringan untuk tugas pelacakan perubahan. Configure a change tracking task

    Bagian

    Parameter

    Deskripsi

    Tidak ada

    Nama Tugas

    Nama tugas yang dibuat otomatis oleh DTS. Kami sarankan Anda menentukan nama deskriptif yang memudahkan identifikasi tugas. Anda tidak perlu menggunakan nama tugas unik.

    Database Sumber

    Tipe Instance

    Tipe instance sumber. Dalam contoh ini, RDS Instance dipilih untuk parameter ini.

    Catatan

    Jika database sumber Anda adalah database yang dikelola sendiri, Anda harus menyiapkan lingkungan jaringan untuk database tersebut. Untuk informasi lebih lanjut, lihat Ikhtisar persiapan.

    Tipe Database

    Nilai parameter ini disetel ke MySQL dan tidak dapat diubah.

    Wilayah Instance

    source region yang Anda pilih di halaman pembelian. Nilai parameter ini tidak dapat diubah.

    ID Instance RDS

    ID instance ApsaraDB RDS for MySQL dari mana Anda ingin melacak perubahan data.

    Catatan

    Instance baca-saja atau instance sementara tidak dapat digunakan sebagai instance sumber untuk pelacakan perubahan.

    Akun Database

    Akun database dari instance ApsaraDB RDS for MySQL sumber.

    Catatan
    • Akun tersebut harus memiliki izin SELECT pada objek yang diperlukan dan izin REPLICATION CLIENT, REPLICATION SLAVE, dan SHOW VIEW.

    • Jika mesin database dari instance ApsaraDB RDS for MySQL sumber adalah MySQL 5.5 atau MySQL 5.6, Anda tidak perlu mengonfigurasi database account atau database password.

    Kata Sandi Database

    Kata sandi untuk akun database ApsaraDB RDS for MySQL sumber.

    Tipe jaringan

    • Classic

    • VPC

    Tipe jaringan dari instance pelacakan perubahan.

    Catatan
    • Jika klien pelacakan perubahan Anda ditempatkan di server lokal, Anda dapat memilih Classic atau VPC.

    • Jika klien pelacakan perubahan Anda ditempatkan di instance ECS, kami sarankan Anda memilih jaringan dari instance ECS. Sebagai contoh, jika instance ECS ditempatkan di Virtual Private Cloud (VPC), pilih VPC sebagai tipe jaringan dan tentukan parameter VPC dan vSwitch.

    • Jika Anda melacak perubahan data melalui jaringan internal, latensi jaringan akan minimal.

    • Classic

      Jika Anda memilih Classic, tidak diperlukan konfigurasi tambahan. Untuk informasi lebih lanjut, lihat Tipe jaringan.

    • VPC

      Jika Anda memilih VPC, Anda harus menentukan parameter VPC dan vSwitch. Untuk informasi lebih lanjut, lihat Tipe jaringan.

  7. Di pojok kanan bawah halaman, klik Set Whitelist and Next.

    Peringatan
    • Jika instance database sumber atau tujuan adalah instance database Alibaba Cloud, seperti instance ApsaraDB RDS for MySQL atau instance ApsaraDB for MongoDB, atau merupakan database mandiri yang di-hosting di Elastic Compute Service (ECS), DTS secara otomatis menambahkan blok CIDR server DTS ke daftar putih instance database atau aturan grup keamanan ECS. Untuk informasi lebih lanjut, lihat Tambahkan Blok CIDR Server DTS ke Pengaturan Keamanan Database Lokal. Jika database sumber atau tujuan adalah database mandiri di pusat data atau berasal dari penyedia layanan cloud lainnya, Anda harus menambahkan blok CIDR server DTS secara manual untuk mengizinkan DTS mengakses database.

    • Jika blok CIDR server DTS ditambahkan secara otomatis atau manual ke daftar putih instance database atau aturan grup keamanan ECS, risiko keamanan mungkin timbul. Oleh karena itu, sebelum menggunakan DTS untuk migrasi data, Anda harus memahami dan mengakui potensi risiko serta mengambil tindakan pencegahan, termasuk tetapi tidak terbatas pada langkah-langkah berikut: tingkatkan keamanan akun dan kata sandi Anda, batasi port yang diekspos, autentikasi panggilan API, periksa daftar putih atau aturan grup keamanan ECS secara berkala dan larang blok CIDR yang tidak sah, atau hubungkan database ke DTS menggunakan Express Connect, VPN Gateway, atau Smart Access Gateway.

    • Setelah tugas DTS Anda selesai atau dilepaskan, kami sarankan Anda mendeteksi dan menghapus blok CIDR yang telah ditambahkan secara manual dari daftar putih instance database atau aturan grup keamanan ECS.

  8. Di pesan Create Change Tracking Account, tunggu hingga akun dibuat lalu klik Next.

    Catatan

    Langkah ini hanya diperlukan jika mesin database dari instance ApsaraDB for MySQL sumber adalah MySQL 5.5 atau MySQL 5.6. Pada langkah ini, DTS membuat akun database untuk pelacakan perubahan di instance sumber.

  9. Pilih jenis perubahan data dan objek. Select the data change types and objects

    Parameter

    Deskripsi

    Tipe Data yang Diperlukan

    • Data Updates

      DTS melacak pembaruan data dari objek yang dipilih, termasuk operasi INSERT, DELETE, dan UPDATE.

    • Schema Updates

      DTS melacak operasi buat, hapus, dan modifikasi yang dilakukan pada semua skema objek dari instance sumber. Anda harus menggunakan klien pelacakan perubahan untuk menyaring data yang diperlukan.

    Catatan
    • Jika Anda memilih database sebagai objek, DTS melacak perubahan data dari semua objek, termasuk objek baru di database.

    • Jika Anda memilih tabel sebagai objek, DTS hanya melacak perubahan data dari tabel ini. Dalam hal ini, jika Anda ingin melacak perubahan data dari tabel lain, Anda harus menambahkan tabel ke objek yang dipilih. Untuk informasi lebih lanjut, lihat Ubah objek untuk pelacakan perubahan.

    Objek yang Diperlukan

    Pilih satu atau lebih objek dari bagian Required Objects dan klik ikon Rightwards arrow untuk menambahkan objek ke bagian Selected.

    Catatan

    Anda dapat memilih tabel atau database sebagai objek untuk pelacakan perubahan.

  10. Di pojok kanan bawah halaman, klik Save and Precheck.

    Catatan
    • Sebelum memulai tugas pelacakan perubahan, DTS melakukan pra-pemeriksaan. Anda hanya dapat memulai tugas setelah melewati pra-pemeriksaan.

    • Jika tugas gagal melewati pra-pemeriksaan, Anda dapat mengklik ikon Info icon di sebelah setiap item yang gagal untuk melihat detailnya. Setelah menyelesaikan masalah berdasarkan penyebabnya, Anda dapat menjalankan pra-pemeriksaan lagi.

  11. Tutup kotak dialog Precheck setelah pesan berikut ditampilkan: The precheck is passed.

Setelah tugas pelacakan perubahan dikonfigurasi, DTS melakukan pelacakan perubahan awal, yang membutuhkan waktu sekitar 1 menit. Setelah pelacakan perubahan awal selesai, Anda dapat membuat satu atau beberapa grup konsumen untuk mengonsumsi data yang dilacak.

Apa yang harus dilakukan selanjutnya

  1. Buat Grup Konsumen

  2. Gunakan Klien Kafka untuk Mengonsumsi Data yang Dilacak

  3. Gunakan Demo SDK untuk Mengonsumsi Data yang Dilacak