النوافذ وتدفقات التغيير والنتائج المصانة

db.getSiblingDB('quay_lab').aggregate([
  { $documents: [{ seq: 1, amount: 5 }, { seq: 2, amount: 8 }, { seq: 3, amount: 2 }] },
  { $setWindowFields: { sortBy: { seq: 1 }, output: {
    running: { $sum: '$amount', window: { documents: ['unbounded', 'current'] } }
  } } },
  { $project: { _id: 0, seq: 1, running: 1 } },
  { $sort: { seq: 1 } }
]);

{ seq: 1, running: 5 }
{ seq: 2, running: 13 }
{ seq: 3, running: 15 }

النافذة تراكم وثائق مرتبة لا مدة ساعة.

// Driver fragment: collection and processIdempotently are supplied by the application.
const stream = collection.watch([{ $match: { operationType: 'insert' } }]);
try {
  for await (const event of stream) {
    await processIdempotently(event._id, event.fullDocument);
    break;
  }
} finally { await stream.close(); }

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