Prepare representative telemetry
Collect and clean time-stamped sensor streams; simulate missing data, noise and device-specific scaling before splitting into train and test sets.
Stream sensor telemetry. Flag anomalous readings.
A streaming sensor dashboard ingests time-series telemetry, runs a lightweight inference model at the edge and surfaces alerts when values or model outputs cross thresholds. Important practical concerns are single-sample latency, model size and false-alert rate when operating on noisy or missing readings.
Learning concept · Not a validated service
A streaming sensor dashboard ingests time-series telemetry, runs a lightweight inference model at the edge and surfaces alerts when values or model outputs cross thresholds. Important practical concerns are single-sample latency, model size and false-alert rate when operating on noisy or missing readings.
A proposed use: continuously monitor device telemetry (temperature, vibration or battery) and surface alerts to a technician dashboard. Keep a human in the loop for any corrective action; this starter does not implement device integration or automated actuation.
Collect and clean time-stamped sensor streams; simulate missing data, noise and device-specific scaling before splitting into train and test sets.
Train a compact classifier or anomaly detector that meets latency and memory targets; prefer models that can be converted to edge runtimes.
Run many repeated single-sample predictions on the target hardware or a close proxy and record median and tail latency.
Select alert thresholds and evaluate precision, recall and false-alert rate on a temporally separated test set; inspect failure cases manually.
The supplied starter generates a synthetic classification dataset with sklearn.make_classification, trains a DecisionTreeClassifier, runs repeated single-sample predictions to estimate per-sample latency, and prints basic tree stats. It does not ingest real sensor telemetry, connect to MQTT, nor implement a dashboard or alerting logic.
X, y = make_classification(n_samples=1000, n_features=12, n_informative=8, random_state=42)
model = DecisionTreeClassifier(max_depth=6, random_state=42)
model.fit(X, y)
sample = X[:1]
start = time.perf_counter()
for _ in range(1000):
model.predict(sample)
latency_ms = (time.perf_counter() - start) * 1000 / 1000The code uses randomly generated feature vectors, not sensor telemetry, and does not implement streaming ingestion, time-series preprocessing, alert thresholds or any deployment artefacts such as MQTT, TensorFlow Lite or an API. Latency is measured in-process on the development machine and will differ on edge hardware.
A proposed extension: replace the synthetic data with recorded device telemetry, add time-window features or an online anomaly detector, expose predictions via a small REST/MQTT service and log alerts to a dashboard for human review.
This is a potential application pathway, not a delivered product. The supplied starter does not implement this service or validate it with real users.
Networkers Home runs this topic inside its Network Engineering Course, with placement support and hands-on labs.