MongoDB

MongoDB nodes let you query and manage documents in MongoDB databases. Each operation is a separate node.

All nodes require a MongoDB connection configured with your connection string and database name.

Nodes

Find

Query documents from a collection.

Field	Description	Notes
Collection	Collection name	Required
Filter	MongoDB query filter (JSON)	Optional. Supports templates
Projection	Fields to include/exclude (JSON)	Optional
Sort	Sort specification (JSON, e.g., {"created_at": -1})	Optional
Limit	Maximum documents to return	Optional

Supports streaming — each document is emitted individually to downstream nodes.

Insert

Insert one or more documents into a collection.

Field	Description	Notes
Collection	Collection name	Required
Document	JSON document or array of documents to insert	Required. Supports templates

Update

Update documents matching a filter.

Field	Description	Notes
Collection	Collection name	Required
Filter	Query filter to match documents (JSON)	Required. Supports templates
Update	Update operations (JSON, e.g., {"$set": {"status": "done"}})	Required. Supports templates
Update Many	Update all matching documents (vs. just the first)	Default: false

Delete

Delete documents matching a filter.

Field	Description	Notes
Collection	Collection name	Required
Filter	Query filter to match documents (JSON)	Required. Supports templates
Delete Many	Delete all matching documents (vs. just the first)	Default: false

Aggregate

Run an aggregation pipeline on a collection.

Field	Description	Notes
Collection	Collection name	Required
Pipeline	Aggregation pipeline stages (JSON array)	Required. Supports templates

Supports streaming — each result document is emitted individually.

Common Patterns

ETL from MongoDB

1. MongoDB Find — query source documents
2. Transform — reshape data
3. DataStore Insert — store in the internal datastore

Update Documents from Upstream Data

1. Google Sheets Read — fetch update data
2. MongoDB Update — apply updates per row using template filters