DataWorks:Tulis data ke sumber data MongoDB melalui sinkronisasi batch

Di DataStudio DataWorks, buat node sinkronisasi offline, lalu konfigurasikan parameter untuk sumber dan tujuan. Anda dapat menggunakan nilai default untuk parameter yang tidak dijelaskan dalam langkah-langkah berikut. Untuk informasi lebih lanjut, lihat Konfigurasi task sinkronisasi di Antarmuka tanpa kode.

1. Konfigurasikan koneksi jaringan untuk task sinkronisasi.

   Pilih sumber data MongoDB dan MaxCompute yang telah Anda buat, pilih grup sumber daya eksklusif untuk Data Integration yang telah dikonfigurasi, lalu uji koneksi jaringan.

2. Konfigurasikan task: Pilih sumber data.

   Pilih tabel partisi MaxCompute dan koleksi MongoDB yang telah Anda siapkan.

   Parameter	Deskripsi
   Write mode (overwrite)	Menentukan apakah data akan ditimpa selama transfer. Parameter ini mencakup Write mode dan Business primary key: Write mode: Jika diatur ke No, operasi insert dilakukan untuk setiap record. Ini adalah opsi default. Jika diatur ke Yes, Anda harus menentukan Business primary key. Operasi overwrite dilakukan untuk record yang memiliki business primary key yang sama. Business primary key: Menentukan business primary key untuk setiap baris. Kunci ini digunakan dalam operasi overwrite. Anda tidak dapat menentukan multiple business primary key. Biasanya ini merujuk pada primary key di MongoDB. Catatan Jika Write mode diatur ke Yes dan bidang selain `_id` dikonfigurasi sebagai business primary key, kesalahan serupa berikut dapat terjadi saat waktu proses: After applying the update, the (immutable) field '_id' was found to have been altered to _id: "2". Hal ini terjadi karena data yang ditulis berisi record di mana `_id` tidak sesuai dengan `replaceKey`. Untuk informasi lebih lanjut, lihat Error: After applying the update, the (immutable) field '_id' was found to have been altered to _id: "2".
   Pre-import statements	Konfigurasi untuk pernyataan pra-eksekusi (PreSQL). Konfigurasi ini dalam format JSON dan mencakup properti type dan json. type: **Wajib**. Nilai yang valid: remove dan drop. Perhatikan bahwa nilai harus dalam huruf kecil. json: Jika type adalah remove, properti ini **wajib**. Sintaks konfigurasi mengikuti standar MongoDB Query. Untuk informasi lebih lanjut, lihat Query Documents. Jika type adalah drop, Anda tidak perlu mengonfigurasi properti ini.

3. Konfigurasikan task: Pemetaan bidang.

   Untuk sumber data MongoDB, Same-row Mapping digunakan secara default. Anda juga dapat mengklik untuk mengedit bidang tabel sumber secara manual. Berikut adalah contoh pengeditan manual.

   {"name":"id","type":"string"}
   {"name":"col_string","type":"string"}
   {"name":"col_int","type":"long"}
   {"name":"col_bigint","type":"long"}
   {"name":"col_decimal","type":"double"}
   {"name":"col_date","type":"date"}
   {"name":"col_boolean","type":"bool"}
   {"name":"col_array","type":"array","splitter":","}

   Setelah Anda mengedit bidang secara manual, pemetaan antara bidang sumber dan tujuan akan ditampilkan di antarmuka.

Setelah konfigurasi selesai, jalankan node sinkronisasi. Setelah node berhasil dijalankan, Anda dapat melihat data yang telah disinkronkan ke koleksi MongoDB.

Jika Anda mengatur tipe ke `ARRAY`, Anda harus mengonfigurasi properti `splitter`. Hal ini mengonversi data ke tipe array di MongoDB. Contohnya:

• Data sumber berupa string: a,b,c.

• Dalam konfigurasi task sinkronisasi, atur type ke ARRAY dan `splitter` ke `,`.

• Setelah task sinkronisasi dieksekusi, data yang ditulis ke MongoDB adalah: ["a","b","c"].