Zum Hauptinhalt springen
Referenzimplementierung · Pegelstände

Drei Quellen, ein gemeinsamer Datenweg

Die Referenz zeigt Schritt für Schritt, wie Pegeldaten aus einer Hersteller-API, einem Messwertarchiv und einem MQTT-Datenstrom zu einem gemeinsamen WaterObserved-Datenbestand, einem Dashboard und fachlichen Benachrichtigungen werden.

Quellen
3
Messstellen
11 vorgesehen
Zielmodell
WaterObserved
Datenraum
ds_environment

Ausgangslage und Ergebnis​

Kleine Gewässer werden von unterschiedlichen Stellen und über verschiedene technische Wege beobachtet. Feldnamen, Kennungen und Aktualisierungsarten unterscheiden sich, im Dashboard sollen die Messstellen aber wie ein gemeinsamer Datenbestand nutzbar sein.

Ausgangslage

Heterogene Quellen

OAuth-API, ZIP- und JSON-Abruf sowie ein laufender MQTT-Datenstrom treffen aufeinander.

Harmonisierung

Ein Zielmodell

Node-RED bildet die fachlich unterschiedlichen Rohdaten auf WaterObserved ab.

Zeitreihe

Messzeit erhalten

Stellio und QuantumLeap führen aktuelle Zustände und historische Messwerte getrennt.

Nutzung

Gemeinsame Lage

Das Dashboard verbindet aktuelle Werte, Schwellen, Karte und Ganglinien.

Architekturdiagramm: Drei Pegeldatenquellen laufen in Node-RED zusammen, werden als WaterObserved in Stellio gespeichert und über Subscription, QuantumLeap und TimescaleDB an Grafana übergeben.
Die Harmonisierung findet unmittelbar nach dem Laden und vor dem Schreiben in Stellio statt.

Die Umsetzung Schritt für Schritt​

Die fünf Schritte folgen dem Arbeitsweg der Plattformnutzung. Laden, Verarbeitung und Speicherung bleiben dabei bewusst auf einer Seite, weil sie in der Referenz einen zusammenhängenden Node-RED-Flow bilden. Die weiteren Seiten ergänzen konkrete Quellen, Feldnamen, Datenräume und Abfragen.

1 · Eingang

Datenquellen prüfen

API, Messwertarchiv und MQTT-Datenstrom mit einer ungefährlichen Probe kontrollieren.

Schritt öffnen
2 · Node-RED

Datenfluss umsetzen

Quellen laden, auf WaterObserved abbilden, in Stellio speichern und mit QuantumLeap historisieren.

Schritt öffnen
3 · Kontrolle

Daten prüfen

Aktuellen Zustand und historische Zeitreihe an den tatsächlichen Zielen nachweisen.

Schritt öffnen
4 · Nutzung

Dashboard erstellen

Kennzahlen, Karte, Status und Ganglinien zu einer verständlichen Sicht verbinden.

Schritt öffnen
5 · Benachrichtigung

Alerting einrichten

Meldehöhe und Aktualität getrennt prüfen und über einen freigegebenen Kontaktpunkt melden.

Schritt öffnen
Technischer Zusammenhang

Stellio führt den aktuellen Zustand im Tenant ds_environment. QuantumLeap historisiert den Typ WaterObserved im TimescaleDB-Schema mtds_environment und in der Tabelle etwaterobserved. Das Dashboard liest aus dieser Zeitreihe.