Your company has mobile applications that collect user activity data. Your team plans to use BigQuery for analyzing this data, performing transformations, and experimenting with machine learning algorithms. To accomplish this, you need to set up a pipeline that ensures the real-time ingestion of user activity data into BigQuery. Considering the need for low-latency and high-volume data streaming, what should you do?