All Products
Search
Document Center

Data Transmission Service:Buat saluran Langganan Data Oracle

Last Updated:Jun 11, 2026

Berlangganan data inkremental dari database Oracle yang dikelola sendiri secara real-time. Langganan Data mendukung pembaruan cache, penguraian keterkaitan asinkron, dan sinkronisasi berbasis ETL.

Prasyarat

  • Database Oracle yang dikelola sendiri harus menggunakan versi 9i, 10g, atau 11g. Instans Real Application Clusters (RAC) tidak didukung.

  • Pencatatan tambahan harus diaktifkan untuk database Oracle yang dikelola sendiri, dengan supplemental_log_data_pk dan supplemental_log_data_ui diaktifkan. Supplemental Logging.

  • Database Oracle yang dikelola sendiri harus berjalan dalam mode ARCHIVELOG dengan periode retensi log arsip yang sesuai dikonfigurasi, serta memastikan log tersebut dapat diakses. ARCHIVELOG.

Catatan penggunaan

  • Perubahan Online DDL oleh alat seperti gh-ost atau pt-online-schema-change tidak dilacak. Klien mungkin gagal menulis data yang telah 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.

Persiapan

Masuk ke database Oracle sumber dan buat akun database dengan hak istimewa DBA untuk Langganan Data.

Penting

Jika Anda perlu melacak perubahan data dari database Oracle tetapi izin administrator basis data (DBA) tidak dapat diberikan kepada akun database, Anda dapat mengaktifkan pencatatan arsip dan pencatatan tambahan, serta memberikan izin detail halus kepada akun tersebut.

  1. Aktifkan pencatatan arsip dan pencatatan tambahan.

    Type

    Procedure

    Archive logging

    Jalankan pernyataan berikut untuk mengaktifkan pencatatan arsip:

    shutdown immediate;
    startup mount;
    alter database archivelog;
    alter database open;
    archive log list;

    Supplemental logging

    Aktifkan pencatatan tambahan di tingkat database atau tabel:

    Catatan

    Anda dapat mengaktifkan pencatatan tambahan tingkat database untuk memastikan stabilitas tugas DTS. Anda juga dapat mengaktifkan pencatatan tambahan tingkat tabel untuk mengurangi penggunaan disk pada database Oracle sumber.

    • Aktifkan pencatatan tambahan tingkat database

      1. Aktifkan pencatatan tambahan minimal:

        alter database add supplemental log data;
      2. Aktifkan pencatatan tambahan kunci primer dan kunci unik di tingkat database:

        alter database add supplemental log data (primary key,unique index) columns;
    • Aktifkan pencatatan tambahan tingkat tabel

      1. Aktifkan pencatatan tambahan minimal:

        alter database add supplemental log data;
      2. Aktifkan pencatatan tambahan tingkat tabel menggunakan salah satu metode berikut:

        • Aktifkan pencatatan tambahan kunci primer di tingkat tabel:

          alter table table_name add supplemental log data (primary key) columns;
        • Aktifkan pencatatan tambahan tingkat tabel untuk semua kolom:

          alter table tb_name add supplemental log data (all) columns ;
  2. Berikan izin detail halus kepada akun database Oracle.

    Oracle Versi 9i hingga 11g

    # Buat akun database, misalnya rdsdt_dtsacct, dan berikan izin kepada akun tersebut.
    create user rdsdt_dtsacct IDENTIFIED BY rdsdt_dtsacct;
    grant create session to rdsdt_dtsacct;
    grant connect to rdsdt_dtsacct;
    grant resource to rdsdt_dtsacct;
    grant execute on sys.dbms_logmnr to rdsdt_dtsacct;
    grant select on V_$LOGMNR_LOGS to rdsdt_dtsacct;
    grant select on all_objects to rdsdt_dtsacct;
    grant select on all_tab_cols to rdsdt_dtsacct;
    grant select on dba_registry to rdsdt_dtsacct;
    grant select any table to rdsdt_dtsacct;
    grant select any transaction to rdsdt_dtsacct;
    -- v$log privileges
    grant select on v_$log to rdsdt_dtsacct;
    -- v$logfile privileges
    grant select on v_$logfile to rdsdt_dtsacct;
    -- v$archived_log privileges
    grant select on v_$archived_log to rdsdt_dtsacct;
    -- v$parameter privileges
    grant select on v_$parameter to rdsdt_dtsacct;
    -- v$database privileges
    grant select on v_$database to rdsdt_dtsacct;
    -- v$active_instances privileges
    grant select on v_$active_instances to rdsdt_dtsacct;
    -- v$instance privileges
    grant select on v_$instance to rdsdt_dtsacct;
    -- v$logmnr_contents privileges
    grant select on v_$logmnr_contents to rdsdt_dtsacct;
    -- system tables
    grant select on sys.USER$ to rdsdt_dtsacct;
    grant select on SYS.OBJ$ to rdsdt_dtsacct;
    grant select on SYS.COL$ to rdsdt_dtsacct;
    grant select on SYS.IND$ to rdsdt_dtsacct;
    grant select on SYS.ICOL$ to rdsdt_dtsacct;
    grant select on SYS.CDEF$ to rdsdt_dtsacct;
    grant select on SYS.CCOL$ to rdsdt_dtsacct;
    grant select on SYS.TABPART$ to rdsdt_dtsacct;
    grant select on SYS.TABSUBPART$ to rdsdt_dtsacct;
    grant select on SYS.TABCOMPART$ to rdsdt_dtsacct;

