MongoDB

io.mongo Storage v0.1.0

Runs one MongoDB operation over the dependency-free OP_MSG wire client: find, insert many, update many, delete many, or an aggregation pipeline. Leave documents empty to insert the input payload.

Ports

Direction	Port	Label
Input	`input`	Payload
Output	`output`	Result

Properties

Property	Type	Default	Description
Credential `credentialId`	`credential`	`""`	Use a stored credential for this connection — its fields are filled in at run start. Pick "None" to enter the connection details manually. accepts credential templates: `mongo`
URI `uri`	`string`	`"mongodb://localhost:27017"`	mongodb://host:port[,host:port…] — credentials go in the User/Password fields, NOT in the URI.
User `user`	`string`	`""`	MongoDB user (SCRAM-SHA-256). Leave blank to skip authentication.
Password `password`	`string`	`""`	MongoDB password — supports ${credential.NAME.FIELD}. ASCII only in v1 (SASLprep is a no-op).
Auth database `authDb`	`string`	`"admin"`	The database the user is defined in.
Database `database`	`string`	`""`	Database to operate on (required).
Collection `collection`	`string`	`""`	Collection to operate on (required).
Operation `operation`	`select`	`"find"`	find/aggregate read documents; insertMany/updateMany/deleteMany write. find/aggregate return the first batch only (keep the limit within one batch). `findinsertManyupdateManydeleteManyaggregate`
Filter `filter`	`json`	`{}`	Query filter as JSON, e.g. {"status": "open"}. {"$oid": "…"} becomes an ObjectId; {"$date": "…"} becomes a date. Shown when `["find", "updateMany", "deleteMany"].includes(operation ?? "find")`
Documents `documents`	`json`	`[]`	Documents to insert as a JSON array. Leave empty to insert the input payload (array → documents, object → one document). Shown when `operation === "insertMany"`
Update `update`	`json`	`{}`	Update document — top-level keys must be $-operators, e.g. {"$set": {"status": "done"}}. Shown when `operation === "updateMany"`
Pipeline `pipeline`	`json`	`[]`	Aggregation pipeline as a JSON array of stages. Shown when `operation === "aggregate"`
Sort `sort`	`json`	`{}`	Sort specification, e.g. {"createdAt": -1}. Shown when `(operation ?? "find") === "find"`
Limit `limit`	`int`	`100`	Result cap for find/aggregate. v1 reads the first batch only — values above 5000 risk truncation. Shown when `["find", "aggregate"].includes(operation ?? "find")`
Timeout (ms) `timeoutMs`	`int`	`15000`	Abort the whole conversation after this many milliseconds.

This page is generated from the node registry by gen-node-docs.mjs on every site build — ports, properties, defaults and visibility rules cannot drift from the code.