რა არის ცვლილების ნაკადები?

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.
});
```ცვლილების ნაკადი აღმოაჩენს მოვლენას თითოეული ცვლილებისთვის (ჩასმა/განახლება/წაშლა), რომელიც შეიცავს დეტალებს იმის შესახებ, თუ რა შეიცვალა — ასე რომ აპლიკაცია რეაგირებს რეალურ დროში.## ფილტრაცია და განახლება```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 ფუნქცია **რეალურ დროის, რეაქტიული, მოვლენზე დაფუძნებული აპლიკაციების** აგებისთვის, ამიტომ მათი გაგება სასარგებლო უმცროსი დონის ცოდნაა თანამედროვე აპლიკაციებისთვის, რომელთაც სჭირდება ცოცხალი მონაცემთა რეაქტიულობა.ძირითადი ღირებულება აპლიკაციების **რეაქციის დაშვება მონაცემთა ცვლილებებზე რეალურ დროში** — მიიღოს push შეტყობინებები დოკუმენტების ჩასმისას, განახლებისას ან წაშლისას — რომელიც აძლევს მნიშვნელოვან უნარებს: **რეალური დროის ფუნქციები** (ცოცხალი განახლებების push კლიენტებზე websockets-ის მეშვეობით მონაცემთა ცვლილებისას — ზოგადი მოთხოვნა თანამშრომლობითი აპლიკაციებისთვის, დაფდასა და შეტყობინებებისთვის), **სინქრონიზება** (ქეშების, ძებნის ინდექსების როგორც Elasticsearch, ან სხვა სისტემების თანმიმდევრობის შენარჩუნება MongoDB-თან მონაცემთა ცვლილებაში), **მოვლენზე დაფუძნებული არქიტექტურა** (სამუშაოთა ნაკადების, შეტყობინებების ან დამუშავების აქტივაცია მონაცემთა ცვლილებებში), და **აუდიტი**.ძირითადი უპირატესობა ამ ყველაფრის შესრულება **დიდი რაოდენობის მოთხოვნის გარეშე** — ცვლილების ნაკადები სთხოვენ ბაზას *push* ცვლილებებს აპლიკაციაში მყისიერად და ეფექტურად, ჩაანაცვლებს აკიცხველ, უფრო მაღალი ლატენტობის ნიმუშს განმეორებითი გამოკითხვის