Send a bulk request to MongoDB.
Execute Bulk requests in MongoDB such as inserts and deletes. Below are sample file contents that can be provided as an input to the Bulk task:
{ "insertOne" : {"firstName": "John", "lastName": "Doe", "city": "Paris"}}
{ "insertOne" : {"firstName": "Ravi", "lastName": "Singh", "city": "Mumbai"}}
{ "deleteMany": {"filter": {"city": "Bengaluru"}}}
type: "io.kestra.plugin.mongodb.bulk"Examples
id: mongodb_bulk
namespace: company.team
tasks:
- id: make_actions
type: io.kestra.plugin.core.storage.Write
content: |
{ "insertOne" : {"firstName": "John", "lastName": "Doe", "city": "Paris"}}
{ "insertOne" : {"firstName": "Ravi", "lastName": "Singh", "city": "Mumbai"}}
{ "deleteMany": {"filter": {"city": "Bengaluru"}}}
- id: bulk
type: io.kestra.plugin.mongodb.Bulk
connection:
uri: "mongodb://YOUR_HOST:27017"
database: "my_database"
collection: "my_collection"
from: "{{ outputs.make_actions.uri }}"
Properties
collection *Requiredstring
MongoDB collection.
connection *RequiredNon-dynamicMongoDbConnection
MongoDB connection properties.
database *Requiredstring
MongoDB database.
from *Requiredstring
The source file.
Pebble expression referencing an Internal Storage URI e.g. {{ outputs.mytask.uri }}.
chunk integerstring
1000Chunk size for every bulk request.
Outputs
deletedCount integer
0The number of documents deleted by the write operation.
insertedCount integer
0The number of documents inserted by the write operation.
matchedCount integer
0The number of documents matched by updates or replacements in the write operation.
modifiedCount integer
0The number of documents modified by the write operation.
size integer
The number of rows processed.
Metrics
records counter
countNumber of documents processed in the bulk operation
requests.count counter
countNumber of bulk requests sent to MongoDB
Definitions
io.kestra.plugin.mongodb.MongoDbConnection
uri *Requiredstring
Connection string to MongoDB server
URL format like mongodb://mongodb0.example.com: 27017