You are a Machine Learning Engineer at a manufacturing company tasked with developing a real-time anomaly detection system for sensor data across multiple production lines. The system must process high-velocity data streams, identify anomalies with low latency, and store the results for further analytics and visualization. The solution must be cost-effective, scalable, and comply with industry standards for data security. Given these requirements, how would you best architect the pipeline using Google Cloud services? Choose the two most appropriate options. (Choose two)