Mitä ovat muutosvirrat (change streams)?

Question

Accepted Answer

**Muutosvirrat** antavat sovellusten **tilata reaaliaikaisia muutoksia** MongoDB-tietoihin — saada ilmoituksia kun dokumentit lisätään, päivitetään tai poistetaan. Ne mahdollistavat reaktiivisia, tapahtumapohjaisia ominaisuuksia (reaaliaikaiset päivitykset, synkronointi, liipaisimet) ilman tietokannan kyselyä. Perustuvat replica set -oplogiin.

## Muutosten valvonta

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

Muutosvirta lähettää tapahtuman jokaiselle muutokselle (insert/update/delete), tiedoilla siitä mitä muuttui — joten sovellus reagoi reaaliajassa.

## Suodatus ja jatkaminen

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

Voit **suodattaa** muutoksia (valvoa vain tiettyjä operaatioita tai dokumentteja) ja **jatkaa** katkenneen yhteyden jälkeen (käyttäen jatkamismerkkiä) — mikä tekee muutosvirroista kestäviä.

## Yleiset käyttötapaukset

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

## Muutosvirrat vs kyselyt

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

## Miksi se on tärkeää

Muutosvirrat ovat arvokas MongoDB-ominaisuus **reaaliaikaisten, reaktiivisten, tapahtumapohjaisten sovellusten** rakentamiseen, joten niiden ymmärtäminen on hyödyllistä senior-tason tietoa moderneihin sovelluksiin, jotka tarvitsevat live-tietojen reaktiivisuutta.

Ydinarvona on mahdollistaa sovelluksille **reagoida tietojen muutoksiin reaaliajassa** — saada push-ilmoituksia kun dokumentit lisätään, päivitetään tai poistetaan — mikä mahdollistaa tärkeitä ominaisuuksia: **reaaliaikaiset ominaisuudet** (push-päivitysten lähettäminen asiakkaille websocketeissa kun tiedot muuttuvat — yleinen tarve yhteistyösovelluksissa, kojeissa, ilmoituksissa), **synkronointi** (välimuistin, hakuindeksien kuten Elasticsearchin tai muiden järjestelmien pitäminen yhdenmukaisten MongoDB:n kanssa kun tiedot muuttuvat), **tapahtumapohjainen arkkitehtuuri** (työnkulkujen, ilmoitusten tai käsittelyn liipaistaminen tietojen muuttuessa) ja **auditointi**.

Pääetu on tehdä kaikki tämä **ilman kyselyä** — muutosvirrat antavat tietokannan *lähettää* muutokset sovellukselle välittömästi ja tehokkaasti, korvaten tuhlattavan, hitaamman kuvion, jossa toistetaan "mitä muuttui?" -kyselyä (mikä kuormittaa tietokantaa ja sisältää viiveen).

Ymmärtäminen siitä, kuinka valvoa kokoelmia, suodattaa muutoksia (vain olennaiset operaatiot/dokumentit) ja jatkaa katkennon jälkeen (jatkamismerkkien avulla jatkuvuuden varmistamiseksi) kattaa käytännön käytön.

Tieto siitä, että muutosvirrat vaativat replica set -konfiguraatiota, on myös relevanttia.

Koska reaaliaikainen reaktiivisuus ja järjestelmien synkronointi ovat yhä tärkeämpiä sovelluksen tarpeita, ja koska muutosvirrat tarjoavat tehokkaan, push-pohjaisen tavan reagoida MongoDB-tietojen muutoksiin (paljon parempi kuin kyselyiden tekeminen), muutosvirtojen ymmärtäminen — mitä ne tekevät, niiden käyttötapaukset (reaaliaikaiset ominaisuudet, synkronointi, tapahtumapohjainen käsittely), jatkamis-/suodatusominaisuudet ja etu kyselyiden tekemiseen verrattuna — on arvokas senior-tason tieto modernien, reaktiivisten MongoDB-sovellusten rakentamiseen, hyödyllinen ominaisuus tavalliseen tarpeeseen reagoida tietojen muutoksiin reaaliajassa ja aihe, joka heijastaa ymmärrystä tapahtumapohjaisten ja reaaliaikaisten sovellusten malleista MongoDB:llä.