Layanan Transmisi Data (DTS) menyinkronkan data dari ApsaraDB for MongoDB (replica set atau kluster sharded) ke Lindorm (mesin wide-column). Layanan ini stabil, hemat biaya, dan mudah digunakan, serta menawarkan konkurensi tinggi dan latensi rendah, sehingga ideal untuk berbagai kasus penggunaan seperti metadata, pesanan, tagihan, profil, dan jejaring sosial.
Prasyarat
Instans ApsaraDB for MongoDB sumber harus berada di wilayah Jerman (Frankfurt).
Instans ApsaraDB for MongoDB sumber harus memiliki arsitektur replica set atau kluster sharded.
PentingJika instans ApsaraDB for MongoDB sumber memiliki arsitektur kluster sharded, Anda harus memperoleh titik akhir untuk setiap node shard dan memverifikasi bahwa semua node shard menggunakan akun dan kata sandi yang sama. Untuk informasi lebih lanjut, lihat Ajukan titik akhir shard.
Buat instans Lindorm target yang menggunakan mesin tabel lebar dan memiliki kapasitas penyimpanan lebih besar daripada instans ApsaraDB for MongoDB sumber. Untuk informasi lebih lanjut, lihat Buat instans.
CatatanKapasitas penyimpanan instans target harus setidaknya 10% lebih besar daripada ruang penyimpanan yang digunakan oleh database sumber.
Buat tabel lebar di instans Lindorm sesuai kebutuhan bisnis. Untuk petunjuknya, lihat Hubungkan ke dan gunakan LindormTable dengan Lindorm-cli atau Hubungkan ke LindormTable dengan Lindorm Shell.
CatatanSemua objek yang Anda buat harus mematuhi Kuota dan batasan.
Jika Anda membuat tabel lebar di Lindorm menggunakan Apache HBase, kami menyarankan menambahkan pemetaan kolom ke tabel tersebut. Untuk informasi lebih lanjut, lihat Contoh penambahan pemetaan kolom untuk tabel yang dibuat dengan memanggil API Apache HBase.
Peringatan
Jenis | Deskripsi |
Batasan database sumber |
|
Batasan lainnya |
|
Penagihan
Jenis sinkronisasi | Biaya konfigurasi tugas |
Sinkronisasi data penuh | Gratis. |
Sinkronisasi data inkremental | Dikenakan biaya. Untuk informasi lebih lanjut, lihat ikhtisar penagihan. |
Jenis sinkronisasi
Jenis | Deskripsi |
Sinkronisasi data penuh | Memindahkan semua data yang ada di objek yang dipilih dari instans ApsaraDB for MongoDB sumber ke instans Lindorm tujuan. Catatan Sinkronisasi data penuh didukung untuk database dan koleksi. |
Sinkronisasi data inkremental | Menyinkronkan perubahan data berkelanjutan dari instans ApsaraDB for MongoDB sumber ke instans Lindorm tujuan setelah sinkronisasi data penuh awal. Catatan
|
Izin akun database
Database | Izin | Aksi |
Sumber ApsaraDB for MongoDB | Izin baca pada database sumber, admin, dan local. | |
Target Lindorm | Izin baca dan tulis pada namespace tujuan. |
Jika Anda menggunakan ChangeStream sebagai metode sinkronisasi inkremental, akun database sumber memerlukan izin baca Change Streams tingkat instans (seperti readAnyDatabase). Jika sumbernya adalah instans ApsaraDB for MongoDB dengan akun kustom, Anda juga harus memberikan izin baca akun tersebut pada database admin. Untuk detailnya, lihat Izin akun root yang ditentukan saat pembuatan instans.
Prosedur
-
Buka halaman daftar tugas sinkronisasi di wilayah tujuan. Anda dapat menggunakan salah satu dari dua metode berikut:
Dari Konsol DTS
-
Masuk ke Konsol Data Transmission Service (DTS).
-
Di panel navigasi kiri, klik Data Synchronization.
-
Di pojok kiri atas halaman, pilih wilayah tempat instans sinkronisasi berada.
Dari Konsol DMS
CatatanOperasi aktual dapat berbeda tergantung pada mode dan tata letak Konsol DMS. Untuk informasi lebih lanjut, lihat Mode sederhana dan Sesuaikan tata letak dan gaya antarmuka DMS.
-
Masuk ke Data Management (DMS).
-
Di bilah menu atas, pilih .
-
Di sebelah kanan Data Synchronization Tasks, pilih wilayah tempat instans sinkronisasi berada.
-
-
Klik Create Task untuk membuka halaman konfigurasi tugas.
Konfigurasikan database sumber dan tujuan.
Kategori
Parameter
Deskripsi
N/A
Task Name
DTS secara otomatis menghasilkan nama tugas. Kami menyarankan Anda menentukan nama deskriptif agar mudah diidentifikasi. Nama ini tidak harus unik.
Source Database
Select Existing Connection
-
Untuk menggunakan instans database yang telah ditambahkan ke sistem (baru dibuat atau disimpan), pilih instans database dari daftar drop-down. Informasi database akan dikonfigurasi secara otomatis.
CatatanDi Konsol DMS, item konfigurasi ini bernama Select a DMS database instance..
-
Jika Anda belum menambahkan instans database ke sistem, atau tidak perlu menggunakan instans yang sudah ditambahkan, konfigurasikan informasi database berikut secara manual.
Database Type
Pilih MongoDB.
Access Method
Pilih Alibaba Cloud Instance.
Instance Region
Pilih wilayah tempat instans ApsaraDB for MongoDB sumber berada.
Replicate Data Across Alibaba Cloud Accounts
Contoh ini menunjukkan cara menyinkronkan data dalam satu Akun Alibaba Cloud. Pilih No.
Architecture
Dalam contoh ini, pilih Replica Set.
CatatanJika instans ApsaraDB for MongoDB sumber adalah Sharded Cluster, Anda juga harus menentukan Shard account dan Shard password.
Migration Method
Pilih metode untuk sinkronisasi data inkremental berdasarkan kebutuhan Anda.
-
Oplog (Direkomendasikan):
Opsi ini tersedia jika Oplog diaktifkan untuk database sumber.
CatatanOplog diaktifkan secara default untuk database MongoDB yang dikelola sendiri dan instans ApsaraDB for MongoDB. Metode ini menawarkan latensi lebih rendah untuk tugas sinkronisasi inkremental karena log diambil lebih cepat. Kami menyarankan memilih Oplog.
-
ChangeStream:
Opsi ini tersedia jika Change Streams diaktifkan untuk database sumber.
Catatan-
Jika database sumber adalah instans Amazon DocumentDB (klaster non-elastis), Anda hanya dapat memilih ChangeStream.
-
Jika Anda mengatur Architecture database sumber ke Sharded Cluster, Anda tidak perlu menentukan Shard account dan Shard password.
-
Instance ID
Pilih ID instans ApsaraDB for MongoDB sumber.
Authentication Database
Masukkan nama database autentikasi untuk instans ApsaraDB for MongoDB sumber. Nilai default-nya adalah admin.
Database Account
Masukkan akun database untuk instans ApsaraDB for MongoDB sumber Anda. Untuk informasi tentang izin yang diperlukan, lihat Izin yang diperlukan untuk akun database.
Database Password
Masukkan kata sandi yang sesuai dengan akun database.
Encryption
DTS mendukung tiga metode koneksi: Non-encrypted, SSL-encrypted, dan Mongo Atlas SSL. Opsi untuk Encryption bervariasi berdasarkan Access Method dan Architecture yang dipilih. Opsi yang ditampilkan di konsol berlaku.
Catatan-
Database MongoDB dengan Architecture Sharded Cluster dan Migration Method Oplog tidak mendukung SSL-encrypted.
-
Jika sumbernya adalah database MongoDB yang dikelola sendiri (Access Method bukan Alibaba Cloud Instance) dengan arsitektur Replica Set, dan Anda memilih SSL-encrypted, DTS juga memungkinkan Anda mengunggah sertifikat CA untuk memverifikasi koneksi.
Destination Database
Select Existing Connection
-
Untuk menggunakan instans database yang telah ditambahkan ke sistem (baru dibuat atau disimpan), pilih instans database dari daftar drop-down. Informasi database akan dikonfigurasi secara otomatis.
CatatanDi Konsol DMS, item konfigurasi ini bernama Select a DMS database instance..
-
Jika Anda belum menambahkan instans database ke sistem, atau tidak perlu menggunakan instans yang sudah ditambahkan, konfigurasikan informasi database berikut secara manual.
Database Type
Pilih Lindorm.
Access Method
Pilih Alibaba Cloud Instance.
Instance Region
Pilih wilayah tempat instans Lindorm tujuan berada.
Instance ID
Pilih ID instans Lindorm tujuan.
Database Account
Masukkan akun database untuk instans Lindorm tujuan. Untuk informasi tentang izin yang diperlukan, lihat Izin yang diperlukan untuk akun database.
Database Password
Masukkan kata sandi yang sesuai dengan akun database.
-
-
Setelah menyelesaikan konfigurasi, klik Test Connectivity and Proceed di bagian bawah halaman.
Catatan-
Pastikan blok CIDR alamat IP server DTS telah ditambahkan ke pengaturan keamanan database sumber dan tujuan untuk mengizinkan akses dari server DTS. Hal ini dapat dilakukan secara otomatis atau manual. Untuk informasi lebih lanjut, lihat Tambahkan blok CIDR alamat IP server DTS ke daftar putih.
-
Jika database sumber atau tujuan adalah database yang dikelola sendiri (di mana Access Method bukan Alibaba Cloud Instance), Anda juga harus mengklik Test Connectivity di kotak dialog CIDR Blocks of DTS Servers.
-
Konfigurasikan objek tugas.
Di halaman Configure Objects, konfigurasikan objek yang akan disinkronkan.
Parameter
Deskripsi
Synchronization Types
Incremental Data Synchronization dipilih. Anda hanya dapat memilih Full Data Synchronization. Schema Synchronization tidak didukung. Setelah Pemeriksaan Awal selesai, DTS menyinkronkan data objek yang dipilih dari instans sumber ke kluster tujuan. Ini berfungsi sebagai data garis dasar untuk sinkronisasi data inkremental berikutnya.
Processing Mode of Conflicting Tables
Tidak perlu konfigurasi. Anda dapat mempertahankan pengaturan default.
Capitalization of Object Names in Destination Instance
Anda dapat mengonfigurasi kebijakan sensitivitas huruf besar/kecil untuk nama objek database dan koleksi dalam bahasa Inggris yang disinkronkan ke instans tujuan. Anda dapat memilih DTS default policy, yang merupakan opsi default, atau menggunakan kebijakan default database sumber atau tujuan. Untuk informasi lebih lanjut, lihat Kebijakan sensitivitas huruf besar/kecil untuk nama objek tujuan.
Source Objects
Di kotak Source Objects, klik objek yang akan disinkronkan, lalu klik
untuk memindahkannya ke kotak Selected Objects.CatatanAnda dapat memilih objek pada tingkat koleksi.
Selected Objects
Jika Anda menggunakan Lindorm SQL untuk membuat tabel lebar di database tujuan, Anda harus mengonfigurasi kolom tambahan untuk sinkronisasi. Kolom yang tidak dikonfigurasi tidak akan disinkronkan.
Edit pemetaan nama database.
Di kotak Selected Objects, klik kanan database yang berisi koleksi yang ingin disinkronkan.
Ubah Schema Name menjadi nama database tujuan di Lindorm.
Di kotak dialog yang muncul, pilih operasi DML yang akan disinkronkan (insert, update, dan delete). Di bagian Additional Columns, klik + New Column untuk menambahkan kolom. Lalu, klik OK.
Opsional: Di bagian Select DML Operations to Be Synchronized, pilih operasi inkremental yang ingin disinkronkan.
Klik OK.
Edit pemetaan nama tabel.
Di kotak Selected Objects, klik kanan koleksi yang ingin disinkronkan.
Ubah Table Name menjadi nama tabel tujuan di Lindorm.
Di kotak dialog Edit Table, Anda juga dapat mengatur Filter Conditions. Sintaks kondisi filter ApsaraDB for MongoDB berbeda dari klausa WHERE SQL standar. Di bagian Select DML Operations to Be Synchronized, pilih insert, update, dan delete. Di bagian Additional Columns, klik + New Column untuk menambahkan kolom ke tabel tujuan untuk tujuan seperti manajemen metadata, pengurutan, atau deduplikasi. Setelah menyelesaikan pengaturan, klik OK.
Opsional: Atur kondisi filter. Untuk informasi lebih lanjut, lihat Atur kondisi filter.
Opsional: Di bagian Select DML Operations to Be Synchronized, pilih operasi inkremental yang ingin disinkronkan.
Konfigurasikan bidang MongoDB yang akan disinkronkan.
Secara default, DTS memetakan data koleksi yang akan disinkronkan dan mengonfigurasi ekspresi di kolom Parameter Value. Anda harus memeriksa apakah ekspresi tersebut memenuhi kebutuhan Anda dan menentukan informasi seperti Column Name, Type, Length, dan Precision.
Di kolom Parameter Value, lihat nama bidang di MongoDB dalam ekspresi
bson_value().Konten yang diapit oleh
""adalah nama bidang di MongoDB. Misalnya, jika ekspresinya adalahbson_value("age"), baris ini sesuai dengan bidangagedi MongoDB.Opsional: Hapus bidang yang tidak ingin disinkronkan.
CatatanUntuk menghapus bidang yang tidak ingin disinkronkan, klik ikon
di baris yang sesuai.Konfigurasikan bidang yang akan disinkronkan.
Lakukan langkah-langkah berikut berdasarkan apakah ekspresi
bson_value()memenuhi kebutuhan Anda.Ekspresi yang cocok
Masukkan Column Name.
CatatanIni adalah nama kolom tujuan di tabel Lindorm.
Jika tabel tujuan dibuat menggunakan SQL, masukkan nama kolom di tabel Lindorm untuk parameter Column Name.
Jika tabel tujuan dibuat menggunakan HBase dan Anda perlu menggunakan fitur tambah kolom, Anda harus menambahkan pemetaan kolom sebelum mengubah nama kolom. Untuk informasi lebih lanjut, lihat Contoh penambahan pemetaan kolom untuk tabel HBase. Konfigurasikan Column Name sebagai berikut:
Jika kolom adalah kunci primer, masukkan ROW.
Jika kolom bukan kunci primer, gunakan format column_family:column_name, seperti person:name.
Pilih Type data untuk kolom tersebut.
PentingPastikan tipe data tabel tujuan kompatibel dengan data di database MongoDB sumber.
Opsional: Konfigurasikan Length dan Precision untuk data kolom.
Ulangi langkah-langkah ini untuk memetakan semua bidang yang relevan.
Ekspresi yang tidak cocok
CatatanMisalnya, bidang yang memiliki struktur hierarkis (parent-child).
Di kolom Actions, klik ikon
di baris yang sesuai.Klik + New Column. Di bagian Additional Columns, klik tombol + New Column di pojok kanan atas.
Konfigurasikan Column Name, Type, Length, dan Precision.
Di kotak teks di bawah Parameter Value, masukkan ekspresi
bson_value(). Untuk informasi lebih lanjut, lihat Contoh penugasan nilai.PentingNilai
bson_value("_id")harus ditugaskan ke kolom kunci primer tabel tujuan.Saat mengonfigurasi ekspresi
bson_value(), Anda harus menentukan jalur hingga subfield tingkat terendah dalam hierarki. Jika tidak, kehilangan data dapat terjadi atau tugas mungkin gagal.
Ulangi langkah-langkah ini untuk memetakan semua bidang yang relevan.
Klik OK.
Klik Next: Advanced Settings untuk mengonfigurasi parameter lanjutan.
Parameter
Deskripsi
Dedicated Cluster for Task Scheduling
Secara default, DTS menjadwalkan tugas pada kluster bersama, dan Anda tidak perlu memilih kluster. Untuk kinerja yang lebih stabil, Anda dapat membeli kluster khusus untuk menjalankan tugas sinkronisasi DTS. Untuk informasi lebih lanjut, lihat Apa itu kluster khusus DTS?.
Retry Time for Failed Connections
Setelah tugas sinkronisasi dimulai, jika koneksi ke database sumber atau tujuan gagal, DTS melaporkan error dan segera mulai mencoba koneksi ulang. Durasi percobaan ulang default adalah 720 menit. Anda juga dapat menentukan durasi percobaan ulang kustom dari 10 hingga 1.440 menit. Kami menyarankan Anda mengatur durasi minimal 30 menit. Jika DTS berhasil terhubung kembali ke database dalam durasi yang ditentukan, tugas sinkronisasi akan dilanjutkan secara otomatis. Jika tidak, tugas akan gagal.
Catatan-
Jika Anda memiliki beberapa instans DTS (misalnya, Instans A dan Instans B) yang berbagi sumber atau tujuan yang sama, dan Anda mengatur waktu percobaan ulang jaringan menjadi 30 menit untuk Instans A dan 60 menit untuk Instans B, durasi yang lebih pendek yaitu 30 menit akan digunakan untuk keduanya.
-
Karena DTS mengenakan biaya untuk waktu proses tugas selama periode percobaan ulang koneksi, kami menyarankan Anda menyesuaikan durasi percobaan ulang berdasarkan kebutuhan bisnis Anda atau segera melepas instans DTS setelah instans database sumber dan tujuan dilepas.
Retry Time for Other Issues
Setelah tugas sinkronisasi dimulai, jika terjadi masalah non-konektivitas lainnya pada database sumber atau tujuan (seperti exception eksekusi DDL atau DML), DTS melaporkan error dan segera mulai melakukan operasi percobaan ulang terus-menerus. Durasi percobaan ulang default adalah 10 menit. Anda juga dapat menyesuaikan durasi percobaan ulang dalam rentang 1 hingga 1.440 menit. Kami menyarankan Anda mengaturnya minimal 10 menit. Jika operasi terkait berhasil dalam durasi percobaan ulang yang ditetapkan, tugas sinkronisasi akan dilanjutkan secara otomatis. Jika tidak, tugas akan gagal.
PentingNilai untuk Retry Time for Other Issues harus lebih kecil daripada Retry Time for Failed Connections.
Enable Throttling for Full Data Synchronization
Selama tahap sinkronisasi penuh, DTS mengonsumsi sumber daya baca dan tulis dari database sumber dan tujuan, yang dapat meningkatkan beban database. Untuk mengurangi beban pada database sumber dan tujuan, Anda dapat mengatur batas laju untuk tugas sinkronisasi penuh dengan mengonfigurasi parameter Queries per second (QPS) to the source database, RPS of Full Data Migration, dan Data migration speed for full migration (MB/s).
Catatan-
Item konfigurasi ini hanya tersedia ketika Synchronization Types diatur ke Full Data Synchronization.
-
Anda juga dapat menyesuaikan laju sinkronisasi penuh setelah instans sinkronisasi sedang berjalan.
Only one data type for primary key _id in a table of the data to be synchronized
Tentukan apakah tipe data kunci primer
_idunik dalam setiap koleksi yang akan disinkronkan.Penting-
Pilih opsi berdasarkan data aktual Anda. Pemilihan yang salah dapat menyebabkan kehilangan data.
-
Parameter ini hanya tersedia jika Synchronization Types mencakup Full Data Synchronization.
-
Yes: Tipe data unik. Selama fase sinkronisasi penuh, DTS tidak memindai tipe data kunci primer di data sumber. Untuk setiap koleksi, DTS hanya menyinkronkan data yang sesuai dengan satu tipe data kunci primer.
-
No: Tipe data tidak unik. Selama fase sinkronisasi penuh, DTS memindai tipe data kunci primer di data sumber dan menyinkronkan semua data.
Enable Throttling for Incremental Data Synchronization
Anda juga dapat mengatur batas laju untuk tugas sinkronisasi inkremental. Untuk mengurangi tekanan pada database tujuan, atur RPS of Incremental Data Synchronization dan Data synchronization speed for incremental synchronization (MB/s).
Environment Tag
Anda dapat memilih tag lingkungan untuk mengidentifikasi instans berdasarkan kebutuhan Anda. Dalam contoh ini, tidak perlu pemilihan.
Configure ETL
Pilih apakah akan mengaktifkan fitur ekstrak, transformasi, muat (ETL). Untuk informasi lebih lanjut, lihat Apa itu ETL? Nilai yang valid:
-
Yes: Mengaktifkan fitur ETL. Masukkan pernyataan pemrosesan data di editor kode. Untuk informasi lebih lanjut, lihat Konfigurasi ETL dalam tugas migrasi data atau sinkronisasi data.
-
No: Menonaktifkan fitur ETL.
CatatanJika tabel tujuan dibuat menggunakan HBase, perhatikan hal berikut:
Sintaks ETL mencakup kolom yang akan dikonfigurasi dan kolom yang akan dikecualikan. Selama sinkronisasi, semua bidang tingkat atas dokumen MongoDB yang dikonfigurasi ETL-nya disimpan di family kolom default f tabel HBase. Contoh berikut menunjukkan cara menulis semua elemen kecuali dua elemen tingkat atas _id dan name sebagai kolom dinamis ke tabel tujuan. Untuk informasi lebih lanjut, lihat Contoh sinkronisasi tabel HBase (ETL).
script:e_expand_bson_value("*", "_id,name")Jika Anda perlu menggunakan fitur kolom baru dan fitur ETL secara bersamaan, pastikan data di Lindorm tidak duplikat.
Kolom yang tidak dikonfigurasi baik dengan fitur kolom baru maupun fitur ETL tidak akan disinkronkan ke database tujuan.
Monitoring and Alerting
Tentukan apakah akan mengonfigurasi peringatan. Jika sinkronisasi gagal atau latensi melebihi ambang batas yang ditentukan, notifikasi akan dikirim ke kontak peringatan.
-
No: Tidak ada peringatan yang dikonfigurasi.
-
Yes: Konfigurasikan peringatan dengan mengatur ambang batas peringatan dan menentukan pemberitahuan peringatan. Untuk informasi lebih lanjut, lihat Konfigurasi pemantauan peringatan selama konfigurasi tugas.
-
-
Simpan tugas dan jalankan pemeriksaan awal.
-
Untuk melihat parameter API untuk mengonfigurasi instans ini, arahkan kursor ke tombol Next: Save Task Settings and Precheck dan klik Preview OpenAPI parameters di gelembung.
-
Jika Anda telah selesai melihat parameter API, klik Next: Save Task Settings and Precheck di bagian bawah halaman.
Catatan-
Sebelum pekerjaan sinkronisasi dimulai, DTS menjalankan pemeriksaan awal. Pekerjaan hanya dapat dimulai setelah semua item pemeriksaan awal lolos.
-
Jika pemeriksaan awal gagal, klik View Details untuk item yang gagal. Perbaiki masalah sesuai petunjuk, lalu jalankan pemeriksaan awal lagi.
-
Jika pemeriksaan awal mengembalikan peringatan:
-
Jika item pemeriksaan gagal dan tidak dapat diabaikan, klik View Details di sebelah item tersebut. Ikuti petunjuk untuk memperbaiki masalah, lalu jalankan pemeriksaan awal lagi.
-
Untuk item pemeriksaan yang dapat diabaikan, Anda dapat mengklik Confirm Alert Details, Ignore, OK, dan Precheck Again secara berurutan untuk melewati peringatan dan menjalankan pemeriksaan awal lagi. Jika Anda memilih untuk mengabaikan item peringatan, hal ini dapat menyebabkan masalah seperti ketidakkonsistenan data dan menimbulkan risiko bagi bisnis Anda.
-
-
Beli instans.
-
Saat Success Rate mencapai 100%, klik Next: Purchase Instance.
-
Di halaman Purchase, pilih metode penagihan dan spesifikasi link untuk instans sinkronisasi data. Tabel berikut menjelaskan parameter-parameter ini secara rinci.
Kategori
Parameter
Deskripsi
New Instance Class
Metode Penagihan
-
Langganan: Anda membayar saat membuat instans. Ini cocok untuk kebutuhan jangka panjang dan lebih hemat biaya daripada bayar sesuai penggunaan. Semakin lama durasi langganan, semakin tinggi diskonnya.
-
Bayar sesuai penggunaan: Anda dikenai biaya per jam. Ini cocok untuk kebutuhan jangka pendek. Anda dapat melepas instans segera setelah digunakan untuk menghemat biaya.
Konfigurasi Kelompok Sumber Daya
Kelompok sumber daya tempat instans tersebut berada. Default-nya adalah kelompok sumber daya default. Untuk informasi lebih lanjut, lihat Apa itu Manajemen Sumber Daya?.
Spesifikasi Link
DTS menyediakan spesifikasi sinkronisasi dengan tingkat kinerja berbeda. Spesifikasi link sinkronisasi memengaruhi laju sinkronisasi. Anda dapat memilih spesifikasi berdasarkan skenario bisnis Anda. Untuk informasi lebih lanjut, lihat Spesifikasi link sinkronisasi data.
Durasi Langganan
Dalam mode langganan, pilih durasi dan jumlah untuk instans langganan. Anda dapat memilih langganan bulanan dari 1 hingga 9 bulan, atau langganan tahunan selama 1, 2, 3, atau 5 tahun.
CatatanOpsi ini hanya tersedia ketika metode penagihan adalah Subscription.
-
-
Setelah menyelesaikan konfigurasi, baca dan pilih Data Transmission Service (Pay-as-you-go) Service Terms.
-
Klik Buy and Start. Di kotak dialog OK, klik OK.
Anda dapat melihat progres tugas di halaman Data Synchronization.
-
Tambahkan pemetaan kolom ke tabel HBase
Contoh ini menunjukkan perintah yang dijalankan di SQL Shell.
Fitur ini memerlukan Lindorm 2.4.0 atau lebih baru.
Tambahkan pemetaan kolom ke tabel HBase.
ALTER TABLE test MAP DYNAMIC COLUMN f:_mongo_id_ HSTRING/HINT/..., person:name HSTRING, person:age HINT;Buat indeks sekunder pada tabel HBase.
CREATE INDEX idx ON test(f:_mongo_id_);
Contoh: ETL untuk tabel HBase
Dokumen MongoDB
{
"_id" : 0,
"person" : {
"name" : "cindy0",
"age" : 0,
"student" : true
}
}Pernyataan pemrosesan ETL
script:e_expand_bson_value("*", "_id")Hasil sinkronisasi
0: jdbc:lindorm:xxx> select * from mongo_test_dynamic_column limit 3;
+------+------+-------------+----------------------------------------------------------+
| ROW | COL | _mongo_id_ | person |
+------+------+-------------+----------------------------------------------------------+
| | 0 | | { "name" : "cindy0", "age" : 0, "student" : true } |
| | 1 | | { "name" : "cindy1", "age" : 1, "student" : false } |
| | 2 | | { "name" : "cindy2", "age" : 2, "student" : true } |
+------+------+-------------+----------------------------------------------------------+
3 rows selected (0.009 seconds)Contoh penugasan nilai
Struktur data ApsaraDB for MongoDB sumber
{
"_id":"62cd344c85c1ea6a2a9f****",
"person":{
"name":"neo",
"age":"26",
"sex":"male"
}
}Skema tabel Lindorm tujuan
Parameter | Tipe |
id | STRING |
person_name | STRING |
person_age | BIGINT |
Konfigurasi penugasan nilai
Anda harus menentukan jalur hierarkis lengkap dalam ekspresi bson_value() untuk mencegah kehilangan data atau kegagalan tugas. Misalnya, jika Anda mengatur ekspresi menjadi bson_value("person"), DTS tidak dapat menyinkronkan data inkremental dari subfield objek person (seperti name, age, dan sex) ke tujuan.
Parameter | Tipe | Nilai |
id | STRING | bson_value("_id") |
person_name | STRING | bson_value("person","name") |
person_age | BIGINT | bson_value("person","age") |