Hva er endringsstrømmer?

Question

Accepted Answer

**Endringsstrømmer** lar applikasjoner **abonnere på sanntidsendringer** i MongoDB-data — motta varsler når dokumenter blir satt inn, oppdatert eller slettet. De muliggjør reaktive, hendelsesdrevne funksjoner (sanntidsoppdateringer, synkronisering, triggere) uten polling av databasen. Bygget på replica set oplog.

## Overvåking av endringer

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

En endringsstrøm sender en hendelse for hver endring (insert/update/delete), med detaljer om hva som endret seg — slik at applikasjonen reagerer i sanntid.

## Filtrering og gjenopptaking

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

Du kan **filtrere** endringer (bare overvåke bestemte operasjoner eller dokumenter) og **gjenoppta** etter en avbrutt forbindelse (ved å bruke en gjenopptakingstoken) — noe som gjør endringsstrømmer motstandsdyktige.

## Vanlige brukstilfeller

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

## Endringsstrømmer 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).
```

## Hvorfor det betyr noe

Endringsstrømmer er en verdifull MongoDB-funksjon for å bygge **sanntids-, reaktive, hendelsesdrevne applikasjoner**, så forståelsen av dem er nyttig kunnskap på seniorvå for moderne applikasjoner som trenger live datareaktivitet.

Kjernenverdien er å gjøre det mulig for applikasjoner å **reagere på dataendringer i sanntid** — motta push-varsler når dokumenter blir satt inn, oppdatert eller slettet — noe som muliggjør viktige muligheter: **sanntidsfunksjoner** (push av live oppdateringer til klienter via websockets når data endres — et vanlig behov for samarbeiidsapper, dashboards, varsler), **synkronisering** (holde cacher, søkeindekser som Elasticsearch, eller andre systemer i synk med MongoDB mens data endres), **hendelsesdreven arkitektur** (utløse arbeidsflyter, varsler, eller behandling ved dataendringer), og **revisjon**.

Hovedfordelen er å gjøre alt dette **uten polling** — endringsstrømmer lar databasen *skyve* endringer til applikasjonen øyeblikkelig og effektivt, og erstatter det sløsende, høyere-latens-mønsteret med gjentatt spørring "hva endret seg?" (som belaster databasen og har forsinkelse).

Forståelsen av hvordan du overvåker samlinger, filtrerer endringer (bare relevante operasjoner/dokumenter), og gjenopptar etter avbrutte forbindelser (ved å bruke gjenopptakingstokener for motstandsdyktighet) dekker praktisk bruk.

Det er også relevant å vite at endringsstrømmer krever et replica set.

Ettersom sanntidsreaktivitet og synkronisering av systemer er økende viktige applikasjonsbehov, og siden endringsstrømmer gir en effektiv, push-basert måte å reagere på MongoDB-dataendringer (mye bedre enn polling), er forståelsen av endringsstrømmer — hva de gjør, brukstilfellene deres (sanntidsfunksjoner, synkronisering, hendelsesdreven prosessering), muligheter for gjenopptaking/filtrering, og fordelen fremfor polling — verdifull kunnskap på seniorvå for å bygge moderne, reaktive MongoDB-applikasjoner, en nyttig funksjon for det vanlige behovet for å reagere på dataendringer i sanntid, og et emne som gjenspeiler forståelse av hendelsesdrevne og sanntidsapplikasjonsmønstre med MongoDB.