Input
MongoDB Input
Reads documents from a MongoDB collection — optionally filtered and narrowed to some fields — one row per document, nested fields flattened to dot paths.
When to use it
Use it to pull a collection (customer profiles, events, orders) into a flow, from Atlas or your own server.
In a pipeline
MongoDB InputFilter RowsExport CSV
Settings
| Setting | Type | Required | Default or hint |
|---|---|---|---|
| Connection | select | Yes | Add a connection below |
| Table | select | Yes | Select a table |
| Filter (JSON) | textarea | — | {"status":"active"} |
| Fields (JSON) | textarea | — | {"name":1,"email":1} |
Example
Active customers
- Table=customers
- Filter (JSON)={"status":"active"}
| _id | name | address.city | status |
|---|---|---|---|
| 6530a1… | Harbour Foods | Leeds | active |
Worth knowing
- Host takes a server name or a full mongodb+srv://… address (Atlas); the Table list shows the database's collections.
- Filter and Fields are MongoDB JSON, e.g. {"total":{"$gt":500}} and {"name":1,"email":1}.
- ObjectIds and dates come back as text; arrays stay as they are (JSON Parse / Flatten or JSON to Rows takes them further).