MongoDB (versi 2)

Konektor MongoDB memungkinkan Anda melakukan operasi penyisipan, penghapusan, pembaruan, dan baca di database MongoDB.

Versi yang didukung

  • MongoDB versi 5 dan yang lebih baru.
  • Mongo Atlas di-deploy di Google Cloud.

Sebelum memulai

Sebelum menggunakan konektor MongoDB, lakukan tugas berikut:

  • Di project Google Cloud Anda:
    • Memberikan peran IAM roles/connectors.admin kepada pengguna mengonfigurasi konektor.
    • Berikan peran IAM berikut ke akun layanan yang ingin Anda gunakan untuk konektor:
      • roles/secretmanager.viewer
      • roles/secretmanager.secretAccessor

      Akun layanan adalah jenis Akun Google khusus yang dimaksudkan untuk mewakili pengguna yang perlu mengautentikasi dan diberi otorisasi untuk mengakses data di Google API. Jika tidak memiliki akun layanan, Anda harus membuat akun layanan. Untuk selengkapnya informasi, lihat Membuat akun layanan.

    • Aktifkan layanan berikut:
      • secretmanager.googleapis.com (Secret Manager API)
      • connectors.googleapis.com (API Konektor)

      Untuk memahami cara mengaktifkan layanan, lihat Mengaktifkan layanan.

    Jika layanan atau izin ini belum diaktifkan untuk project Anda sebelumnya, Anda akan diminta untuk mengaktifkannya saat mengonfigurasi konektor.

Mengonfigurasi konektor