Prosedur

  1. Beli saluran Langganan Data. Proses pembelian.

    Catatan

    Pada halaman pembelian, atur Subscription Instance Type ke Oracle dan pilih wilayah instans sumber.

  2. Masuk ke DTS console.

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

  4. Di bagian atas halaman Data Subscription, pilih wilayah saluran langganan.

  5. Temukan saluran Langganan Data yang telah dibeli dan klik Configure Subscription Channel.

  6. Konfigurasikan database sumber dan jenis jaringan.

    Configure source database and network type

    Category

    Parameter

    Description

    N/A

    Subscription name

    DTS menghasilkan nama secara otomatis. Gunakan nama deskriptif agar lebih mudah diidentifikasi. Tidak perlu unik.

    Source database information

    Instance type

    Pilih tipe instans sumber. Contoh ini menggunakan User-Created Database with Public IP.

    Catatan

    Jika database yang dikelola sendiri Anda memiliki tipe instans berbeda, Anda mungkin perlu menyelesaikan persiapan tambahan. Untuk informasi selengkapnya, lihat Preparations for data migration.

    Database type

    Otomatis diisi sebagai Oracle. Tidak dapat diubah.

    Instance region

    Source Instance Region yang dipilih saat pembelian. Tidak dapat diubah.

    ECS instance ID

    Pilih Instance ECS yang menjalankan database Oracle yang dikelola sendiri Anda.

    Port

    Port layanan dari database Oracle yang dikelola sendiri.

    SID

    SID dari database Oracle yang dikelola sendiri.

    Database account

    Akun database dari database Oracle yang dikelola sendiri.

    Catatan

    Ikuti Persiapan untuk membuat dan mengonfigurasi akun ini.

    Database password

    Masukkan password akun database.

    Consumption network type

    N/A

    Jenis jaringan untuk saluran Langganan Data.

    Catatan
    • Pilih jenis jaringan yang sama dengan Instance ECS tempat klien langganan Anda ditempatkan. Misalnya, jika Instance ECS berada di VPC, pilih VPC sebagai jenis jaringan dan tentukan Proprietary Network dan vSwitch.

    • Koneksi jaringan privat meminimalkan latensi.

    • 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?.

  7. Klik Authorize Whitelist and Proceed to Next Step.

    DTS menambahkan Blok CIDR servernya ke konfigurasi database sumber. Untuk instans Alibaba Cloud seperti ApsaraDB RDS for MySQL atau ApsaraDB for MongoDB, Blok CIDR ditambahkan ke daftar putih instans. Untuk database yang dikelola sendiri di ECS, DTS menambahkan Blok CIDR ke aturan grup keamanan, tetapi Anda juga harus menambahkannya ke daftar putih database. CIDR blocks 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 langganan.

    Select data types and subscription objects

    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. Filter data yang diperlukan di aplikasi klien Anda.

    Catatan
    • Memilih seluruh database juga melacak perubahan pada objek yang ditambahkan nanti.
    • Memilih tabel tertentu hanya akan melacak tabel tersebut. Untuk melacak tabel baru, tambahkan tabel tersebut ke objek langganan. Ubah objek untuk pelacakan perubahan.
    Required objects

    Di kotak Required Objects, pilih objek yang akan dilacak dan klik ikon untuk memindahkannya ke kotak Selected Objects.

    Catatan Anda dapat memilih objek di tingkat database atau tabel.
  9. Di pojok kanan bawah halaman, klik Save and Precheck.

    Catatan
    • DTS menjalankan pemeriksaan awal sebelum tugas langganan dimulai. Tugas hanya akan dimulai setelah pemeriksaan awal berhasil.

    • Jika pemeriksaan awal gagal, klik ikon Prompt di samping item yang gagal untuk melihat detailnya. Perbaiki masalah tersebut dan jalankan ulang pemeriksaan awal.

  10. Setelah Precheck Passed muncul di kotak dialog Precheck, tutup kotak dialog Precheck.

    Saluran Langganan Data memasuki tahap inisialisasi, yang biasanya memakan waktu sekitar satu menit. Setelah inisialisasi selesai, buat kelompok konsumen dan mulai mengonsumsi data langganan.

Langkah selanjutnya

  1. Buat kelompok konsumen

  2. Gunakan klien Kafka untuk mengonsumsi data langganan

  3. Gunakan kode contoh SDK untuk mengonsumsi data langganan