MongoDB Update

MongoDB Update
Certified
Update or replace MongoDB documents

Runs MongoDB replaceOne, updateOne, or updateMany on a collection. Defaults to UPDATE_ONE; both filter and document accept BSON maps or strings and are rendered from Flow variables. Requires write access; upserts are not exposed.

yaml
type: io.kestra.plugin.mongodb.Update

Examples

Replace a document.

yaml
id: mongodb_update
namespace: company.team

tasks:
  - id: update
    type: io.kestra.plugin.mongodb.Update
    connection:
      uri: "mongodb://root:example@localhost:27017/?authSource=admin"
    database: "my_database"
    collection: "my_collection"
    operation: "REPLACE_ONE"
    document:
      _id:
        $oid: 60930c39a982931c20ef6cd6
      name: "John Doe"
      city: "Paris"
    filter:
      _id:
        $oid: 60930c39a982931c20ef6cd6

Update a document.

yaml
id: mongodb_update
namespace: company.team

tasks:
  - id: update
    type: io.kestra.plugin.mongodb.Update
    connection:
      uri: "mongodb://root:example@localhost:27017/?authSource=admin"
    database: "my_database"
    collection: "my_collection"
    filter:
      _id:
        $oid: 60930c39a982931c20ef6cd6
    document: '{"$set": { "tags": ["blue", "green", "red"]}}'

Properties

collection *string

MongoDB collection

connection *

MongoDB connection properties

Definitions

io.kestra.plugin.mongodb.MongoDbConnection

uri*string

Connection string to MongoDB server

URL format like mongodb://mongodb0.example.com: 27017

database *string

MongoDB database

document *object

Update payload or replacement document

BSON string or map rendered before execution.

filter *object

Query filter

BSON string or map rendered before execution; selects documents to update.

operation string

DefaultUPDATE_ONE

Possible Values

REPLACE_ONEUPDATE_ONEUPDATE_MANY

Update operation

One of UPDATE_ONE (default), UPDATE_MANY, or REPLACE_ONE.

Outputs

matchedCount integer

Default0

The number of documents matched by the query

modifiedCount integer

The number of documents modified by the update

upsertedId string

Upserted document id

Null unless MongoDB created a document during the write.

wasAcknowledged boolean

Whether the write was acknowledged

Metrics

updated.count counter

Unitcount

Number of documents updated in MongoDB

Debezium DB2

Tasks that ingest IBM Db2 change data through Debezium connectors in Kestra.

Data

Airbyte

Tasks that trigger and monitor Airbyte sync and reset jobs in self-hosted Airbyte and Airbyte Cloud

Data

MongoDB UpdateCertifiedUpdate or replace MongoDB documents

MongoDB Update

More Plugins in this Category

Debezium DB2

Airbyte

MongoDB Update
Certified
Update or replace MongoDB documents