You are designing a data pipeline for a smart city project that involves aggregating sensor data collected every minute from thousands of IoT devices deployed across the city. The project requires real-time analysis to monitor traffic flow, air quality, and energy usage to make immediate adjustments. Given the need for low latency processing, scalability to handle the volume of data, and the ability to provide real-time insights, which data pipeline type would you choose? (Choose one correct option)