Co jsou Change Streams?

Question

Accepted Answer

**Change streams** umožňují aplikacím **přihlásit se k odběru změn v reálném čase** v datech MongoDB — obdrží notifikace, když jsou dokumenty vloženy, aktualizovány nebo smazány. Umožňují reaktivní, event-driven funkce (aktualizace v reálném čase, synchronizace, triggery) bez dotazování databáze. Jsou postaveny na replica set oplog.

## Sledování změn

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

Change stream emituje event pro každou změnu (insert/update/delete), s detaily o tom, co se změnilo — takže se aplikace reaguje v reálném čase.

## Filtrování a obnovování

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

Můžete **filtrovat** změny (sledovat pouze určité operace nebo dokumenty) a **obnovit** se po odpojení (pomocí resume tokenu) — což dělá change streamy odolnými.

## Běžné případy použití

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

## Change streams vs dotazování

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

## Proč to není jedno

Change streams jsou cennou funkcí MongoDB pro vytváření **aplikací v reálném čase, reaktivních a event-driven**, takže jejich porozumění je užitečné znalostí senior úrovně pro moderní aplikace vyžadující reaktivitu živých dat.

Hlavní hodnota je umožnit aplikacím **reagovat na změny dat v reálném čase** — obdrží push notifikace, když jsou dokumenty vloženy, aktualizovány nebo smazány — což zajišťuje důležité schopnosti: **funkce v reálném čase** (odesílání živých aktualizací klientům přes websockety, když se data změní — běžná potřeba pro kolaborativní aplikace, dashboardy, notifikace), **synchronizace** (zachování konzistence mezipaměti, vyhledávacích indexů jako Elasticsearch nebo ostatních systémů s MongoDB, jak se data mění), **event-driven architektura** (spouštění pracovních postupů, notifikací nebo zpracování při změnách dat), a **audit**.

Klíčová výhoda je provádění všeho tohoto **bez dotazování** — change streamy umožňují databázi *poslat* změny aplikaci okamžitě a efektivně, což nahrazuje plýtvající, vyšší latenci způsobený opakovaným dotazováním „co se změnilo?