¿Qué son los change streams?

Question

Accepted Answer

**Change streams** permiten que las aplicaciones **se suscriban a cambios en tiempo real** en datos de MongoDB — recibiendo notificaciones cuando se insertan, actualizan o eliminan documentos. Habilitan características reactivas y orientadas a eventos (actualizaciones en tiempo real, sincronización, triggers) sin hacer polling a la base de datos. Construidos sobre el oplog del replica set.

## Observando cambios

```js
// watch a collection for changes — get notified in real time
const changeStream = db.collection("orders").watch();

changeStream.on("change", (change) => {
  console.log(change.operationType);   // "insert", "update", "delete", "replace"
  console.log(change.fullDocument);     // the changed document (for inserts/updates)
  // react: push to websockets, update a cache, trigger a workflow, etc.
});
```

Un change stream emite un evento para cada cambio (inserción/actualización/eliminación), con detalles sobre qué cambió — para que la aplicación reaccione en tiempo real.

## Filtrado y reanudación

```js
// watch only specific changes with an aggregation pipeline filter
db.collection("orders").watch([
  { $match: { operationType: "insert", "fullDocument.status": "urgent" } }
]);

// resume from where you left off (resilient to disconnections)
db.collection("orders").watch([], { resumeAfter: lastChangeToken });
```

Puedes **filtrar** cambios (observar solo ciertas operaciones o documentos) y **reanudar** después de una desconexión (usando un token de reanudación) — haciendo que los change streams sean resilientes.

## Casos de uso comunes

```text
✓ REAL-TIME features — push live updates to clients (websockets) when data changes
✓ SYNCING — keep a cache, search index (Elasticsearch), or another system in sync
✓ EVENT-DRIVEN architecture — trigger workflows/notifications on data changes
✓ AUDITING — log changes; analytics on data modifications
→ All WITHOUT polling the database repeatedly (efficient, real-time)
```

## Change streams vs polling

```text
❌ POLLING — repeatedly query "what changed?" → inefficient, latency, load on the DB
✅ CHANGE STREAMS — the database PUSHES changes to you in real time → efficient, instant
→ The right way to react to data changes (requires a replica set).
```

## Por qué es importante

Los change streams son una característica valiosa de MongoDB para construir **aplicaciones reactivas, orientadas a eventos y en tiempo real**, por lo que comprenderlos es conocimiento útil de nivel senior para aplicaciones modernas que necesitan reactividad de datos en vivo.

El valor central es permitir que las aplicaciones **reaccionen a cambios de datos en tiempo real** — recibiendo notificaciones push cuando se insertan, actualizan o eliminan documentos — que potencia capacidades importantes: **características en tiempo real** (empujando actualizaciones en vivo a clientes a través de websockets cuando los datos cambian — una necesidad común para aplicaciones colaborativas, dashboards, notificaciones), **sincronización** (manteniendo cachés, índices de búsqueda como Elasticsearch, u otros sistemas consistentes con MongoDB a medida que los datos cambian), **arquitectura orientada a eventos** (activando workflows, notificaciones, o procesamiento en cambios de datos), y **auditoría**.

La ventaja clave es hacer todo esto **sin polling** — los change streams permiten que la base de datos *empuje* cambios a la aplicación instantáneamente y de manera eficiente, reemplazando el patrón derrochador y de mayor latencia de repetidamente consultar "¿qué cambió?" (que carga la base de datos y tiene retraso).

Entender cómo observar colecciones, filtrar cambios (solo operaciones/documentos relevantes), y reanudar después de desconexiones (usando tokens de reanudación para resiliencia) cubre el uso práctico.

Saber que los change streams requieren un replica set también es relevante.

Ya que la reactividad en tiempo real y mantener sistemas sincronizados son necesidades de aplicación cada vez más importantes, y ya que los change streams proporcionan una manera eficiente y basada en push para reaccionar a cambios de datos de MongoDB (mucho mejor que polling), entender los change streams — qué hacen, sus casos de uso (características en tiempo real, sincronización, procesamiento orientado a eventos), las capacidades de reanudación/filtrado, y la ventaja sobre polling — es conocimiento valioso de nivel senior para construir aplicaciones MongoDB modernas y reactivas, una característica útil para la necesidad común de responder a cambios de datos en tiempo real y un tema que refleja la comprensión de patrones de aplicaciones orientadas a eventos y en tiempo real con MongoDB.