Change streams क्या हैं?

Question

Accepted Answer

**Change streams** applications को MongoDB data में **real-time changes की subscribe करने** देती हैं — documents के insert, update, या delete होने पर notifications प्राप्त करना। वे database को poll किए बिना reactive, event-driven features (real-time updates, syncing, triggers) सक्षम करती हैं। replica set oplog पर निर्मित।

## Changes के लिए watch करना

```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 प्रत्येक change (insert/update/delete) के लिए एक event emit करता है, इस बारे में विवरण के साथ कि क्या बदला — ताकि application real time में react करे।

## Filtering और resuming

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

आप changes को **filter** कर सकते हैं (केवल कुछ operations या documents को watch करना) और एक disconnection के बाद **resume** कर सकते हैं (एक resume token का उपयोग करते हुए) — change streams को resilient बनाना।

## सामान्य उपयोग के मामले

```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 बनाम 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).
```

## यह क्यों महत्वपूर्ण है

Change streams **real-time, reactive, event-driven applications** बनाने के लिए एक मूल्यवान MongoDB feature है, इसलिए इन्हें समझना live data reactivity की आवश्यकता वाली आधुनिक applications के लिए उपयोगी senior-स्तरीय ज्ञान है।

मूल मूल्य applications को **real time में data changes पर react करने** में सक्षम बनाना है — documents के insert, update, या delete होने पर push notifications प्राप्त करना — जो महत्वपूर्ण क्षमताओं को शक्ति देता है: **real-time features** (data बदलने पर websockets के माध्यम से clients को live updates push करना — collaborative apps, dashboards, notifications के लिए एक सामान्य आवश्यकता), **syncing** (data बदलने पर caches, search indexes जैसे Elasticsearch, या अन्य systems को MongoDB के साथ सुसंगत रखना), **event-driven architecture** (data changes पर workflows, notifications, या processing को trigger करना), और **auditing**।

मुख्य लाभ यह सब **polling के बिना** करना है — change streams database को application को changes तुरंत और कुशलता से *push* करने देती हैं, बार-बार "क्या बदला?" query करने के बेकार, उच्च-latency pattern को प्रतिस्थापित करते हुए (जो database पर load डालता है और देरी रखता है)।

यह समझना कि collections को कैसे watch करें, changes को filter करें (केवल प्रासंगिक operations/documents), और disconnections के बाद resume करें (resilience के लिए resume tokens का उपयोग करते हुए) व्यावहारिक उपयोग को कवर करता है।

यह जानना कि change streams को एक replica set की आवश्यकता होती है भी प्रासंगिक है।

चूँकि real-time reactivity और systems को sync में रखना तेजी से महत्वपूर्ण application जरूरतें हैं, और चूँकि change streams MongoDB data changes पर react करने का एक कुशल, push-आधारित तरीका प्रदान करती हैं (polling से कहीं बेहतर), change streams को समझना — वे क्या करती हैं, उनके उपयोग के मामले (real-time features, syncing, event-driven processing), resume/filter क्षमताएँ, और polling पर लाभ — आधुनिक, reactive MongoDB applications बनाने के लिए मूल्यवान senior-स्तरीय ज्ञान है, real time में data changes पर प्रतिक्रिया देने की सामान्य आवश्यकता के लिए एक उपयोगी feature और MongoDB के साथ event-driven तथा real-time application patterns की समझ को दर्शाने वाला एक विषय।