Skip to main content

mongodb

EXPERIMENTAL

This component is experimental and therefore subject to change or removal outside of major version releases.

Executes a find query and creates a message for each row received.

Introduced in version 3.64.0.

# Common config fields, showing default values
input:
label: ""
mongodb:
url: ""
database: ""
collection: ""
username: ""
password: ""
query: ""

Once the rows from the query are exhausted this input shuts down, allowing the pipeline to gracefully terminate (or the next input in a sequence to execute).

Fields

url

The URL of the target MongoDB DB.

Type: string

# Examples

url: mongodb://localhost:27017

database

The name of the target MongoDB database.

Type: string

collection

The collection to select from.

Type: string

username

The username to connect to the database.

Type: string
Default: ""

password

The password to connect to the database.

Type: string
Default: ""

operation

The mongodb operation to perform.

Type: string
Default: "find"
Requires version 4.2.0 or newer
Options: find, aggregate.

query

Bloblang expression describing MongoDB query.

Type: string

# Examples

query: |2
root.from = {"$lte": timestamp_unix()}
root.to = {"$gte": timestamp_unix()}