LandauOne

Live-Daten

Vom Sensor zum Diagramm, ohne stille Lücke

Messwerte kommen aus dem, was Sie ohnehin betreiben, werden geprüft, bevor sie behalten werden, und erscheinen in jedem Modul, das auf sie zeigt. Die beiden Monitor-Module sind dafür da, dass Sie das nie auf Treu und Glauben nehmen müssen.

  1. 1

    Er kommt an

    Von Ihren Message-Brokern, über einen schlichten HTTP-Aufruf oder aus dem Log-Exporter, den Sie bereits verwenden.

  2. 2

    Er wird sortiert

    In Messung, Richtung oder Position — und ein Wert, der auf die falsche Sensorart zielt, wird abgewiesen, statt als etwas gespeichert zu werden, das er nicht ist.

  3. 3

    Er wird geprüft

    Zeitstempel müssen in einem Fenster liegen, das Sie konfigurieren — ein Sender mit falsch gehender Uhr kann nicht ins nächste Jahr schreiben.

  4. 4

    Er zählt einmal

    Ein doppelt zugestellter Messwert wird als derselbe Messwert erkannt, statt still einen Durchschnitt zu verfälschen.

  5. 5

    Er gehört Ihrem Blick

    Auf einem Diagramm, einer Kachel, einem Karten-Marker oder einem Grundriss — überall dort, wo Sie etwas darauf gerichtet haben.

Messungen, Richtungen und Positionen

Drei Arten von Messwert, mit Absicht getrennt gehalten. Eine Richtung wird um den Kreis gemittelt statt durch die 0°/360°-Naht — wo der schlichte Durchschnitt aus 350° und 10° genau Süden ergäbe.

Zusammengefasst nach Ihrer Art

Jedes Diagramm und jede Kachel wählt die eigene Zusammenfassung pro Intervall: Durchschnitt, Minimum, Maximum, Summe, Anzahl, Median und Perzentile, Spitzen-Hüllkurven, Standardabweichung, Zähler-Deltas oder Datenabdeckung — die Perzentile werden beim Verdichten jedes Tages und Monats vorberechnet, sodass ein P95 kostet, was ein Durchschnitt kostet. Richtungen bekommen echte Kreisstatistik — einen Kompasskurs, die Sektorverteilung einer Windrose — und Positionen zeichnen sich als Spuren über die Zeit, statt zu einem Punkt gemittelt zu werden, der nie besucht wurde.

Text und Logs ebenso

Anwendungslogs und eigene Text-Nutzdaten kommen auf demselben Weg an und landen im Log-Explorer — durchsuchbar nach Identifier, Quelle und Zeit, markiert mit Ihren Hervorhebungsgruppen.

Verluste werden gezählt, nie angenommen

Was tatsächlich verloren geht, wird als solches gemeldet, statt still vergessen zu werden. Genau diese Zahl ist einen Alarm wert — und sie steht auf den Monitor-Seiten, nicht irgendwo vergraben.

Bündel, wenn Ihr Gateway sie hat

Jeder Transport nimmt ein Bündel Messwerte je Nachricht an — ein Gateway, das eine Sekunde der Messungen seiner Sensoren auf einmal abgibt — ebenso wie einen Messwert nach dem anderen. Die Bündelform ist es, die eine einzelne Aufnahmeinstanz Hunderttausende Messwerte pro Sekunde nehmen lässt.

Listener, die sich selbst heilen

Ein Broker-Consumer, der auf einer toten Verbindung hängen bleibt, wird bemerkt, am Health-Endpunkt gemeldet und neu gestartet — auf jedem Transport gleich — statt still dazusitzen, während sich Messwerte ungesehen stauen.

Für die Ingenieure

Unter der Haube: eine Streaming-ETL-Pipeline

Wenn Ihr Team in Data-Engineering-Begriffen denkt: Der Ingestion-Pfad ist ETL — Extract, Transform, Load — nur kontinuierlich statt im Nachtlauf. Der Transform-Schritt ist abgeschlossen, bevor irgendetwas den Langzeitspeicher erreicht — gespeichert wird bereits die saubere, kanonische Form, die jedes Modul liest.

Extract

Messwerte kommen aus den Message-Brokern, die Sie bereits betreiben, oder über schlichtes HTTP. Die Feldnamen des Produzenten werden an der Tür auf eine kanonische Form abgebildet — nichts weiter unten sieht je ein quellenspezifisches Format, und eine neue Quelle ändert nie, was gespeichert wird.

Transform

Vor der Speicherung wird jeder Messwert validiert, sein Zeitstempel normalisiert und am akzeptierten Fenster gemessen, eine erneute Zustellung als derselbe Messwert erkannt und seine Art — Messung, Richtung oder Position — entschieden. Anschließend werden die Messwerte zu Minutenzusammenfassungen verdichtet, korrekt über alle empfangenden Instanzen hinweg berechnet, nicht pro Maschine.

Load

Ein separater Lauf schreibt abgeschlossene Minuten in die Datenbank, entkoppelt vom Eintreffen — langsamer Speicher verzögert die Speicherung, nie die Ingestion, und die Monitor-Seiten zeigen exakt, wie weit die Load-Stufe zurückliegt. Zum Monatsschluss werden versiegelte Monate direkt in der Datenbank in eine kompakte Abfrageform gefaltet.

Die Streaming-Pipeline: Produzenten über MQTT, Kafka, Service Bus, Event Hubs, HTTP und Logs laufen in Extract, Transform und den bestätigten Puffer zusammen, werden in die Datenbank geladen, und jede Stufe meldet an die Monitore. Persistenzgrenze Ihre Produzenten MQTT Kafka Azure Service Bus Azure Event Hubs HTTP Logs (OTLP) 1 Extract Feld-Mapping an der Tür eine kanonische Form neue Quelle = Konfiguration, nie eine Speicheränderung 2 Transform validiert · Zeitstempel-Fenster Duplikate einmal gezählt Messung · Richtung · Position zu Minutenwerten verdichtet Puffer ✓ an den Produzenten bestätigt 3 Load geschrieben, entkoppelt vom Eingang Minuten-Historie monatlich gefaltet in eine kompakte Abfrageform Die Monitor-Module akzeptiert · verworfen und warum · Rückstand · Verzug
Die ganze Reise eines Messwerts: viele Quellen, eine kanonische Form, geprüft, bevor er behalten wird — bestätigt erst an der Persistenzgrenze und an jeder Naht beobachtet.

Dieselben drei Stufen tragen auch Text und Logs — extrahiert aus denselben Brokern, dem Standard-Telemetrie-Logprotokoll und schlichtem HTTP, und geladen als komprimierte Dateien statt Datenbankzeilen, sodass Logvolumen nie auf der Datenbank lastet.