Što su tokovi promjena (change streams)?

Question

Accepted Answer

**Tokovi promjena** omogućuju aplikacijama **pretplatu na promjene u stvarnom vremenu** u MongoDB podacima — primanje obavijesti kada se dokumenti umetnu, ažuriraju ili izbrišu. Omogućuju reaktivne, event-driven značajke (ažuriranja u stvarnom vremenu, sinkronizacija, okidači) bez poliiranja baze podataka. Izgrađeni na temelju replike skupa oplog.

## Praćenje promjena

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

Tok promjena emitira događaj za svaku promjenu (umetanje/ažuriranje/brisanje), s detaljima o tome što se promijenilo — tako da aplikacija reagira u stvarnom vremenu.

## Filtriranje i nastavak

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

Možete **filtrirati** promjene (pratiti samo određene operacije ili dokumente) i **nastaviti** nakon prekida veze (korištenjem tokena za nastavak) — čineći tokove promjena otpornim.

## Česti slučajevi korištenja

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

## Tokovi promjena naspram poliiranja

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

## Zašto je važno

Tokovi promjena su vrijedna MongoDB značajka za izgradnju **aplikacija u stvarnom vremenu, reaktivnih, event-driven aplikacija**, tako da je razumijevanje njih korisno znanje razine seniora za moderne aplikacije koje trebaju reaktivnost živih podataka.

Temeljena vrijednost je omogućavanje aplikacijama da **reagiraju na promjene podataka u stvarnom vremenu** — primanje push obavijesti kada se dokumenti umetnu, ažuriraju ili izbrišu — što omogućava važne mogućnosti: **značajke u stvarnom vremenu** (slanje živih ažuriranja klijentima putem websocketa kada se podaci promijene — čest zahtjev za suradničke aplikacije, nadzorne ploče, obavijesti), **sinkronizacija** (održavanje cache-a, indeksa pretraživanja poput Elasticsearch-a ili drugih sustava u skladu s MongoDB-om kako se podaci mijenjaju), **event-driven arhitektura** (pokretanje radnih tijekova, obavijesti ili obrade na promjene podataka) i **nadzor**.

Klučna prednost je sve to raditi **bez poliiranja** — tokovi promjena omogućuju bazi podataka da *proslijedi* promjene aplikaciji trenutno i učinkovito, zamjenjujući rasipnu, visokolatentu šemu ponavljanja upita "što se promijenilo?" (što opterećuje bazu podataka i ima kašnjenje).

Razumijevanje kako pratiti kolekcije, filtrirati promjene (samo relevantne operacije/dokumente) i nastaviti nakon prekida veze (korištenjem tokena za nastavak za otpornost) pokriva praktičnu upotrebu.

Znanje da tokovi promjena zahtijevaju replike skupa je također relevantno.

Budući da su reaktivnost u stvarnom vremenu i održavanje sustava u sinkronizaciji sve važniji zahtjevi aplikacija, i budući da tokovi promjena pružaju učinkovit, push-based način da reagiraju na promjene MongoDB podataka (daleko bolje od poliiranja), razumijevanje tokova promjena — što oni rade, njihovi slučajevi korištenja (značajke u stvarnom vremenu, sinkronizacija, event-driven obrada), mogućnosti nastavka/filtriranja i prednost u odnosu na poliiranje — je vrijednost znanja razine seniora za izgradnju modernih, reaktivnih MongoDB aplikacija, korisne značajke za čest zahtjev za reagiranjem na promjene podataka u stvarnom vremenu i tema koja odražava razumijevanje event-driven i aplikacija sa stvarnom vremenom s MongoDB-om.