Bulk
yaml
type: "io.kestra.plugin.mongodb.bulk"
Examples
yaml
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
connection *RequiredNon-dynamicMongoDbConnection
database *Requiredstring
from *Requiredstring
chunk integerstring
Default
1000
Outputs
deletedCount integer
Default
0
insertedCount integer
Default
0
matchedCount integer
Default
0
modifiedCount integer
Default
0