Mengonfigurasi konektor mengharuskan Anda membuat koneksi ke sumber data (sistem backend). Koneksi bersifat khusus untuk sumber data. Ini berarti bahwa jika Anda memiliki banyak sumber data, Anda harus membuat koneksi terpisah untuk setiap sumber data. Untuk membuat koneksi, lakukan langkah-langkah berikut:

  1. Di Konsol Cloud, buka Integration Connectors > Halaman Koneksi lalu pilih atau buat project Google Cloud.

    Buka halaman Koneksi

  2. Klik + Create new untuk membuka halaman Create Connection.
  3. Di bagian Lokasi, pilih lokasi untuk koneksi.
    1. Region: Pilih lokasi dari menu drop-down.

      Untuk mengetahui daftar semua wilayah yang didukung, lihat Lokasi.

    2. Klik Berikutnya.
  4. Di bagian Connection Details, selesaikan langkah-langkah berikut:
    1. Connector: Pilih MongoDB dari menu drop-down Konektor yang tersedia.
    2. Versi konektor: Pilih 2 versi 2 dari menu drop-down versi yang tersedia.
    3. Di kolom Connection Name, masukkan nama untuk instance Koneksi.

      Nama koneksi harus memenuhi kriteria berikut:

      • Nama koneksi dapat menggunakan huruf, angka, atau tanda hubung.
      • Huruf harus huruf kecil.
      • Nama koneksi harus dimulai dengan huruf dan diakhiri dengan huruf atau angka.
      • Nama koneksi tidak boleh lebih dari 63 karakter.
    4. Jika perlu, masukkan Description untuk instance koneksi.
    5. Secara opsional, aktifkan Cloud logging, dan kemudian pilih level log. Secara default, level log disetel ke Error.
    6. Akun Layanan: Pilih akun layanan yang memiliki peran yang diperlukan.
    7. Anda juga dapat mengonfigurasi Setelan node koneksi:

      • Jumlah minimum node: Masukkan jumlah minimum node koneksi.
      • Jumlah maksimum node: Masukkan jumlah maksimum node koneksi.

      Simpul adalah unit (atau replika) koneksi yang memproses transaksi. Diperlukan lebih banyak {i>node<i} untuk memproses lebih banyak transaksi untuk koneksi dan sebaliknya, lebih sedikit node yang diperlukan untuk memproses lebih sedikit transaksi. Untuk memahami pengaruh node terhadap harga konektor Anda, lihat Harga untuk node koneksi. Jika Anda tidak memasukkan nilai apa pun, secara default node minimum ditetapkan ke 2 (untuk ketersediaan yang lebih baik) dan node maksimum ditetapkan ke 50.

    8. Database: Nama database MongoDB.
    9. Waktu Tunggu Koneksi: Waktu Tunggu Koneksi dalam dtk.
    10. Gunakan SSL: Tentukan apakah SSL diaktifkan atau tidak.
    11. Nama Aplikasi: Nama Aplikasi Kustom untuk Mongo.
    12. Maksimal Detik Keusangan: Waktu dalam detik seberapa usang suatu sekunder sebelum klien berhenti menggunakannya untuk operasi baca.
    13. Tulis Masalah(w Option): Opsi untuk meminta konfirmasi bahwa tulisan tersebut telah disebarkan ke sejumlah instance tertentu dengan tag spesifik.
    14. Write Concern(wtimeoutMS Option): Menentukan batas waktu, dalam milidetik, untuk masalah tulis.
    15. Write Concern(Journal Option): Meminta konfirmasi dari MongoDB yang operasi tulis telah ditulis ke jurnal.
    16. Preferensi Baca: Tetapkan atribut ini ke strategi untuk membaca dari kumpulan replika. Nilai yang diterima adalah primary, primaryPreferred, secondary, secondaryPreferred, dan terdekat.
    17. Jenis Cluster: Tentukan jenis cluster MongoDB.
    18. Aktifkan Enkripsi: Menentukan apakah enkripsi diaktifkan atau tidak.
    19. Jenis Enkripsi: Menentukan jenis enkripsi yang diaktifkan. Saat ini hanya jenis Local Encryption yang didukung.
    20. Skema Enkripsi: Menentukan informasi skema enkripsi, termasuk {i>field<i} dan algoritma enkripsi, {i>key alt name<i}, jenis kueri, dan faktor pertentangan. Contoh: 
      {
  "database.collection": {
    "encryptMetadata": {
      "algorithm": "parentAlgo"
    },
    "properties": {
      "passportId": {},
      "medicalRecords": {
        "encryptMetadata": {
          "algorithm": "medicalRecordParentAlgo"
        },
        "properties": {
          "medicalRecord1": {},
          "medicalRecord2": {
            "encrypt": {
              "algorithm": "medicalRecord2Algo",
              "keyAltName": "medicalRecord2Altkey",
              "queryType": "equality",
              "contentionFactor": 3
            }
          }
        }
      },
      "insuranceProperties": {
        "properties": {
          "policyNumber": {},
          "insuranceRecord1": {
            "encrypt": {
              "algorithm": "insuranceRecord1Algo",
              "keyAltName": "insuranceRecord1AltKey"
            }
          },
          "insuranceRecord2": {
            "encrypt": {
              "algorithm": "insuranceRecord2Algo",
              "keyAltName": "insuranceRecord2AltKey",
              "contentionFactor": 5
            }
          }
        }
      }
    }
  }
}
    21. encryption_master_key: Rahasia Secret Manager yang berisi kunci master enkripsi.
    22. encryption_key_vault: Nilai vault kunci enkripsi.
    23. Database Auth: Tentukan nama database MongoDB untuk autentikasi.
    24. Anda juga dapat mengklik + TAMBAHKAN LABEL untuk menambahkan label ke Koneksi dalam bentuk pasangan kunci/nilai.
    25. Klik NEXT.
  5. Di bagian Destinations, masukkan detail host jarak jauh (sistem backend) yang ingin Anda hubungkan.
    1. Jenis Tujuan: Anda dapat menentukan detail tujuan sebagai alamat {i>host<i}, yang dapat berupa salah satu dari hal berikut:
      • String SRV Mongo tunggal. Contoh, mongodb+srv://cluster2.2f.mongodb.net
      • Setiap replika. Contoh, dasdsf.2f.mongodb01.net
      • dengan Alamat IP tertentu Misalnya,10.23.123.12

      Awalan mongodb:// akan ditambahkan ke URL final setelah menggabungkan semua replika dalam string koneksi jika mongodb+srv tidak ditentukan.

      • Alamat host: Tentukan nama host atau alamat IP tujuan.

        Jika Anda ingin membuat koneksi pribadi ke backend, lakukan hal berikut:

      Untuk memasukkan tujuan lain, klik +TAMBAHKAN TUJUAN.

    2. Klik NEXT.
  6. Di bagian Authentication, masukkan detail autentikasi.
    1. Pilih Jenis autentikasi, lalu masukkan detail yang relevan.

      Jenis autentikasi berikut didukung oleh koneksi MongoDB:

      • Nama pengguna dan {i>password<i}

      2. Untuk memahami cara mengonfigurasi autentikasi ini jenis, lihat Mengonfigurasi autentikasi.

    2. Klik NEXT.
  7. Peninjauan: Tinjau detail koneksi dan autentikasi Anda.
  8. Klik Create.

