PLUGINSPLUGIN-MONGODBTASKSIO.KESTRA.PLUGIN.MONGODB.LOAD

​Load

Load Load

yaml
type: "io.kestra.plugin.mongodb.Load"

Bulk load documents in MongoDB using Kestra Internal Storage file

Examples

yaml
id: "load"
type: "io.kestra.plugin.mongodb.Load"
connection:
  uri: "mongodb://root:example@localhost:27017/?authSource=admin"
database: "my_database"
collection: "my_collection"
from: "{{ inputs.file }}"

Properties

collection

  • Type: string
  • Dynamic: ✔️
  • Required: ✔️

The mongodb collection.

connection

The connection properties.

database

  • Type: string
  • Dynamic: ✔️
  • Required: ✔️

The mongodb database.

from

  • Type: string
  • Dynamic: ✔️
  • Required: ✔️

The source file

chunk

  • Type: integer
  • Dynamic: ✔️
  • Required: ❌

The size of chunk for every bulk request

idKey

  • Type: string
  • Dynamic: ✔️
  • Required: ❌

Use this key as id.

removeIdKey

  • Type: boolean
  • Dynamic: ✔️
  • Required: ❌
  • Default: true

Remove idKey from the final document

Outputs

deletedCount

  • Type: integer
  • Default: 0

The number of documents deleted by the write operation.

insertedCount

  • Type: integer
  • Default: 0

The number of documents inserted by the write operation.

matchedCount

  • Type: integer
  • Default: 0

The number of documents matched by updates or replacements in the write operation.

modifiedCount

  • Type: integer
  • Default: 0

The number of documents modified by the write operation.

size

  • Type: integer

The size of the rows processed

Definitions

MongoDbConnection

uri

  • Type: string
  • Dynamic: ✔️
  • Required: ✔️
  • Min length: 1

Connection string to mongodb server

url format like mongodb://mongodb0.example.com:27017