How would you design a high-throughput system to ingest and process real-time health data from wearable devices?