Kaj so tokovi sprememb?

Question

Accepted Answer

**Tokovi sprememb** omogočajo aplikacijam, da se **naročijo na spremembe podatkov v realnem času** v MongoDB-ju — prejemajo obvestila, ko se dokumenti vstavijo, posodabljajo ali izbrišejo. Omogočajo reaktivne, Event-driven funkcionalnosti (posodobitve v realnem času, sinhronizacija, sprožilci) brez povpraševanja zbirke podatkov. Zgrajeni na repliki set oplog.

## Spremljanje sprememb

```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 sprememb oddaja dogodek za vsako spremembo (vstavljanje/posodabljanje/brisanje), s podrobnostmi o tem, kaj se je spremenilo — zato se aplikacija odzove v realnem času.

## Filtriranje in nadaljevanje

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

Spremembe lahko **filtrirate** (spremljate samo določene operacije ali dokumente) in **nadaljujete** po prekinitvi (z uporabo žetona za nadaljevanje) — kar naredi tokove sprememb odpornimi.

## Pogosti primeri uporabe

```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 sprememb v primerjavi s povpraševanjem

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

## Zakaj je to pomembno

Tokovi sprememb so dragocena funkcionalnost MongoDB-ja za gradnjo **aplikacij v realnem času, reaktivnih, Event-driven**, zato je njihovo razumevanje koristno znanje na višji ravni za sodobne aplikacije, ki potrebujejo dinamičnost podatkov v realnem času.

Osrednja vrednost je omogočanje aplikacijam, da se **odzvejo na spremembe podatkov v realnem času** — prejemajo obvestila (push), ko se dokumenti vstavijo, posodabljajo ali izbrišejo — kar omogoča pomembne zmogljivosti: **funkcionalnosti v realnem času** (pošiljanje živih posodobitev odjemalcem prek websocket-ov, ko se podatki spremenijo — pogosta potreba za sodelovalne aplikacije, nadzorne plošče, obvestila), **sinhronizacija** (ohranjanje predpomnilnikov, iskalnih indeksov, kot je Elasticsearch, ali drugih sistemov usklajenih z MongoDB-jem, ko se podatki spremenijo), **Event-driven arhitektura** (sprožanje delovnih tokov, obvestil ali obdelave pri spremembi podatkov), in **revizija**.

Ključna prednost je izvajanje vsega tega **brez povpraševanja** — tokovi sprememb pustijo zbirki podatkov, da *potisne* spremembe aplikaciji takoj in učinkovito, kar nadomesti neproduktivni vzorec, ki ima višjo zakasnitev, ki neprestano vprašuje "kaj se je spremenilo?" (kar obrementuje zbirko podatkov in ima zamudo).

Razumevanje, kako spremljati zbirke, filtrirati spremembe (samo relevantne operacije/dokumente) in nadaljevati po prekinitvah (z uporabo žetonov za nadaljevanje za odpornost) pokriva praktično uporabo.

Tudi vedeti, da tokovi sprememb zahtevajo repliko set, je pomembno.

Ker sta dinamičnost v realnem času in skladnost sistemov vse bolj pomembni potrebi aplikacij, in ker tokovi sprememb zagotavljajo učinkovit način, osnovan na potiskanju, da se odzvete na spremembe podatkov MongoDB-ja (bistveno bolje kot povpraševanje), je razumevanje tokov sprememb — kaj počnejo, njihovi primeri uporabe (funkcionalnosti v realnem času, sinhronizacija, Event-driven obdelava), zmogljivosti nadaljevanja/filtriranja in prednost pred povpraševanjem — dragoceno znanje na višji ravni za gradnjo sodobnih, reaktivnih aplikacij MongoDB-ja, koristna funkcionalnost za pogosto potrebo reagiranja na spremembe podatkov v realnem času in tema, ki odraža razumevanje vzorcev aplikacij, vzvezanih na dogodke in realnem času s MongoDB-jem.