Part 3: store, detect and show

Scroll or pinch to zoom, drag to move, double-click to zoom in 100% SVG PNG Back to the post

Architecture: a consumer pulls from the Pub/Sub subscription telemetry-ingest and inserts into TimescaleDB on CloudNativePG, acknowledging only after commit. Drasi reads the plain table tag_latest by logical replication and runs continuous queries; when a condition holds for a few seconds it calls the stored procedure raise_alarm, which writes alarm_events and sends a NOTIFY. An alarm-bridge listens and posts to the Alertmanager API, which sends to Microsoft Teams and email. A plant-exporter queries TimescaleDB for Prometheus, and Perses draws dashboards from Prometheus. Grafana reads TimescaleDB directly with a read-only role.