Ce sunt change streams-urile?

Question

Accepted Answer

**Change streams-urile** permit aplicațiilor să se **aboneze la schimbări în timp real** în datele MongoDB — primind notificări când documentele sunt inserate, actualizate sau șterse. Ele activează funcții reactive și conduse de evenimente (actualizări în timp real, sincronizare, declanșatori) fără a face polling-ul bazei de date. Construite pe baza replicaset oplog-ului.

## Monitorizarea schimbărilor

```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 eveniment pentru fiecare schimbare (insert/update/delete), cu detalii despre ceea ce s-a schimbat — astfel încât aplicația răspunde în timp real.

## Filtrare și reluare

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

Poți **filtra** schimbări (monitorizează doar anumite operații sau documente) și **relua** după o deconectare (folosind un token de reluare) — făcând change streams-urile rezistente.

## Cazuri de utilizare frecvente

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

## De ce conteaza

Change streams-urile sunt o caracteristică valoroasă a MongoDB pentru construirea **aplicațiilor reactive, conduse de evenimente și în timp real**, deci înțelegerea lor este cunoștințe utile de nivel senior pentru aplicațiile moderne care necesită reactivitate live a datelor.

Valoarea de bază este permite aplicațiilor să **reacționeze la schimbări de date în timp real** — primind notificări push când documentele sunt inserate, actualizate sau șterse — ceea ce alimentează capabilități importante: **funcții în timp real** (trimiterea actualizărilor live către clienți prin websockets atunci când datele se schimbă — o nevoie comună pentru aplicații colaborative, tablouri de bord, notificări), **sincronizare** (menținerea cache-urilor, indexilor de căutare cum ar fi Elasticsearch, sau a altor sisteme în concordanță cu MongoDB pe măsură ce datele se schimbă), **arhitectură condusă de evenimente** (declanșarea fluxurilor de lucru, notificărilor sau procesării la schimbări de date), și **auditare**.

Avantajul cheie este realizarea tuturor acestor lucruri **fără polling** — change streams-urile permit bazei de date să *împingă* schimbări către aplicație instant și eficient, înlocuind modelul risipitor și cu latență mai mare de a interoga în mod repetat "ce s-a schimbat?" (ceea ce încarcă baza de date și are întârziere).

Înțelegerea modului de monitorizare a colecțiilor, filtrare a schimbărilor (doar operații/documente relevante) și reluare după deconectări (folosind tokenuri de reluare pentru rezistență) acoperă utilizarea practică.

Cunoscerea faptului că change streams-urile necesită un replica set este de asemenea relevantă.

Din moment ce reactivitatea în timp real și menținerea sistemelor în sincronizare sunt nevoi din ce în ce mai importante pentru aplicații, și din moment ce change streams-urile oferă un mod eficient, bazat pe push, pentru a reacționa la schimbări de date MongoDB (mult mai bun decât polling-ul), înțelegerea change streams-urilor — ceea ce fac, cazurile lor de utilizare (funcții în timp real, sincronizare, procesare condusă de evenimente), capacitățile de reluare/filtrare și avantajul față de polling — este cunoștințe valoroase de nivel senior pentru construirea aplicațiilor MongoDB moderne și reactive, o caracteristică utilă pentru necesitatea comună de a răspunde la schimbări de date în timp real și un subiect reflectând înțelegerea modelelor de aplicații conduse de evenimente și în timp real cu MongoDB.