Czym są strumienie zmian (change streams)?

Question

Accepted Answer

**Strumienie zmian** pozwalają aplikacjom **subskrybować zmiany w czasie rzeczywistym** w danych MongoDB — otrzymując powiadomienia gdy dokumenty są wstawiane, aktualizowane lub usuwane. Umożliwiają reaktywne, sterowane zdarzeniami funkcje (aktualizacje w czasie rzeczywistym, synchronizacja, triggery) bez odpytywania bazy danych. Zbudowane na bazie oplog zestawu replik.

## Obserwowanie zmian

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

Strumień zmian emituje zdarzenie dla każdej zmiany (wstawienie/aktualizacja/usunięcie), ze szczegółami na temat tego, co się zmieniło — aby aplikacja reagowała w czasie rzeczywistym.

## Filtrowanie i wznowienie

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

Możesz **filtrować** zmiany (obserwować tylko określone operacje lub dokumenty) i **wznowić** po rozłączeniu (używając tokenu wznowienia) — co czyni strumienie zmian odpornym.

## Typowe przypadki użycia

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

## Strumienie zmian a odpytywanie

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

## Dlaczego to ważne

Strumienie zmian to cenna funkcja MongoDB do budowania **aplikacji reaktywnych, sterowanych zdarzeniami, działających w czasie rzeczywistym**, dlatego zrozumienie ich jest przydatną wiedzą na poziomie seniora dla nowoczesnych aplikacji wymagających reaktywności danych na żywo.

Główną wartością jest umożliwienie aplikacjom **reagowania na zmiany danych w czasie rzeczywistym** — otrzymywania powiadomień push gdy dokumenty są wstawiane, aktualizowane lub usuwane — co umożliwia ważne możliwości: **funkcje czasu rzeczywistego** (wysyłanie live'owych aktualizacji do klientów przez websockety gdy dane się zmieniają — częsta potrzeba dla aplikacji współpracujących, dashboardów, powiadomień), **synchronizacja** (utrzymywanie cache'y, indeksów wyszukiwania takich jak Elasticsearch, czy innych systemów w zgodzie z MongoDB gdy dane się zmieniają), **architektura sterowana zdarzeniami** (uruchamianie przepływów pracy, powiadomień, lub przetwarzania przy zmianach danych), i **audyt**.

Główną zaletą jest robienie wszystkiego tego **bez odpytywania** — strumienie zmian pozwalają bazie danych *wypychać* zmiany do aplikacji natychmiast i efektywnie, zastępując marnotratwny, wyższym opóźnieniem schemat wielokrotnego pytania "co się zmieniło?" (co obciąża bazę danych i ma opóźnienie).

Zrozumienie jak obserwować kolekcje, filtrować zmiany (tylko odpowiednie operacje/dokumenty), i wznowić po rozłączeniach (używając tokenów wznowienia dla odporności) obejmuje praktyczne użycie.

Wiedzenie, że strumienie zmian wymagają zestawu replik jest również istotne.

Ponieważ reaktywność w czasie rzeczywistym i utrzymywanie systemów w synchronizacji są coraz ważniejszymi potrzebami aplikacji, a strumienie zmian zapewniają efektywny, oparty na wypychaniu sposób reagowania na zmiany danych MongoDB (znacznie lepszy niż odpytywanie), zrozumienie strumieni zmian — co robią, ich przypadki użycia (funkcje czasu rzeczywistego, synchronizacja, przetwarzanie sterowane zdarzeniami), możliwości wznowienia/filtrowania, i zaleta nad odpytywaniem — jest cenną wiedzą na poziomie seniora do budowania nowoczesnych, reaktywnych aplikacji MongoDB, przydatną funkcją dla wspólnej potrzeby reagowania na zmiany danych w czasie rzeczywistym i temat odzwierciedlający zrozumienie aplikacji sterowanych zdarzeniami i aplikacji czasu rzeczywistego z MongoDB.