Anda dapat menstreaming update change data capture (CDC) dari set replika MongoDB yang dikelola sendiri atau cluster yang di-sharding ke tujuan yang didukung, seperti BigQuery atau Cloud Storage, menggunakan Datastream. Untuk menyiapkan sumber, Anda
membuat pengguna Datastream dengan hak istimewa baca di database admin
untuk deployment Anda.
Kumpulan replika
Untuk mengetahui informasi tentang cara men-deploy set replika MongoDB, lihat Men-deploy set replika yang dikelola sendiri dalam dokumentasi MongoDB.
Untuk mengonfigurasi Datastream agar dapat digunakan dengan set replika MongoDB yang dikelola mandiri, ikuti langkah-langkah berikut:
- Instal Shell MongoDB. Untuk mengetahui informasi tentang cara menginstal MongoDB Shell, lihat Menginstal mongosh.
- Buka jendela terminal, dan jalankan perintah
mongoshuntuk terhubung ke set replika atau node utama Anda. Buat pengguna untuk Datastream di database
admin:use admin db.createUser({ user: "USERNAME", pwd: "PASSWORD", roles: [ "readAnyDatabase", {role: "read", db: "admin"} ] })Ganti USERNAME dan PASSWORD dengan nama pengguna dan sandi pilihan Anda.
Cluster yang di-sharding
Untuk mengetahui informasi tentang cara men-deploy cluster yang di-sharding, lihat Men-deploy cluster yang di-sharding dalam dokumentasi MongoDB.
Untuk mengonfigurasi Datastream agar dapat digunakan dengan cluster sharding MongoDB yang dikelola sendiri, ikuti langkah-langkah berikut:
- Instal Shell MongoDB. Untuk mengetahui informasi tentang cara menginstal MongoDB Shell, lihat Menginstal mongosh.
- Buka jendela terminal, dan jalankan perintah
mongoshuntuk terhubung ke cluster sharded MongoDB Anda. Buat pengguna Datastream di setiap node shard utama dan router kueri
mongos:use admin db.createUser({ user: "USERNAME", pwd: "PASSWORD", roles: [ "readAnyDatabase" ] })Ganti USERNAME dan PASSWORD dengan nama pengguna dan sandi Anda. Anda dapat memilih nama pengguna dan sandi apa pun, tetapi harus sama di semua node shard utama dan router kueri
mongos.Untuk mengetahui shard mana yang terhubung ke router kueri
mongos, jalankan perintah berikut:db.adminCommand({ listShards: 1 })