Mengonfigurasi autentikasi

Masukkan detail berdasarkan autentikasi yang ingin Anda gunakan.

  • Nama pengguna dan sandi
    • Nama pengguna: Nama pengguna untuk konektor
    • Password: Secret Manager yang berisi sandi pengguna.
    • Skema Auth: Skema yang digunakan untuk autentikasi.

      Skema Auth berikut didukung oleh koneksi MongoDB:

      • Polos
      • SCRAM-SHA-1
      • SCRAM-SHA-256

Entity, operasi, dan tindakan

Semua Integration Connectors menyediakan lapisan abstraksi untuk objek aplikasi yang terhubung. Anda hanya dapat mengakses objek aplikasi melalui abstraksi ini. Abstraksi ini diekspos kepada Anda sebagai entity, operasi, dan tindakan.

  • Entitas: Entitas dapat dianggap sebagai objek, atau kumpulan properti, di aplikasi atau layanan yang terhubung. Definisi entitas berbeda dari konektor ke entitas konektor 20%. Misalnya, dalam konektor {i>database<i}, tabel adalah entitas, dalam konektor server file, folder adalah entitas, dan dalam konektor sistem pesan, antrean adalah entitas.

    Namun, mungkin saja konektor tidak mendukung atau memiliki entitas apa pun. Dalam hal ini, Daftar Entities akan kosong.

  • Operasi: Operasi adalah aktivitas yang dapat Anda lakukan pada entitas. Anda dapat melakukan salah satu operasi berikut pada entitas:

    Memilih sebuah entitas dari daftar yang tersedia akan menghasilkan daftar yang tersedia untuk entity tersebut. Untuk deskripsi operasi yang terperinci, lihat tugas Konektor operasi entity. Namun, jika konektor tidak mendukung operasi entity apa pun, seperti operasi tidak tercantum dalam daftar Operations.

  • Tindakan: Tindakan adalah fungsi kelas pertama yang tersedia untuk integrasi melalui antarmuka konektor. Tindakan memungkinkan Anda membuat perubahan pada suatu entitas atau beberapa entitas, dan bervariasi dari satu konektor ke konektor lainnya. Biasanya, suatu tindakan akan memiliki beberapa parameter input, dan output . Namun, mungkin saja bahwa konektor tidak mendukung tindakan apa pun, dalam hal ini daftar Actions akan kosong.

Keterbatasan sistem

Konektor MongoDB dapat memproses maksimum 70 transaksi per detik, per node, dan men-throttle semua transaksi di luar batas ini. Secara default, Integration Connectors mengalokasikan 2 node (untuk ketersediaan yang lebih baik) untuk sebuah koneksi.

Untuk informasi tentang batas yang berlaku bagi Konektor Integrasi, lihat Batas.

Jenis data yang didukung

Berikut adalah jenis data yang didukung untuk konektor ini:

  • BIGINT
  • BINARY
  • BIT
  • BOOLEAN
  • CHAR
  • DATE
  • DECIMAL
  • DOUBLE
  • FLOAT
  • INTEGER
  • PANJANG VARCHAR
  • VARCHAR PANJANG
  • NCHAR
  • NUMERIC
  • NVARCHAR
  • NYATA
  • INT KECIL
  • WAKTU
  • TIMESTAMP
  • INT TINY
  • VARBINARY
  • VARCHAR

Konfigurasi untuk cluster MongoDB Atlas

Konfigurasi autentikasi untuk cluster MongoDB Atlas sedikit berbeda dari langkah-langkah yang didokumentasikan sebelumnya. Untuk mengautentikasi terhadap Versa 3 , Anda harus terlebih dahulu mendapatkan string koneksi Versa 3. Untuk mendapatkan Versa 3 string koneksi, lakukan langkah-langkah berikut:

  1. Pada tampilan Clusters, klik Connect untuk cluster yang ingin dihubungkan.
  2. Klik Hubungkan Aplikasi Anda.
  3. Pilih salah satu opsi driver untuk menampilkan string koneksi.

