Your company is launching a new mobile application and plans to use BigQuery for real-time analysis, transformation, and ML experimentation of user activity data. The team is considering various approaches to ensure real-time ingestion of this data into BigQuery. The solution must be scalable, cost-effective, and capable of handling high volumes of data with low latency. Which of the following approaches should your team adopt? (Choose one correct option)