How alexochoki/real-time-streaming-with-fabric works
The repository combines a minute-level tablet-press telemetry simulator with a manufacturing-operations dashboard. The documented workflow runs from simulated machine signals through IoT ingestion, stream processing, time-series analytics, and dashboard monitoring; the sampled Python source supports the simulator’s payload and IoT send, while the README describes the cloud services. The React dashboard renders operational KPIs and downtime, failure, MTTR, MTBF, and state views. Its sampled state chart uses embedded example data, so a live connection from the dashboard to the documented analytics services is not evidenced here.
Main entry points: App.tsx Dashboard app · dawa_stream.py Telemetry simulator · config.py Simulator settings · KPIStrip.tsx KPI strip
Components 18
Telemetry Simulation
- Telemetry simulator
factory_data_simulator/dawa_stream.py - Simulator settings
factory_data_simulator/config.py
Cloud Streaming
- Azure IoT Hub
- Fabric Eventstream
Operational Analytics
- Fabric KQL database
- Power BI
- Lakehouse or Warehouse
- Fabric alerts
Dashboard
- Dashboard app
report/themes/src/App.tsx - KPI strip
report/themes/src/components/KPIStrip.tsx - Downtime by reason
report/themes/src/components/DowntimeByReason.tsx - Failures by hour
report/themes/src/components/FailureCountByHour.tsx - MTTR by hour
report/themes/src/components/MTTRByHour.tsx - MTBF by hour
report/themes/src/components/MTBFByHour.tsx - Total downtime
report/themes/src/components/TotalDowntimeByHour.tsx - State distribution
report/themes/src/components/StateDistribution.tsx
Other components
- Factory machines
- Production engineer
Connections 16
- Factory machines → Telemetry simulator: simulates signals
- Simulator settings → Telemetry simulator: configures
- Telemetry simulator → Azure IoT Hub: sends telemetry
- Azure IoT Hub → Fabric Eventstream: routes events
- Fabric Eventstream → Fabric KQL database: processes and routes
- Fabric KQL database → Power BI: serves live queries
- Fabric Eventstream → Lakehouse or Warehouse: stores historical data
- Fabric Eventstream → Fabric alerts: triggers alerts
- Production engineer → Dashboard app: views operations
- Dashboard app → KPI strip: renders
- Dashboard app → Downtime by reason: renders
- Dashboard app → Failures by hour: renders
- Dashboard app → MTTR by hour: renders
- Dashboard app → MTBF by hour: renders
- Dashboard app → Total downtime: renders
- Dashboard app → State distribution: renders