Untuk mengautentikasi terhadap cluster Atlas, gunakan konfigurasi berikut:

  • Database Auth: Tetapkan nilai ke admin, karena semua MongoDB Pengguna Versa 3 dikaitkan dengan database admin.
  • Menggunakan SSL: Setel nilai ke true.
  • Server: Setel nilai ke mongodb+srv://MongoDB INSTANCE SERVER NAME tanpa menyertakan nama pengguna dan {i>password<i}.

Tindakan

Bagian ini mencantumkan semua tindakan yang didukung oleh koneksi MongoDB.

Tindakan AggregatePipeline

Tindakan ini menggabungkan perubahan pipeline dalam kumpulan.

Parameter input tindakan AggregatePipeline

Nama parameter Jenis data Wajib Deskripsi
koleksi String Ya Nama koleksi MongoDB.
pipeline String Ya Pipeline agregasi yang berisi stage kolom sebagai daftar string.
page_size Bilangan bulat Tidak Jumlah item yang akan disertakan di setiap halaman dari kumpulan hasil.
page_no Bilangan bulat Tidak Indeks halaman yang akan diambil dari kumpulan hasil. Indeks dimulai dari 0.

Untuk contoh cara mengonfigurasi tindakan AggregatePipeline, lihat Contoh.

Tindakan CountDocuments

Tindakan ini menghitung semua dokumen yang memenuhi kondisi tertentu dalam koleksi.

Parameter input tindakan CountDocuments

Nama parameter Jenis data Wajib Deskripsi
koleksi String Ya Nama koleksi MongoDB.
filter String Tidak Kondisi filter yang dinyatakan dalam format kueri MongoDB. Kondisi ini dapat berisi kolom terenkripsi jika skema enkripsi diaktifkan untuk kesetaraan jenis kueri.

Parameter output tindakan CountDocuments

Tindakan ini akan menampilkan jumlah semua dokumen yang memenuhi kondisi tertentu.

Untuk contoh cara mengonfigurasi tindakan CountDocuments, lihat Contoh.

Tindakan Hapus Documents

Tindakan ini akan menghapus dokumen dalam koleksi.

Parameter input tindakan DeleteDocuments

Nama parameter Jenis data Wajib Deskripsi
koleksi String Ya Nama koleksi MongoDB.
filter String Tidak Kondisi filter yang dinyatakan dalam format kueri MongoDB. Kondisi ini dapat berisi kolom terenkripsi jika skema enkripsi diaktifkan untuk kesetaraan jenis kueri.

Parameter output tindakan DeleteDocuments

Tindakan ini akan menampilkan jumlah dokumen yang telah dihapus.

Untuk contoh cara mengonfigurasi tindakan DeleteDocuments, lihat Contoh.

Tindakan DistinctValues

Tindakan ini akan menampilkan nilai kolom yang berbeda dalam sebuah koleksi.

Parameter input tindakan DistinctValues

Nama parameter Jenis data Wajib Deskripsi
koleksi String Ya Nama koleksi MongoDB.
kolom String Ya Nama kolom untuk kueri nilai yang berbeda.
filter String Tidak Kondisi filter yang dinyatakan dalam format kueri MongoDB. Kondisi ini dapat berisi kolom terenkripsi jika skema enkripsi diaktifkan untuk kesetaraan jenis kueri.

Untuk contoh cara mengonfigurasi tindakan DistinctValues, lihat Contoh.

Tindakan InsertDocument

Tindakan ini akan menyisipkan dokumen ke dalam koleksi.

Tabel berikut menjelaskan parameter input dan output dari tindakan InsertDocument.

Parameter input tindakan InsertDocument

Nama parameter Jenis data Wajib Deskripsi
koleksi String Ya Nama koleksi MongoDB.
dokumen String Tidak Dokumen yang akan ditambahkan ke koleksi MongoDB.

Parameter output tindakan InsertDocument

Tindakan ini akan menampilkan ID dokumen yang disisipkan.

Untuk contoh cara mengonfigurasi tindakan InsertDocument, lihat Contoh.

Tindakan ListDocuments

