real-time data processing pipeline