Halaman ini menjelaskan cara mengubah skema di Cloud Data Fusion saat Anda mereplikasi data dari database Microsoft SQL Server ke tabel BigQuery. Untuk memastikan tugas replikasi terus mereplikasi data dari sumber SQL Server setelah skema berubah, lakukan langkah-langkah berikut.
Sebelum memulai
- Membuat tugas replikasi di Cloud Data Fusion. Untuk mengetahui informasi selengkapnya, lihat Memulai Replikasi.
Mengubah skema
Buka instance Anda:
Di konsol Google Cloud, buka halaman Cloud Data Fusion.
Untuk membuka instance di antarmuka web Cloud Data Fusion, klik Instance, lalu klik View instance.
Di antarmuka web Cloud Data Fusion, klik Replikasi.
Hentikan tugas replikasi.
Terapkan perubahan skema yang didukung ke tabel sumber, seperti Tambahkan kolom nullable.
Buat tabel pengambilan baru menggunakan prosedur
sys.sp_cdc_enable_table
dengan nilai unik untuk parameter@capture_instance
.Terapkan perubahan skema yang sama pada tabel target di BigQuery.
Mulai ulang tugas replikasi.
Opsional: Saat tugas mulai melakukan streaming perubahan baru yang terjadi setelah Anda menghentikan tugas, Anda dapat menghapus tabel pengambilan lama menggunakan prosedur tersimpan
sys.sp_cdc_disable_table
. Tetapkan parameter@capture_instance
ke nama instance pengambilan lama.
Setelah Anda menerapkan perubahan skema pada tabel sumber dan sebelum membuat tabel tangkapan baru (seperti yang Anda lakukan pada langkah sebelumnya), semua perubahan akan direkam oleh tangkapan lama dengan skema lama. Jika Anda menambahkan kolom, peristiwa perubahan apa pun selama waktu tersebut tidak berisi data untuk kolom baru. Jika aplikasi Anda tidak dapat menangani transisi tersebut, ikuti langkah-langkah berikut:
Menangguhkan semua aplikasi yang membuat record database.
Pastikan tugas replikasi telah memproses semua peristiwa yang ada.
Hentikan tugas replikasi.
Terapkan perubahan skema ke tabel sumber, seperti Tambahkan kolom nullable.
Buat tabel pengambilan baru menggunakan prosedur
sys.sp_cdc_enable_table
dengan nilai unik untuk parameter@capture_instance
.Lanjutkan aplikasi yang Anda tangguhkan pada langkah pertama.
Terapkan perubahan skema yang sama pada tabel target di BigQuery.
Mulai ulang tugas replikasi.
Opsional: Saat tugas mulai melakukan streaming perubahan baru yang terjadi setelah Anda membuat tabel tangkapan baru di langkah sebelumnya, Anda dapat menghapus tabel tangkapan lama menggunakan prosedur tersimpan
sys.sp_cdc_disable_table
. Tetapkan parameter@capture_instance
ke nama instance pengambilan lama.
Langkah selanjutnya
- Pelajari lebih lanjut Replikasi.
- Lihat perubahan skema yang didukung.
- Lihat Replication API.
- Pelajari cara menautkan ke penyelesaian tugas terkait.