Tabel berikut menjelaskan parameter input dan output dari tindakan ListDocuments.

Parameter input tindakan ListDocuments

Nama parameter Jenis data Wajib Deskripsi
koleksi String Ya Nama koleksi MongoDB.
filter String Tidak Kondisi filter yang dinyatakan dalam format kueri MongoDB. Kondisi ini dapat berisi kolom terenkripsi jika skema enkripsi diaktifkan untuk kesetaraan jenis kueri.
page_size Bilangan bulat Tidak Jumlah item yang akan disertakan di setiap halaman dari kumpulan hasil.
page_no Bilangan bulat Tidak Indeks halaman yang akan diambil dari kumpulan hasil. Indeks dimulai dari 0.
proyeksi String Tidak Kumpulan kolom atau properti yang akan disertakan dalam proyeksi kueri dalam format Mongo.
sort_by String Tidak Spesifikasi pengurutan hasil kueri menggunakan format MongoDB's Binary JSON (BSON).

Parameter output dari tindakan ListDocuments

Tindakan tersebut akan menampilkan daftar dokumen yang memenuhi kondisi filter sesuai dengan ukuran halaman. Ukuran halaman default adalah 25 dan ukuran halaman maksimum adalah 50.000.

Untuk contoh cara mengonfigurasi tindakan ListDocuments, lihat Contoh.

Memperbarui tindakan Documents

Tabel berikut menjelaskan parameter input dan output dari tindakan UpdateDocuments.

Parameter input tindakan UpdateDocuments

Nama parameter Jenis data Wajib Deskripsi
koleksi String Ya Nama koleksi MongoDB.
nilai String Tidak Nilai yang akan diperbarui dalam format Mongo.
filter String Tidak Kondisi filter yang dinyatakan dalam format kueri MongoDB. Kondisi ini dapat berisi kolom terenkripsi jika skema enkripsi diaktifkan untuk kesetaraan jenis kueri.
upsert Boolean Tidak Operasi diperbarui dan tidak.

Parameter output dari tindakan UpdateDocuments

Tindakan ini akan menampilkan jumlah dokumen yang diperbarui.

Untuk contoh cara mengonfigurasi tindakan UpdateDocuments, lihat Contoh.

Tindakan PerbaruiDocumentsWithEncryption

Tindakan ini memungkinkan pengguna memperbarui nilai terenkripsi.Tabel berikut menjelaskan parameter input dan output dari tindakan UpdateDocumentsWithEncryption.

Parameter input tindakan UpdateDocumentsWithEncryption

Nama parameter Jenis data Wajib Deskripsi
koleksi String Ya Nama koleksi MongoDB.
dokumen String Tidak Dokumen yang berisi nilai yang akan diperbarui. Nilai dapat berisi kolom yang akan dienkripsi menggunakan CSFLE.
filter String Tidak Kondisi filter yang dinyatakan dalam format kueri MongoDB. Kondisi ini dapat berisi kolom terenkripsi jika skema enkripsi diaktifkan untuk kesetaraan jenis kueri.
upsert Boolean Tidak Menentukan apakah operasinya adalah upsert.

Parameter output tindakan UpdateDocumentsWithEncryption

Tindakan ini akan menampilkan jumlah dokumen yang diperbarui.

Untuk contoh cara mengonfigurasi tindakan UpdateDocumentsWithEncryption, lihat Contoh.

Contoh

Bagian ini menjelaskan cara melakukan beberapa operasi dan tindakan entity di konektor ini.

Contoh - Perubahan pipeline gabungan

  1. Dalam dialog Configure connector task, klik Actions.
  2. Pilih tindakan AggregatePipeline, lalu klik Done.
  3. Di bagian Task Input pada tugas Connectors, klik connectorInputPayload, lalu masukkan nilai yang mirip dengan berikut ini di Kolom Default Value: 
    {
  "collection": "restaurants",
  "pipeline": {
    "stages": [
      "{$addFields: { \"new_menu_item\": \"tea\"}}"
    ]
  },
  "page_size": 1,
  "page_no": 0
}

    4. Contoh ini menambahkan item menu baru ke semua dokumen dalam koleksi restaurant dan mengembalikan laman pertama dari hasil.

