Cosa sono i change streams?

Question

Accepted Answer

**Change streams** permettono alle applicazioni di **sottoscriversi ai cambiamenti in tempo reale** nei dati di MongoDB — ricevendo notifiche quando i documenti vengono inseriti, aggiornati o eliminati. Abilitano funzionalità reattive e event-driven (aggiornamenti in tempo reale, sincronizzazione, trigger) senza interrogare il database. Costruiti sull'oplog del replica set.

## Osservare i cambiamenti

```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 emette un evento per ogni cambiamento (insert/update/delete), con dettagli su cosa è cambiato — in modo che l'applicazione reagisca in tempo reale.

## Filtraggio e ripresa

```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 });
```

Puoi **filtrare** i cambiamenti (osservare solo determinate operazioni o documenti) e **riprendere** dopo una disconnessione (usando un resume token) — rendendo i change streams resilienti.

## Casi d'uso comuni

```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).
```

## Perché è importante

I change streams sono una funzionalità preziosa di MongoDB per costruire **applicazioni reattive, event-driven e in tempo reale**, pertanto comprenderli è una conoscenza utile di livello senior per le applicazioni moderne che necessitano di reattività dei dati in tempo reale.

Il valore fondamentale è consentire alle applicazioni di **reagire ai cambiamenti dei dati in tempo reale** — ricevendo notifiche push quando i documenti vengono inseriti, aggiornati o eliminati — il che abilita capacità importanti: **funzionalità in tempo reale** (spingendo aggiornamenti live ai client via websocket quando i dati cambiano — un'esigenza comune per app collaborative, dashboard, notifiche), **sincronizzazione** (mantenendo cache, indici di ricerca come Elasticsearch, o altri sistemi coerenti con MongoDB mentre i dati cambiano), **architettura event-driven** (attivando workflow, notifiche, o elaborazione sui cambiamenti dei dati), e **auditing**.

Il vantaggio chiave è fare tutto questo **senza polling** — i change streams permettono al database di *spingere* i cambiamenti all'applicazione istantaneamente e efficientemente, sostituendo il modello dispendioso e a latenza più alta di interrogare ripetutamente "cosa è cambiato?" (che carica il database e ha ritardo).

Comprendere come osservare le collezioni, filtrare i cambiamenti (solo operazioni/documenti rilevanti), e riprendere dopo disconnessioni (usando resume token per resilienza) copre l'utilizzo pratico.

Sapere che i change stream richiedono un replica set è anche rilevante.

Poiché la reattività in tempo reale e il mantenimento dei sistemi sincronizzati sono esigenze di applicazione sempre più importanti, e poiché i change stream forniscono un modo efficiente basato su push per reagire ai cambiamenti dei dati MongoDB (molto migliore del polling), comprendere i change stream — cosa fanno, i loro casi d'uso (funzionalità in tempo reale, sincronizzazione, elaborazione event-driven), le capacità di resume/filter, e il vantaggio rispetto al polling — è una conoscenza preziosa di livello senior per costruire applicazioni MongoDB moderne e reattive, una funzionalità utile per l'esigenza comune di rispondere ai cambiamenti dei dati in tempo reale e un argomento che riflette la comprensione dei modelli di applicazione event-driven e in tempo reale con MongoDB.