Change streams के बारे मा के हो?

Question

Accepted Answer

**Change streams** ले applications लाई **MongoDB डेटामा रीयल-टाइम परिवर्तनहरूको ताबेदारी गर्न** सक्षम गरिदिन्छ — कागजातहरू सम्मिलित, अद्यावधिक वा मेटिएको बेलामा सूचनाहरू प्राप्त गर्दै। तिनीहरूले डेटाबेसको पोलिङ गरी बिना रीयल-टाइम अद्यावधिकहरू, सिंकिङ, ट्रिगरहरू जस्ता प्रतिक्रियाशील, घटना-संचालित सुविधाहरू सक्षम गर्छन्। रेप्लिका सेट oplog मा निर्मित।

## परिवर्तनहरूको लागि हेर्दै

```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 ले प्रत्येक परिवर्तनको लागि एक घटना उत्सर्जन गर्छ (सम्मिलित/अद्यावधिक/मेटिए), के परिवर्तन भएको बारेमा विवरणहरू सहित — ताकि अनुप्रयोग रीयल-टाइममा प्रतिक्रिया गर्छ।

## निस्पंदन र पुनरारम्भ

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

तपाई परिवर्तनहरू **निस्पंदन** गर्न सक्नुहुन्छ (केवल निश्चित अपरेशन वा कागजातहरू हेर्न) र डिस्कनेक्शनको पछि **पुनरारम्भ** गर्न सक्नुहुन्छ (resume token प्रयोग गरी) — change streams लाई तनिसुकी बनाइदै।

## सामान्य प्रयोग केसहरू

```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 बनाम पोलिङ

```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 हेर्ने सङ्कलनहरू, परिवर्तनहरू निस्पंदन गर्ने (केवल प्रासङ्गिक अपरेशनहरू/कागजातहरू), र डिस्कनेक्शनहरूको पछि पुनरारम्भ गर्ने (resilience को लागि resume tokens प्रयोग गरी) **रीयल-टाइम, प्रतिक्रियाशील, घटना-संचालित अनुप्रयोगहरू** निर्माण गर्नको लागि मूल्यवान MongoDB सुविधा हो, त्यसैले तिनीहरूलाई बुझ्नु आधुनिक अनुप्रयोगहरूको लागि उपयोगी वरिष्ठ-स्तरको ज्ञान हो जसलाई लाइभ डेटा reactivity को आवश्यकता छ।

मूल मूल्य अनुप्रयोगहरूलाई **डेटा परिवर्तनहरूमा रीयल-टाइममा प्रतिक्रिया गर्न** सक्षम गर्नु हो — कागजातहरू सम्मिलित, अद्यावधिक वा मेटिएको बेलामा पुश सूचनाहरू प्राप्त गर्दै — जो महत्त्वपूर्ण क्षमताहरूलाई शक्ति दिन्छ: **रीयल-टाइम सुविधाहरू** (websockets माध्यमबाट डेटा परिवर्तन हुँदा ग्राहकहरूलाई लाइभ अद्यावधिकहरू पुश गर्दै — सहयोगी अनुप्रयोगहरू, ड्यासबोर्डहरू, सूचनाहरूको लागि सामान्य आवश्यकता), **सिंकिङ** (क्यासहरू, Elasticsearch जस्ता खोज अनुक्रमणिका, वा अन्य प्रणाली MongoDB सँग सुसंगत राख्दै डेटा परिवर्तन हुँदा), **घटना-संचालित आर्किटेक्चर** (कार्यप्रवाहहरू, सूचनाहरू, वा डेटा परिवर्तनहरूमा प्रसंस्करण ट्रिगर गर्दै), र **अडिटिङ**।

मुख्य लाभ सबै यो गरी **पोलिङ बिना** हो — change streams ले डेटाबेसलाई अनुप्रयोगमा परिवर्तनहरू तुरुन्त र कुशलतापूर्वक *पुश* गर्न दिन्छ,