MongoDB
Create or update a recurring MongoDB connector
Create or update a recurring MongoDB connector. Generates a Bento pipeline with a mongodb input that polls a MongoDB collection on a configurable interval and streams documents to Kafka → Firestore. The connection URL (including any credentials) is NEVER stored in the pipeline config — it is resolved from an environment variable at runtime via Secret Manager.
Technical details
Authentication ▾
Contact us for setup details.
Ingestion ▾
Tools exposed (1) ▾
Create or update a recurring MongoDB connector. Generates a Bento pipeline with a mongodb input that polls a MongoDB collection on a configurable interval and streams documents to Kafka → Firestore. The connection URL (including any credentials) is NEVER stored in the pipeline config — it is resolved from an environment variable at runtime via Secret Manager.
Inputs ▾
upsert_bento_mongodb
| Name | Type | Required | Description |
|---|---|---|---|
| dashboardId | string | no | Target dashboard/initiative ID. Omit to use the current dashboard. |
| connectorId | string | no | If provided, updates the existing connector instead of creating a new one. |
| connectorName | string | yes | Human-readable name for this connector, e.g. 'MongoDB — production.events collection'. |
| connectionUrlEnvVar | string | yes | Name of the environment variable that holds the full MongoDB connection URL, e.g. 'MONGO_URI'. The URL may include embedded credentials (mongodb+srv://user:pass@cluster.mongodb.net). The value is resolved from Secret Manager at pipeline runtime — never pass the URL directly. |
| database | string | yes | MongoDB database name, e.g. 'production' or 'analytics'. |
| collection | string | yes | MongoDB collection name to query, e.g. 'events' or 'users'. |
| query | string | no | MongoDB query filter as a JSON string, e.g. '{"status": "active"}'. Omit or pass '{}' to return all documents. |
| pollingInterval | string | yes | How often Bento polls MongoDB, e.g. '15m', '1h', '6h'. Use 'realtime' for the fastest practical rate (1m). |
| idExpression | string | no | Optional Bloblang expression for the Firestore document ID. Provide when documents have a stable unique key, e.g. 'this._id.string()' or 'this.userId.string()'. |