خط أنابيب معالجة بيانات حركة المرور في الوقت الفعلي باستخدام NATS JetStream
2025-05-10
يصف هذا المقطع من التعليمات البرمجية خط أنابيب لمعالجة بيانات حركة المرور في الوقت الفعلي تم إنشاؤه باستخدام NATS JetStream. تأتي البيانات من رسائل على موضوع `traffic.light.events`، ويتم معالجتها عبر قائمة الانتظار `myqueue`. يقوم خط الأنابيب بتجميع البيانات حسب `traffic_light_id`، ويرسمها بيانياً لحساب إجمالي عدد السيارات والركاب لكل إشارة مرور، ثم يرسل البيانات المجمعة بطلب POST إلى `https://example.com/traffic_data`. يتم استخدام نوافذ زمنية ومعالجة الدُفعات لتحسين الكفاءة.
التطوير