Telemetry to alert
| ID | telemetry.alert-pipeline |
|---|---|
| Description | Device telemetry flows through ingestion, stream processing and rules into outbound notifications. |
| Key | alert-pipeline |
| Tags | telemetry alerts |
100%
Steps
Workflow steps
| Number | Source | Destination | Description |
|---|---|---|---|
| 1 | Edge agent | MQTT broker | Publish telemetry batch |
| 2 | MQTT broker | Stream processor | Deliver to consumer |
| 3 | Stream processor | Stream processor | Window aggregation |
| 4 | Stream processor | Rule runtime | Enriched event |
| 5 | Stream processor | Dashboard | Live aggregate (WebSocket) |
| - if Threshold breached | |||
| 6 | Rule runtime | Notifications | Raise alert |
| 7 | Notifications | Dashboard | Alert delivered |
| else Within bounds | |||
| 8 | Rule runtime | Stream processor | No action |
| end | |||