You are designing a data processing solution to support real-time analytics for a retail company. The system must process high-velocity data from IoT sensors, apply transformations, and load the refined data into BigQuery for real-time querying. Which approach should you use to ensure low-latency data processing and scalability?