ચેஞ્જ સ્ટ્રીમ્સ શું છે?

Question

Accepted Answer

**ચેઞ્જ સ્ટ્રીમ્સ** એપ્લિકેશનને **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.
});
```

ચેઞ્જ સ્ટ્રીમ દરેક ચેઞ્જ (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 });
```

તમે ચેઞ્જ **ફિલ્ટર કરી શકો છો** (માત્ર ચોક્કસ ઑપરેશનો અથવા ડોક્યુમેન્ટ્સ જોવાઈ શકે છે) અને ડિસકનેક્શન પછી **રેઝ્યુમ કરી શકો છો** (રેઝ્યુમ ટોકનનો ઉપયોગ કરીને) — ચેઞ્જ સ્ટ્રીમ્સને સ્થિતિશીલ બનાતું છે.

## સામાન્ય ઉપયોગ કેસ્સ

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

## ચેઞ્જ સ્ટ્રીમ્સ વર્સેસ પોલિંગ

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

## તે શા માટે મહત્વપૂર્ણ છે

ચેઞ્જ સ્ટ્રીમ્સ **રીયલ-ટાઇમ, રીએક્ટિવ, ઈવેન્ટ-ડ્રિવન એપ્લિકેશનો** બનાવવા માટે MongoDB નું મૂલ્યવાન ફીચર છે, તેથી તેમને સમજવું આધુનિક એપ્લિકેશનો માટે ઉપયોગી સીનિયર-લેવલ જ્ઞાન છે જેને લાઈવ ડેટા રીએક્ટિવિટીની જરૂર છે.

મુખ્ય મૂલ્ય એપ્લિકેશનોને **ડેટા ચેઞ્જમાં રીયલ-ટાઇમમાં પ્રતિક્રિયા કરવા** સક્ષમ બનાવવું છે — જ્યારે ડોક્યુમેન્ટ્સ સંમિલિત, અપડેટ અથવા ડિલીટ થાય તો પુશ નોટિફિકેશન્સ પ્રાપ્ત કરવું — જે મહત્વપૂર્ણ ક્ષમતાઓને શક્તિ આપે છે: **રીયલ-ટાઇમ ફીચર્સ** (જ્યારે ડેટા ચેઞ્જ થાય ત્યારે websockets દ્વારા ક્લાયન્ટ્સને લાઈવ અપડેટ્સ પુશ કરવું — કોલાબોરેટિવ ઍપ્સ, ડેશબોર્ડ્સ, નોટિફિકેશનો માટે સામાન્ય જરૂર), **સિંક્રોનાઈજેશન** (કેશ્સ, Elasticsearch જેવી સર્ચ ઈન્ડેક્સ્સ અથવા અન્ય સિસ્ટમ્સને MongoDB સાથે સુસંગત રાખવું જ્યારે ડેટા ચેઞ્જ થાય), **ઈવેન્ટ-ડ્રિવન આર્કિટેક્ચર** (ડેટા ચેઞ્જ પર વર્કફ્લો, નોટિફિકેશનો અથવા પ્રોસેસિંગ ટ્રિગર કરવું), અને **ઓડિટિંગ**.

મુખ્ય ફાયદો આ બધું **પોલિંગ વિના** કરવું છે — ચેઞ્જ સ્ટ્રીમ્સ ડેટાબેસને ચેઞ્જ્સ તરત અને કુશળતાથી **પુશ કરવા દે છે** એપ્લિકેશનમાં, વારંવાર