How would you design a data ingestion pipeline that processes real-time events and stores them in a cloud data warehouse?
