A Real-Time Pipeline for Anomaly Detection and Explanation in Streaming Data
摘要
We present a prototype real-time pipeline for anomaly detection and explanation in streaming time series data. The system consists of four core modules: time series storage, anomaly detection, model-agnostic explanation, and interactive visualisation. It supports multiple detection methods and produces variable-level contribution scores to explain real-time anomalies. An explainability score is introduced to quantify interpretability, aiding domain experts in understanding alerts. The pipeline updates both detection and explanation modules incrementally using a window-based approach. Preliminary results show reliable detection and intuitive explanations. Our pipeline is fully containerised and distributed to facilitate demonstration and deployment, enabling quick setup and reproducibility. Future work will focus on continuous learning to adapt to new data without forgetting past patterns.