ما هي تدفقات التغييرات (Change Streams)؟

Question

Accepted Answer

**تدفقات التغييرات** تسمح للتطبيقات **بالاشتراك في التغييرات الفورية** في بيانات 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.
});
```

تصدر تدفق التغييرات حدثاً لكل تغيير (إدراج/تحديث/حذف)، مع تفاصيل حول ما تغيّر — بحيث يتفاعل التطبيق في الوقت الفعلي.

## التصفية والاستئناف

```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 مع تغيير البيانات)، **الهندسة الموجهة للأحداث** (تشغيل سير العمل أو الإشعارات أو المعالجة عند تغييرات البيانات)، و**التدقيق**.

الميزة الرئيسية هي فعل كل هذا **دون استقصاء** — تدفقات التغييرات تسمح لقاعدة البيانات *بدفع* التغييرات إلى التطبيق فوراً وبكفاءة، مستبدلة النمط المهدر وأعلى الكمون لتكرار الاستعلام "ماذا تغيّر؟" (الذي يحمّل قاعدة البيانات ويسبب تأخيراً).

فهم كيفية مراقبة المجموعات وتصفية التغييرات (العمليات/المستندات الملائمة فقط) والاستئناف بعد قطع الاتصال (باستخدام رموز الاستئناف للمرونة) يغطي الاستخدام العملي.

معرفة أن تدفقات التغييرات تتطلب مجموعة نسخ متماثلة مهمة أيضاً.

بما أن التفاعل الفوري وإبقاء الأنظمة متزامنة احتياجات تطبيق متزايدة الأهمية، وبما أن تدفقات التغييرات توفر طريقة فعالة موجهة للدفع للاستجابة لتغييرات بيانات MongoDB (أفضل بكثير من الاستقصاء)، فإن فهم تدفقات التغييرات — ما تفعله وحالات استخدامها (الميزات الفورية والمزامنة ومعالجة الأحداث) وقدرات الاستئناف والتصفية والميزة على الاستقصاء — هو معرفة مفيدة على مستوى أول لبناء تطبيقات MongoDB تفاعلية حديثة وميزة مفيدة للاحتياج الشائع للاستجابة لتغييرات البيانات في الوقت الفعلي وموضوع يعكس فهماً لأنماط التطبيقات الموجهة للأحداث والفورية مع MongoDB.