Design a real-time streaming pipeline that ingests IoT sensor data, processes it for anomalies, and triggers alerts.
