Change streams म्हणजे काय?

Question

Accepted Answer

**Change streams** अनुप्रयोगांना MongoDB डेटामधील **वास्तविक-समय बदलांसाठी सदस्यता घेणे** सक्षम करतात — जेव्हा दस्तऐवज घालवले जातात, अपडेट केले जातात किंवा हटवले जातात तेव्हा सूचना प्राप्त करतात. ते डेटाबेससमोरून पोल केल्याशिवाय प्रतिक्रियाशील, इव्हेंट-चालित वैशिष्ट्ये (वास्तविक-समय अपडेट, समन्वयन, ट्रिगर) सक्षम करतात. Replica set 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.
});
```

A change stream प्रत्येक बदलासाठी एक इव्हेंट उत्सर्जित करतो (insert/update/delete), काय बदलले याच्या तपशीलांसह — जेणेकरून अनुप्रयोग वास्तविक वेळेत प्रतिक्रिया देतो.

## फिल्टरिंग आणि पुनः सुरू करणे

```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 **वास्तविक-समय, प्रतिक्रियाशील, इव्हेंट-चालित अनुप्रयोग** बांधण्यासाठी एक मूल्यवान MongoDB वैशिष्ट्य आहे, त्यामुळे त्यांना समजून घेणे आधुनिक अनुप्रयोगांसाठी वरिष्ठ-स्तरीय ज्ञान उपयोगी आहे ज्यांना लाइव्ह डेटा प्रतिक्रियाशीलता आवश्यक आहे.

मूल मूल्य अनुप्रयोगांना **वास्तविक वेळेत डेटा बदलांना प्रतिक्रिया देणे** सक्षम करणे आहे — जेव्हा दस्तऐवज घालवले जातात, अपडेट केले जातात किंवा हटवले जातात तेव्हा पुश सूचना प्राप्त करतात — जे महत्वाचे क्षमता शक्तिशाली करतात: **वास्तविक-समय वैशिष्ट्ये** (डेटा बदलते तेव्हा websockets द्वारे ग्राहकांना लाइव्ह अपडेट पुश करणे — सहयोगी अनुप्रयोग, डॅशबोर्ड, सूचनांसाठी सामान्य आवश्यकता), **समन्वयन** (कॅश, Elasticsearch सारख्या शोध निर्देशिका, किंवा इतर प्रणाली MongoDB सह सुसंगत ठेवणे जेव्हा डेटा बदलतो), **इव्हेंट-चालित आर्किटेक्चर** (कार्यप्रवाह, सूचना, किंवा डेटा बदलांवर प्रक्रिया ट्रिगर करणे), आणि **ऑडिटिंग**.

मुख्य लाभ असा आहे की सर्व काही **पोलिंग न करता** — change streams डेटाबेसला अनुप्रयोगाला बदल तात्काळ आणि कार्यक्षमतेने *पुश* करू देतात, "काय बदलले?" बारंबार प्रश्न विचारण्याच्या व्यर्थ, उच्च-विलंब पद्धतीची जागा घेतात (ज्यामुळे डेटाबेस लोड होतो आणि विलंब आहे).

संग्रह पहाणे, बदल फिल्टर करणे (फक्त प्रासंगिक ऑपरेशन/दस्तऐवज), आणि डिस्कनेक्शनानंतर पुनः सुरू करणे (लचकदारपणासाठी resume tokens वापरून) व्यावहारिक वापराचा कव्हर करते.

Change streams साठी replica set आवश्यक असे जाणून घेणे देखील प्रासंगिक आहे.

वास्तविक-समय प्रतिक्रियाशीलता आणि प्रणाली समन्वयित ठेवणे हे वाढतेच महत्वाचे अनुप्रयोग आवश्यकता आहेत, आणि change streams MongoDB डेटा बदलांना प्रतिक्रिया देण्याचा एक कार्यक्षम, पुश-आधारित मार्ग प्रदान करतात (पोलिंगपेक्षा खूपच चांगले), change streams समजून घेणे — ते काय करतात, त्यांचे वापराचे प्रकरण (वास्तविक-समय वैशिष्ट्ये, समन्वयन, इव्हेंट-चालित प्रक्रिया), resume/filter क्षमता, आणि पोलिंगवर लाभ — आधुनिक, प्रतिक्रियाशील MongoDB अनुप्रयोग बांधण्यासाठी मूल्यवान वरिष्ठ-स्तरीय ज्ञान आहे, डेटा बदलांना वास्तविक वेळेत प्रतिक्रिया देण्यासाठी सामान्य आवश्यकतेसाठी एक उपयोगी वैशिष्ट्य आणि MongoDB सह इव्हेंट-चालित आणि वास्तविक-समय अनुप्रयोग पद्धतींची समज दर्शविणारा विषय.