Meneruskan argumen runtime ke tugas Replikasi

Halaman ini menjelaskan cara meneruskan argumen runtime dalam tugas replikasi Cloud Data Fusion.

Sebelum memulai

• Membuat tugas replikasi di instance Cloud Data Fusion. Untuk informasi selengkapnya, lihat Memulai Replikasi.

Meneruskan argumen Debezium ke tugas replikasi

Untuk meneruskan argumen Debezium ke tugas replikasi MySQL atau SQL Server di Cloud Data Fusion, tentukan argumen runtime yang diawali dengan source.connector.

Konsol

1. Buka instance Anda:

   1. Di konsol Google Cloud, buka halaman Cloud Data Fusion.

   2. Untuk membuka instance di antarmuka web Cloud Data Fusion, klik Instance, lalu klik View instance.

      Buka Instance

2. Klik Menu > Control Center.

3. Temukan Application untuk tugas replikasi, lalu klik Preferences. Jendela Preferences akan terbuka.

4. Di kolom Key, tentukan argumen runtime untuk tugas replikasi dengan mengawalinya dengan source.connector.

   

5. Klik Simpan & Tutup.

REST API

Untuk menetapkan argumen runtime menggunakan REST API, baca referensi Microservice Preferensi CDAP.

Mengonfigurasi parameter JDBC

Untuk meneruskan parameter JDBC ke tugas replikasi MySQL atau SQL Server, tentukan argumen runtime yang diawali dengan source.connector.database.

Misalnya, untuk mengonfigurasi parameter JDBC sessionVariables ke MAX_EXECUTION_TIME=43200000, tetapkan argumen runtime dengan kunci source.connector.database.sessionVariables dan nilai MAX_EXECUTION_TIME=43200000.

Untuk mengonfigurasi beberapa parameter JDBC, tetapkan argumen runtime untuk setiap parameter. Misalnya, untuk mengonfigurasi parameter JDBC encrypt=true&trustServerCertificate=true, teruskan argumen berikut:

Kunci	Nilai
source.connector.database.encrypt	true
source.connector.database.trustServerCertificate	true

Catatan: Cloud Data Fusion tidak mendukung penyetelan argumen JDBC selama penyiapan atau penilaian tugas replikasi. Jika Anda harus menetapkan parameter JDBC untuk menyelesaikan masalah penilaian, lewati penilaian dengan men-deploy tugas replikasi melalui Replication API. Kemudian, sebelum memulai tugas, konfigurasikan argumen JDBC seperti yang dijelaskan sebelumnya di bagian ini.

Mengonfigurasi parameter kunci utama

Tabel sumber yang direplikasi harus memiliki {i>primary key<i}. Ini adalah persyaratan ketat hanya jika Oracle adalah database sumber. Untuk sumber SQL Server dan MySQL, Anda dapat menentukan kunci utama kustom, meskipun tabel sumber tidak memilikinya.

Tetapkan parameter key dengan argumen runtime berikut:

source.connector.message.key.columns = SCHEMA.TABLE:KEY_COLUMN

Ganti kode berikut:

• SCHEMA: Nama skema sumber.
• TABLE: Nama tabel sumber.
• KEY_COLUMN: Kolom yang berisi kunci aman.

Anda dapat menetapkan kunci utama untuk beberapa tabel dengan properti key. Contoh berikut menunjukkan cara menetapkan kunci untuk tabel inventory.customers dan purchase.orders:

source.connector.message.key.columns = inventory.customers:pk1,pk2;purchase.orders:pk3,pk4

Mengonfigurasi mode isolasi untuk snapshot dalam replikasi SQL Server

Untuk mengetahui informasi selengkapnya tentang argumen runtime untuk mode isolasi, lihat Tingkat isolasi dalam replikasi SQL Server.

Langkah selanjutnya

• Pelajari Replikasi di Cloud Data Fusion lebih lanjut.
• Lihat referensi Replikasi API.
• Ikuti tutorial untuk Mereplikasi data dari MySQL ke BigQuery.
• Ikuti tutorial untuk Mereplikasi data dari SQL Server ke BigQuery.
• Ikuti tutorial Mereplikasi data dari Oracle ke BigQuery.