load
Bulk load documents into a MongoDB using Kestra’s internal storage file.
Bulk load documents into a MongoDB using Kestra’s internal storage file.
Bulk load documents into a MongoDB using Kestra’s internal storage file.
type: "io.kestra.plugin.mongodb.load"Examples
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 }}"
Properties
collection*Requiredstring
MongoDB collection.
connection*RequiredNon-dynamic
MongoDB connection properties.
io.kestra.plugin.mongodb.MongoDbConnection
Connection string to MongoDB server
URL format like mongodb://mongodb0.example.com: 27017
database*Requiredstring
MongoDB database.
from*Requiredstring
The source file.
Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.
chunkintegerstring
1000Chunk size for every bulk request.
idKeystring
Use this key as ID
removeIdKeybooleanstring
trueWhether to remove idKey from the final document
Outputs
deletedCountinteger
0The number of documents deleted by the write operation.
insertedCountinteger
0The number of documents inserted by the write operation.
matchedCountinteger
0The number of documents matched by updates or replacements in the write operation.
modifiedCountinteger
0The number of documents modified by the write operation.
sizeinteger
The number of rows processed.
Metrics
recordscounter
countNumber of documents processed in the bulk operation
requests.countcounter
countNumber of bulk requests sent to MongoDB
