Implement Anomaly Detection Pipeline

Develop a real-time (or near real-time) data processing pipeline that ingests simulated market data. Implement a multi-stage anomaly detection system that identifies patterns characteristic of the manipulation scenarios you defined. You can use statistical methods, rule-based heuristics, or basic ML models. The pipeline should flag suspicious activities and provide relevant market context.