Describe how you would architect a data pipeline to ingest real-time telemetry from 10,000 global assets for ChampionX.