LandauOne

Dati live

Dal sensore al grafico, senza buchi silenziosi

Le letture arrivano da ciò che già usi, vengono verificate prima di essere conservate e compaiono in ogni modulo che le punta. I due moduli Monitor esistono perché tu non debba mai crederci sulla parola.

  1. 1

    Arriva

    Dai tuoi message broker, da una semplice chiamata HTTP o dall'esportatore di log che già usi.

  2. 2

    Viene smistata

    In misura, direzione o posizione — e un valore destinato al tipo di sensore sbagliato viene rifiutato, non salvato come qualcosa che non è.

  3. 3

    Viene verificata

    I timestamp sono tenuti dentro una finestra che configuri tu, così un mittente con l'orologio sbagliato non può scrivere nell'anno prossimo.

  4. 4

    Viene contata una volta

    Una lettura consegnata due volte è riconosciuta come la stessa lettura, invece di trascinare in silenzio una media fuori rotta.

  5. 5

    È lì da guardare

    Su un grafico, un riquadro, un marker su mappa o planimetria — ovunque tu abbia puntato qualcosa verso di essa.

Misure, direzioni e posizioni

Tre tipi di lettura, tenuti separati di proposito. Una direzione viene mediata lungo il cerchio anziché attraverso la cucitura 0°/360°, dove la media semplice di 350° e 10° darebbe pieno sud.

Riassunti a modo tuo

Ogni grafico e riquadro sceglie il proprio riepilogo per intervallo: media, minimo, massimo, somma, conteggio, mediana e percentili, inviluppi dei picchi, deviazione standard, delta dei contatori o copertura dei dati — i percentili sono precalcolati quando ogni giorno e ogni mese viene compattato, così un P95 costa quanto una media. Le direzioni ricevono una vera statistica circolare — una direzione di bussola, la distribuzione per settori di una rosa dei venti — e le posizioni si disegnano come tracce nel tempo anziché essere mediate in un punto mai visitato.

Anche testi e log

I log applicativi e i payload di testo personalizzati arrivano per la stessa strada e finiscono in Esplora log — ricercabili per identificatore, origine e tempo, e marcati con i tuoi gruppi di evidenziazione.

Le perdite si contano, non si presumono

Ciò che davvero va perso viene segnalato come tale, non dimenticato in silenzio. È quello il numero su cui vale la pena impostare un avviso, e sta sulle pagine Monitor, non sepolto.

A lotti, quando il tuo gateway li ha

Ogni trasporto accetta un lotto di letture per messaggio — un gateway che scarica in una volta un secondo di campioni dei suoi sensori — così come una lettura alla volta. È la forma a lotti che permette a una singola istanza di ingestione di assorbire centinaia di migliaia di letture al secondo.

Listener che si riparano da soli

Un consumer di broker bloccato su una connessione morta viene notato, segnalato sull’endpoint di salute e riavviato — su ogni trasporto, allo stesso modo — invece di restare in silenzio mentre le letture si accumulano senza che nessuno lo veda.

Per gli ingegneri

Sotto il cofano: una pipeline ETL in streaming

Se il tuo team ragiona in termini di data engineering, il percorso di ingestione è ETL — extract, transform, load — eseguito in continuo anziché su pianificazione notturna. La trasformazione è conclusa prima che qualcosa raggiunga lo storage a lungo termine, così ciò che è salvato è già la forma pulita e canonica che ogni modulo legge.

Extract

Le letture arrivano dai message broker che già usi, o su semplice HTTP. I nomi dei campi del producer vengono mappati sulla forma canonica direttamente all'ingresso — a valle nessuno vede mai un formato specifico della sorgente, e aggiungere una sorgente non cambia mai ciò che è salvato.

Transform

Prima del salvataggio ogni lettura è validata, il suo timestamp normalizzato e tenuto nella finestra accettata, una riconsegna riconosciuta come la stessa lettura, e il suo tipo — misura, direzione o posizione — deciso. Le letture sono poi ridotte in riepiloghi al minuto, calcolati correttamente su tutte le istanze riceventi, non per macchina.

Load

Uno sweep separato scrive i minuti conclusi nel database, disaccoppiato dall'arrivo — uno storage lento ritarda il salvataggio, mai l'ingestione, e le pagine Monitor mostrano esattamente quanto la fase di load è indietro. A fine mese, i mesi sigillati vengono ripiegati in forma compatta di interrogazione dentro il database stesso.

La pipeline in streaming: i producer su MQTT, Kafka, Service Bus, Event Hubs, HTTP e log convergono in extract, transform e nel buffer con conferma, vengono caricati nel database, e ogni fase riferisce ai monitor. confine di durabilità I tuoi producer MQTT Kafka Azure Service Bus Azure Event Hubs HTTP Log (OTLP) 1 Extract campi mappati all'ingresso una forma canonica nuova sorgente = config, mai un cambio di storage 2 Transform validata · finestra temporale duplicati contati una volta misura · direzione · posizione ridotta a riepiloghi al minuto Buffer ✓ confermato al producer 3 Load sweep, disaccoppiato dall'arrivo storico al minuto ripiegato ogni mese in forma compatta di query I moduli Monitor accettato · scartato e perché · arretrato · ritardo
L'intero viaggio di una lettura: molte sorgenti, una forma canonica, verificata prima di essere conservata — confermata al producer solo al confine di durabilità, e osservata a ogni giuntura.

Le stesse tre fasi trasportano testi e log — estratti dagli stessi broker, dal protocollo standard di telemetria per i log e da semplice HTTP, e caricati come file compressi anziché righe di database, così il volume dei log non pesa mai sul database.