Design the Telemetry Data Processing Pipeline

Outline a robust and scalable architecture for ingesting and processing high-volume, real-time telemetry data from a fleet of distributed BESS units. Consider how to handle data heterogeneity (different sensor types, sampling rates), missing data, and potential out-of-order events. Specify how Ray will be used to parallelize feature engineering steps (e.g., windowed statistics, frequency domain transforms) across multiple data streams or BESS units.