Kas yra pokyčių srautai?

Question

Accepted Answer

**Pokyčių srautai** leidžia aplikacijoms **užsiregistruoti realaus laiko pokyčiams** MongoDB duomenimis — gauti pranešimus, kai dokumentai įterpiami, atnaujinami arba ištrinti. Jie suteikia galimybę kurti reaktyvias, įvykiais valdomus funkcijas (realaus laiko atnaujinimus, sinchronizavimą, trigerius) be duomenų bazės apklausimo. Suburti ant replikų rinkinio operacijų žurnalio.

## Pokytimų stebėjimas

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

Pokyčių sraute išmetamas įvykis kiekvienam pokyčiui (įterpimas/atnaujinimas/ištrynimas) su išsamia informacija apie tai, kas pasikeitė — todėl aplikacija reaguoja iš karto.

## Filtravimas ir atnaujinimas

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

Jūs galite **filtruoti** pokyčius (stebėti tik tam tikras operacijas ar dokumentus) ir **atnaujinti** po atjungimo (naudojant atnaujinimo žymeną) — padarant pokyčių srautus atspariais.

## Bendri naudojimo atvejai

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

## Pokyčių srautai ir apklausos

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

## Kodėl tai svarbu

Pokyčių srautai yra vertinga MongoDB funkcija **realaus laiko, reaktyvioms, įvykiais valdomoms aplikacijoms** kurti, todėl jų supratimas yra naudingas aukštos lygio žinios šiuolaikinėms aplikacijoms, kurioms reikalingas tiesioginės duomenų reaktyvumas.

Bendra vertė — **greitai reaguoti į duomenų pokyčius** — gauti šifavimo pranešimus, kai dokumentai įterpiami, atnaujinami arba ištrinti — kurie suteikia galimybes: **realaus laiko funkcijos** (siųsti tiesioginius atnaujinimus klientams per websocket'us, kai keičiasi duomenys — bendras poreikis bendradarbiaujančioms aplikacijoms, ataskaitoms, pranešimams), **sinchronizavimas** (paleisti podėlių, paieškos indeksų kaip Elasticsearch ar kitų sistemų suderinimą su MongoDB, kai keičiasi duomenys), **įvykiais valdoma architektūra** (sukelti darbo eigas, pranešimus ar apdorojimą keičiantis duomenims), ir **auditas**.

Pagrindinį privalumas yra visko tai atlikus **be apklausimo** — pokyčių srautai leidžia duomenų bazei *stumti* pokyčius į aplikaciją iš karto ir efektyviai, pakeičiant švaistytą, didesnio latentimo modelį pasikartojančio klausimo „kas pasikeitė?