Data ingestion pipeline