How jnbalaji-jb/rigpulse-telemetry-lab works
RigPulse is a local industrial-telemetry reliability lab. Its main workflow is to generate reproducible telemetry (or ingest CSV), validate and persist readings, score them with interpretable detectors, then inspect alerts and evaluate results. Separate analysis branches report distribution drift and compare alerts with synthetic ground truth. The CLI orchestrates batch workflows; a FastAPI read API serves the browser dashboard. The graph reflects implemented capabilities; planned streaming, multivariate ML, and incident management are not runtime components. Relationships are limited to README statements and the sampled source; unsampled implementation details are omitted.
Main entry points: cli.py CLI commands · storage.py SQLite readings & alerts · api.py FastAPI read API · ingest.py CSV ingestion
Components 13
Batch Workflow
- CLI commands
src/rigpulse/cli.py - Telemetry simulator
src/rigpulse/simulate.py - CSV ingestion
src/rigpulse/ingest.py - Synthetic labels
src/rigpulse/simulate.py
Reliability Analysis
- Alert detection
src/rigpulse/detection.py - PSI drift report
src/rigpulse/drift.py - Label evaluation
src/rigpulse/evaluation.py
Read API & Dashboard
- FastAPI read API
src/rigpulse/api.py - Telemetry dashboard
src/rigpulse/web/app.js
Domain & Persistence
- Reading validation
src/rigpulse/models.py - SQLite readings & alerts
src/rigpulse/storage.py
Other components
- Local operator
- Dashboard user
Connections 18
- Local operator → CLI commands: runs commands
src/rigpulse/cli.py - CLI commands → Telemetry simulator: generates data
src/rigpulse/cli.py - CLI commands → CSV ingestion: ingests CSV
src/rigpulse/cli.py - CLI commands → Alert detection: runs detection
src/rigpulse/cli.py - CLI commands → PSI drift report: requests report
src/rigpulse/cli.py - CLI commands → Label evaluation: evaluates alerts
src/rigpulse/cli.py - CLI commands → SQLite readings & alerts: reads summary
src/rigpulse/cli.py - CLI commands → FastAPI read API: starts server
src/rigpulse/cli.py - CSV ingestion → Reading validation: parses readings
src/rigpulse/ingest.py - CSV ingestion → SQLite readings & alerts: inserts readings
src/rigpulse/ingest.py - Alert detection → SQLite readings & alerts: reads readings; replaces alerts
src/rigpulse/detection.py - PSI drift report → SQLite readings & alerts: reads readings
src/rigpulse/drift.py - Label evaluation → SQLite readings & alerts: reads readings and alerts
src/rigpulse/evaluation.py - Label evaluation → Synthetic labels: compares labels
src/rigpulse/cli.py - Dashboard user → Telemetry dashboard: views telemetry
README.md - Telemetry dashboard → FastAPI read API: fetches API data
src/rigpulse/web/app.js - FastAPI read API → SQLite readings & alerts: queries summaries and series
src/rigpulse/api.py - FastAPI read API → Telemetry dashboard: serves page
src/rigpulse/api.py