האתגר
מה עמד לפני MaxSense?
MaxSense חיברה אלפי חיישני IoT לפלטפורמה מרכזית, אך מנוע ה-Ingestion הישן לא יכול היה לעמוד בקצב של 50,000 Events לשנייה בשעות שיא. נתונים הלכו לאיבוד, Alerts על חריגות הגיעו באיחור של דקות, ולא הייתה יכולת אנליטיקה היסטורית על נתוני עבר.
הפתרון
מה בנינו
בנינו Streaming Pipeline מבוסס Apache Kafka ל-Ingestion בזמן אמת, עם Apache Flink ל-Stream Processing ומחשוב Aggregations בחלון זמן. נתונים נשמרים ב-TimescaleDB לאנליטיקה היסטורית. מנוע Alerting מבוסס כללים מגיב לחריגות תוך 800ms מרגע קבלת ה-Event.
תוצאות
מה השגנו יחד
✓Pipeline תומך ב-80,000 Events לשנייה ב-Production בלי אובדן נתונים
✓Latency מ-Sensor ל-Alert ירד מ-4 דקות ל-800ms
✓4.2 מיליארד Events היסטוריים נשמרים ב-TimescaleDB עם שאילתה תחת שנייה