Bulk load documents into a MongoDB using Kestra’s internal storage file.
yaml
type: "io.kestra.plugin.mongodb.load"yaml
id: mongodb_load
namespace: company.team
inputs:
- id: file
type: FILE
tasks:
- 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 }}"
MongoDB collection.
MongoDB connection properties.
MongoDB database.
The source file.
Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.
Default
1000Chunk size for every bulk request.
Use this key as ID
Default
trueWhether to remove idKey from the final document
Default
0The number of documents deleted by the write operation.
Default
0The number of documents inserted by the write operation.
Default
0The number of documents matched by updates or replacements in the write operation.
Default
0The number of documents modified by the write operation.
The number of rows processed.
Connection string to MongoDB server
URL format like mongodb://mongodb0.example.com: 27017