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
- Type: MongoDbConnection
- Dynamic: ❓
- Required: ✔️
The connection properties.
database
- Type: string
- Dynamic: ✔️
- Required: ✔️
The mongodb database.
from
- Type: string
- Dynamic: ✔️
- Required: ✔️
The source file
chunk
- Type: integer
- Dynamic: ✔️
- Required: ❌
- Default:
1000
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