find
Find documents in a MongoDB collection.

Find documents in a MongoDB collection.

yaml
type: "io.kestra.plugin.mongodb.find"

Examples

yaml
id: mongodb_find
namespace: company.team

tasks:
  - id: find
    type: io.kestra.plugin.mongodb.Find
    connection:
      uri: "mongodb://root:example@localhost:27017/?authSource=admin"
    database: "my_database"
    collection: "my_collection"
    filter:
      _id:
        $oid: 60930c39a982931c20ef6cd6

Find documents in MongoDB based on a filter condition using MongoDB Query Language.

yaml
id: filter_mongodb
namespace: company.team

tasks:
  - id: filter
    type: io.kestra.plugin.mongodb.Find
    connection:
      uri: mongodb://host.docker.internal:27017/
    database: local
    collection: pokemon
    store: true
    filter:
      base_experience:
        $gt: 100

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.

filterobject

MongoDB BSON filter

limitintegerstring

The number of records to return

projectionobject

MongoDB BSON projection

skipintegerstring

The number of records to skip

sortobject

MongoDB BSON sort

Can be a BSON string or a map.

storebooleanstring

Defaultfalse

Whether to store the data from the query result into an Ion-serialized data file

Outputs

rowsarray

List containing the fetched data.

Only populated if store parameter is set to false.

sizeinteger

The number of rows fetched.

uristring

Formaturi

URI of the file containing the fetched results.

Only populated if store parameter is set to true.

Metrics

recordscounter

Unitcount

Number of documents fetched from MongoDB

Opensearch

Enterprise

This sub-group of plugins contains tasks for using Opensearch EE. Opensearch is a distributed, RESTful search and analytics engine capable of addressing a growing number of use cases.

Database

OpenSearch

This sub-group of plugins contains tasks for using Opensearch. Opensearch is a distributed, RESTful search and analytics engine capable of addressing a growing number of use cases.

Database