محرك رصد الحالات الشاذة: رصد أحداث لقاء AIS مباشرة

تنشر تغذيات AIS البحرية دفقا متواصلا من تحديثات مواقع السفن. رصد حدث ذي دلالة داخل هذا الدفق، كسفينتين تلتقيان في البحر بينما لا توجد أي منهما في ميناء، مشكلة بحث لا مشكلة لوحة بيانات. اختبرنا قدرتنا على رصد هذا النوع من اللقاءات والحالات الشاذة في التقارب في وقت قريب من الفعلي، كجهد بحثي خاص بنا، لا كمشروع لعميل.

كان الجزء الصعب هو الحجم. مقارنة كل سفينة بكل سفينة أخرى عند كل تحديث لا تبقى سريعة مع نمو الأسطول.

بنينا خط أنابيب الاستيعاب والمعالجة على Java 21 وSpring WebFlux، ببث تحديثات AIS الحية عبر Kafka. تُوضع مواقع السفن في خلايا جيوهاش، بحيث تُجرى فحوصات التقارب فقط مقابل السفن القريبة بدلا من الأسطول كاملا. يخزّن رسم بياني في Neo4j علاقات السفن، بحيث يمكن تتبع نمط لقاء عبر عدة اجتماعات بدلا من لقطة واحدة.

• استيعاب بث قائم على Kafka لبيانات AIS الحية
• تجميع بخلايا جيوهاش يحد من مقارنات التقارب
• نموذج رسم بياني في Neo4j يتتبع أنماط اجتماع سفن متعددة
• خط معالجة تفاعلي على Spring WebFlux

يعالج المحرك تدفقات AIS الحية ويرصد أحداث التقارب واللقاء بين السفن لحظة وقوعها. يبقي نهج خلايا جيوهاش المقارنات محدودة مع نمو عدد السفن. يعمل كمنتج بحثي داخلي، غير مرتبط بمشروع لعميل.