Mik azok a change stream-ek?

Question

Accepted Answer

**A change stream-ek** lehetővé teszik az alkalmazások számára, hogy **valós idejű módosulásokra iratkozzanak fel** a MongoDB adatokba — értesítéseket kapva, amikor dokumentumok beszúrásra, frissítésre vagy törlésre kerülnek. Lehetővé teszik a reaktív, eseményvezérelt funkciókat (valós idejű frissítések, szinkronizálás, triggerek) az adatbázis lekérdezése nélkül. Az replica set oplog-on alapulnak.

## Módosulások figyelése

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

Egy change stream eseményt bocsát ki minden módosításra (beszúrás/frissítés/törlés), részletekkel arról, hogy mi változott — így az alkalmazás valós időben reagálhat.

## Szűrés és folytatás

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

A módosulásokat **szűrheti** (csak bizonyos műveletek vagy dokumentumok figyelése) és **folytathatja** a szétkapcsolódás után (resume token használatával) — így a change stream-ek rugalmassá válnak.

## Gyakori használati esetek

```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 stream-ek vs lekérdezés

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

## Miért fontos ez

A change stream-ek értékes MongoDB funkció **valós idejű, reaktív, eseményvezérelt alkalmazások** építéséhez, így az azok megértése hasznos senior szintű tudás a modern, élő adatreaktivitást igénylő alkalmazásoknál.

Az alapvető érték az, hogy az alkalmazások **valós időben reagálhassanak az adatváltozásokra** — push-értesítéseket kapva, amikor dokumentumok beszúrásra, frissítésre vagy törlésre kerülnek — ami fontos lehetőségeket tesz lehetővé: **valós idejű funkciók** (élő frissítések küldése az ügyfeleknek websocket-en keresztül az adatok változásakor — gyakori igény az együttműködő alkalmazások, irányítópultok, értesítések számára), **szinkronizálás** (cache-ek, keresési indexek (mint az Elasticsearch) vagy más rendszerek konzisztenciájának megőrzése a MongoDB-vel az adatok változásakor), **eseményvezérelt архитектúра** (munkafolyamatok, értesítések vagy feldolgozás kiváltása az adatváltozásokon), és **auditálás**.

A fő előny az, hogy mindez **lekérdezés nélkül** történik — a change stream-ek lehetővé teszik az adatbázis számára, hogy az **adatbázis azonnal és hatékonyan tolja** a módosulásokat az alkalmazásba, helyettesítve a pazarló, magasabb késleltetésű "mi változott?" ismételt lekérdezésének mintáját (amely terhelést jelent az adatbázisra és késleltetés van).

Annak megértése, hogy hogyan lehet figyelemmel kísérni a kollekciókat, szűrni a módosulásokat (csak releváns műveletek/dokumentumok) és folytatni a szétkapcsolódás után (resume tokenek használatával a rugalmasság érdekében) a praktikus használatot fedi le.

Az is releváns, hogy a change stream-ek replica set-et igényelnek.

Mivel a valós idejű reaktivitás és a rendszerek szinkronizálása egyre fontosabbak az alkalmazások szempontjából, és mivel a change stream-ek hatékony, push-alapú módot biztosítanak a MongoDB adatváltozásokra való reagálásra (sokkal jobb, mint a lekérdezés), a change stream-ek megértése — mit csinálnak, a felhasználási esetek (valós idejű funkciók, szinkronizálás, eseményvezérelt feldolgozás), a szinkronizálási/szűrési lehetőségek és az előny a lekérdezéssel szemben — hasznos senior szintű tudás a modern, reaktív MongoDB alkalmazások építéséhez, hasznos funkció a közös igényre, hogy valós időben reagáljunk az adatváltozásokra, valamint a téma tükrözi az eseményvezérelt és valós idejű alkalmazásmintázatok megértését a MongoDB-vel.