Contoh - Menghitung dokumen

  1. Dalam dialog Configure connector task, klik Actions.
  2. Pilih tindakan CountDocuments, lalu klik Done.
  3. Di bagian Task Input pada tugas Connectors, klik connectorInputPayload, lalu masukkan nilai yang mirip dengan berikut ini di Kolom Default Value: 
    {
"collection":"restaurants",
"filter": "{\"name\": \"CarvelIceCream1\"}"
}

    4. Contoh ini menampilkan jumlah dokumen yang cocok dengan kriteria filter. Jika tindakan berhasil, tugas Connectors Parameter respons connectorOutputPayload akan memiliki nilai yang serupa menjadi sebagai berikut:

    {
  "results": [
   {
    "count": 5
   }
  ]
}

Contoh - Menghapus dokumen

  1. Dalam dialog Configure connector task, klik Actions.
  2. Pilih tindakan DeleteDocuments, lalu klik Done.
  3. Di bagian Task Input pada tugas Connectors, klik connectorInputPayload, lalu masukkan kode berikut di Kolom Default Value: 
    {
  "collection": "Insurancedocuments",
  "filter": "{\"insurance.provider\":\"ABC\"}"}

    4. Contoh ini menghapus semua dokumen yang memiliki penyedia asuransi sebagai ABC.

Contoh - Menemukan nilai yang berbeda dalam koleksi

  1. Dalam dialog Configure connector task, klik Actions.
  2. Pilih tindakan DistinctValues, lalu klik Done.
  3. Di bagian Task Input pada tugas Connectors, klik connectorInputPayload, lalu masukkan nilai yang mirip dengan berikut ini di Kolom Default Value: 
    {"collection":"restaurants","field":"contact"}

    4. Contoh ini menampilkan nilai yang berbeda dalam koleksi restaurants. Jika tindakan berhasil, tugas Connectors Parameter respons connectorOutputPayload akan memiliki nilai yang serupa menjadi sebagai berikut:

    {
 "results": [
  {
   "DistinctValues": [
    "3217902323",
    "8747479023",
    "3492619023"
   ]
  }
 ]
}

Contoh - Menyisipkan dokumen

  1. Dalam dialog Configure connector task, klik Actions.
  2. Pilih tindakan InsertDocument, lalu klik Done.
  3. Di bagian Task Input pada tugas Connectors, klik connectorInputPayload, lalu masukkan nilai yang mirip dengan berikut ini di Kolom Default Value: 
    { {
"collection": "Insurancedocuments",
"document": "{\"fname\":\"firstName\",
\"lname\":\"lastName\",
\"passportId\":\"ABCD1234\",
\"bloodType\":\"A\",
\"medicalRecords\":[{\"item\":\"name1\"},{\"item\":\"name2\"}],
\"insurance\":{\"policyNumber\":\"12345\",\"provider\":\"provider2\"}}"
} }

    4. Contoh ini menyisipkan dokumen dalam koleksi Insurancedocuments. Konten dokumen ditentukan di kolom document. Jika penyisipan berhasil, Anda akan mendapatkan ID dari dokumen yang disisipkan tugas Connectors Parameter respons connectorOutputPayload.

Contoh - Membuat daftar dokumen

  1. Dalam dialog Configure connector task, klik Actions.
  2. Pilih tindakan ListDocuments, lalu klik Done.
  3. Di bagian Task Input pada tugas Connectors, klik connectorInputPayload, lalu masukkan nilai yang mirip dengan berikut ini di Kolom Default Value: 
    {
"collection": "Insurancedocuments",
"filter": "{\"insurance.provider\":\"ABC\"}",
"page_size": 10
}

    4. Contoh ini menampilkan dokumen dalam koleksi Insurancedocuments dengan penyedia asuransinya adalah ABC. Ukuran halaman kumpulan hasil diatur ke 10 dan daftar file akan yang tersedia untuk Anda dalam format JSON dalam tugas Connectors Parameter respons connectorOutputPayload.

