Conector de origen
Conector de MongoDB
Integración de MongoDB con bases de datos, warehouses y herramientas de BI
Base documental usada como fuente operacional para analítica. Datrise captura entidades de MongoDB como collections, documents, change streams, and schema snapshots, y luego entrega modelos normalizados y tipados para reporting en warehouse, atribución y flujos de IA.
La MongoDB Wire Protocol drivers + Change Streams (pre/post-images, MongoDB 6.0+) se autentica con username / password, mTLS, service account, las cargas incrementales usan resumeToken (Change Streams).
De los 4 objetos, 2 se sincronizan con upsert por clave primaria y 2 como flujos append-only, de modo que cada ejecución incremental solo mueve lo que cambió desde la última marca de agua. Cada objeto llega a su propia tabla (por ejemplo `mongodb_collections`) con el esquema derivado de la API de MongoDB, no de un CSV, en cualquiera de los 43 destinos soportados.
Datrise está en acceso anticipado: elige un destino abajo para ver el pipeline de MongoDB y únete a la lista de espera para recibir el conector con onboarding guiado.
Qué datos de MongoDB extrae Datrise
Cada objeto llega a su propia tabla tipada. El modo de sync se deriva del objeto: los objetos de historial se anexan, el resto se actualiza con upsert.
| Objeto | Tabla de destino | Modo de sync |
|---|---|---|
| collections | mongodb_collections | Upsert por clave primaria, incremental por updated-at |
| documents | mongodb_documents | Upsert por clave primaria, incremental por updated-at |
| change streams | mongodb_change_streams | Append incremental por marca de tiempo |
| schema snapshots | mongodb_schema_snapshots | Append incremental por marca de tiempo |
API de MongoDB: datos de configuración del conector
Verificado contra la documentación del proveedor el 2026-09-02. Los valores desconocidos se dejan en blanco, no se inventan.
| API | MongoDB Wire Protocol drivers + Change Streams (pre/post-images, MongoDB 6.0+) |
|---|---|
| Autenticación | username / password, mTLS, service account — SCRAM (username/password) is the default; x.509 certificate auth is common for service-to-service TLS, and Atlas additionally supports AWS-IAM and OIDC as service-account-style mechanisms (Kerberos/LDAP are Enterprise-only and LDAP is deprecated as of MongoDB 8.0). |
| Paginación | cursor — Reads are cursor-based (`find()`/`getMore` batches); Change Streams separately expose a resumable position via an opaque `resumeToken` returned on each event and in `postBatchResumeToken`. |
| Límite de peticiones | No publicado |
| Cursor incremental | resumeToken (Change Streams) — A Change Stream's `resumeToken` (passed back via `resumeAfter`/`startAfter`) is the native CDC cursor; it only resolves as far back as the oplog's retention window, so a connector that falls behind that window must fall back to a full resync. |
| Webhooks | No |
| Exportación masiva | Sí — mongodump / mongoexport (BSON or JSON/CSV dumps, optionally with --oplog for a consistent point-in-time snapshot) |
| Detección de borrados | Sí — Change Stream events with `operationType: "delete"` report the removed document's `_id` via `documentKey`; recovering its prior field values requires pre-images, which must be enabled per collection ahead of time via `changeStreamPreAndPostImages`. |
Destinos populares para MongoDB
Elige un destino abajo para abrir la página de pipeline lista para usar.
- AAirtable
Destino de hoja relacional para equipos de operaciones y go-to-market.
Ver pipeline - AAmazon Athena
SQL serverless sobre tablas del data lake en S3.
Ver pipeline - AAmazon DynamoDB
Base key-value y documental serverless en AWS.
Ver pipeline - AAmazon QuickSight
BI serverless en AWS con SPICE y analítica embebida.
Ver pipeline - AAmazon Redshift
Almacén a escala petabyte en AWS con Spectrum.
Ver pipeline - AAmazon S3 Data Lake
Zona de aterrizaje en object storage para parquet y snapshots.
Ver pipeline - AApache Superset
BI open source para exploración SQL, gráficos y publicación de dashboards.
Ver pipeline - AArchivos CSV
Destino de archivos planos para exportaciones y compartición ligera.
Ver pipeline - AAzure Data Lake Storage
Almacenamiento ADLS Gen2 para cargas analíticas.
Ver pipeline
Preguntas sobre el conector de MongoDB
- ¿Qué datos de MongoDB extrae el conector?
- 4 objetos: collections, documents, change streams y schema snapshots. Cada uno se carga en su propia tabla con tipos preservados; los objetos con historial (2: change streams y schema snapshots) se cargan como append-only.
- ¿La integración de MongoDB es incremental?
- Sí. Tras la carga inicial completa, cada ejecución lee solo los registros cambiados desde la última marca de agua (updated-at o timestamp del evento) y aplica upsert o append según el objeto.
- ¿A dónde puedo cargar los datos de MongoDB?
- A 43 destinos: bases de datos relacionales, warehouses, data lakes, hojas de cálculo y herramientas de BI. Cada par MongoDB → destino tiene su propia página con el mapeo de objetos a tablas.
Acceso anticipado
Lanza tu pipeline de MongoDB con onboarding guiado
Únete a la lista de espera para obtener acceso prioritario a integraciones de MongoDB con setup guiado, mapeo consciente del esquema y sincronización incremental de nivel producción.