iot-telemetry

An ultra-fast, memory-efficient streaming telemetry analytics pipeline built with Polars and DuckDB, featuring out-of-core aggregations and real-time anomaly detection benchmarks.

CATALYST is An intelligent in-cabin co-pilot for CAT heavy machinery combining real-time safety telemetry, task workflows, and ML-powered task duration estimation.

Autonomous Hydraulic Telemetry & Plumber Voice Dispatch Engine — Hazen-Williams head loss solver, leak diagnostics & WebRTC intake.

Interactive global container logistics & maritime IoT command center powered by Google Gemini AI and Zero-Trust telemetry.

💧 Plataforma de resiliencia hídrica urbana, inteligencia territorial SIG, extracción somera frugal, tratamiento 80/20 POU y telemetría regulada para Tijuana.

Implementación física integral (Full-Stack IoT) para la digitalización concurrente y visualización telemétrica de campos electromagnéticos en equipos TMS, erradicando la latencia secuencial.

AI-based early warning & landslide risk monitoring system in NER (MDoNER PS 26001). 95.89% recall ML pipeline, DLHI index & Leaflet GIS dashboard.

An enterprise-grade, hardware-optimized timeseries database compression engine in Rust. Achieves a 21.5% compression ratio (40% smaller than GZIP) on 2M+ rows, while offering 10x-250x faster block-level random-access queries ($O(1)$ seeks) using Double-Delta and Gorilla float XOR codecs. C-FFI compatible.

Production-grade, decoupled IoT telemetry streaming pipeline ingesting sensor data via Kafka, filtering anomalies with PySpark, orchestrating via Mage AI, and modeling in Snowflake with dbt.

Enterprise IoT telemetry gateway built with Spring Boot, Apache Kafka, Docker, Terraform, and H2. Processes real-time sensor data using Kafka producers and consumers, detects critical alerts, and stores telemetry events.

Low-latency real-time fleet telemetry pipeline. Ingests, validates, and statefully aggregates (sliding event-time windows) vehicle diagnostics under 148ms. Features Kafka buffers, PyFlink stream-processing, S3 checkpoints, and Redis active cache serving. Handles 50k events/sec with custom watermark handling, and schema validation gates.

Pinpoints the machines driving factory downtime and the roles driving pay inequality — pandas, SciPy

ABDM-compliant rural health grid featuring on-device Edge AI clinical triage, IoT cold-chain telemetry, SEIR outbreak radar, and autonomous drone logistics.

Urban Water Leakage & Loss Detection Intelligence System with Real-Time IoT Telemetry, Z-Score Anomaly Engine, GIS Choropleth Mapping, and Dual-Corroborated Citizen Dispatch

Enterprise-grade Event-Driven Architecture (EDA) for maritime logistics. Built with AWS CDK, Node.js, and React. Features Hybrid Compute (Lambda/Docker), Polyglot Persistence (DynamoDB/RDS), Zero-Trust Security via Cognito, and 100% Test Coverage.

Blynk 2.0 Cloud IoT servo actuator framework with bidirectional Virtual Pin telemetry and auto-reconnect

Industrial IoT predictive maintenance engine forecasting cold-chain thermal excursions with 81.5% calibrated quantile prediction intervals & physics-informed rolling features.

Enterprise-grade real-time industrial anomaly detection & self-retraining MLOps platform: Kafka streaming, Great Expectations firewall, 17-dim feature store, Isolation Forest champion model, sub-8ms FastAPI serving, Prometheus/Grafana observability, drift monitoring (PSI/KS), and zero-downtime K8s CI/CD.

End-to-End ETL pipeline integrating solar power generation metrics with weather telemetry data for predictive analytics.

An industrial IoT Edge-to-Cloud telemetry solution featuring real-time electrical computations, threshold fault logic, tabular CSV data logging, and professional PDF compliance reporting.