Contoh - Memperbarui dokumen

  1. Dalam dialog Configure connector task, klik Actions.
  2. Pilih tindakan UpdateDocuments, lalu klik Done.
  3. Di bagian Task Input pada tugas Connectors, klik connectorInputPayload, lalu masukkan nilai yang mirip dengan berikut ini di Kolom Default Value: 
    {"collection":"Insurancedocuments",
"values":" {$set: { lname:\"Smith\" }}",
"filter":"{\"insurance.provider\":\"ABC\"}"}

    4. Contoh ini memperbarui nama belakang menjadi Smith dalam dokumen yang cocok kriteria filter. Jika pembaruan berhasil, Anda akan mendapatkan jumlah jumlah dokumen yang diperbarui. Responsnya akan tersedia di tugas Connectors Parameter respons connectorOutputPayload.

Contoh - Memperbarui dokumen dengan enkripsi

  1. Dalam dialog Configure connector task, klik Actions.
  2. Pilih tindakan UpdateDocumentsWithEncryption, lalu klik Done.
  3. Di bagian Task Input pada tugas Connectors, klik connectorInputPayload, lalu masukkan kode berikut di Kolom Default Value: 
    { {"collection":"Insurancedocuments",
"document":" { \"insurance.provider\":\"XYZ\" }",
"filter":"{\"insurance.provider\":\"ABC\"}"}

    4. Contoh ini memperbarui penyedia asuransi menjadi XYZ di semua dokumen yang mencantumkan penyedia asuransi sebagai ABC.

Menggunakan terraform untuk membuat koneksi

Anda dapat menggunakan Terraform resource untuk membuat koneksi baru.

Untuk mempelajari cara menerapkan atau menghapus konfigurasi Terraform, lihat Perintah dasar Terraform.

Guna melihat contoh template terraform untuk pembuatan koneksi, lihat contoh template.

Saat membuat koneksi ini menggunakan Terraform, Anda harus menetapkan variabel berikut dalam file konfigurasi Terraform:

Nama parameter Jenis data Wajib Deskripsi
database STRING Benar Nama database MongoDB.
timeout INTEGER Salah Waktu tunggu koneksi habis dalam detik.
enable_ssl BOOLEAN Salah Bidang ini menetapkan apakah SSL diaktifkan.
app_name STRING Salah Nama aplikasi kustom untuk MongoDB.
max_staleness_seconds INTEGER Salah Waktu dalam detik seberapa usang suatu sekunder, sebelum klien berhenti menggunakannya untuk operasi baca.
write_concern STRING Salah Opsi untuk meminta konfirmasi bahwa operasi tulis telah diterapkan ke sejumlah instance tertentu dengan tag yang ditentukan.
write_concern_timeout INTEGER Salah Menentukan batas waktu, dalam milidetik, untuk masalah penulisan.
write_concern_journal BOOLEAN Salah Meminta konfirmasi dari MongoDB bahwa operasi tulis telah ditulis ke jurnal.
read_preference ENUM Salah Membaca preferensi untuk koneksi ini. Nilai yang didukung adalah: primary, primaryPreferred, secondary, secondaryPreferred, terdekat
cluster_type ENUM Salah Menentukan jenis cluster MongoDB. Nilai yang didukung adalah: repLICA_SET, STANDALONE, SHARDED, UNKNOWN
enable_encryption BOOLEAN Salah Kolom ini menetapkan apakah Enkripsi diaktifkan.
encryption_type ENUM Salah Kolom ini menetapkan jenis enkripsi yang diaktifkan. Nilai yang didukung adalah: local
encryption_schema STRING Salah Informasi skema enkripsi, termasuk kolom dan algoritma enkripsi yang digunakan.
encryption_master_key RAHASIA Salah Secret Manager Secret yang berisi kunci master enkripsi.
encryption_key_vault STRING Salah Nilai Vault Kunci Enkripsi.
auth_database STRING Benar Nama database MongoDB untuk autentikasi.

Menggunakan koneksi MongoDB dalam integrasi

Setelah dibuat, koneksi akan tersedia di Integrasi Apigee dan Application Integration. Anda dapat menggunakan koneksi dalam integrasi melalui tugas Connectors.

  • Untuk memahami cara membuat dan menggunakan tugas Konektor di Integrasi Apigee, lihat Tugas konektor.
  • Untuk memahami cara membuat dan menggunakan tugas Konektor di Application Integration, lihat Tugas konektor.

Dapatkan bantuan dari komunitas Google Cloud

Anda dapat memposting pertanyaan dan mendiskusikan konektor ini di Google Cloud di Forum Cloud.

Langkah selanjutnya