LandauOne

Datos en vivo

De un sensor a un gráfico, sin huecos silenciosos

Las lecturas llegan desde lo que usted ya opera, se comprueban antes de conservarse y aparecen en cada módulo apuntado hacia ellas. Los dos módulos de monitorización existen para que nunca tenga que dar eso por supuesto.

  1. 1

    Llega

    Desde sus brókeres de mensajes, desde una llamada HTTP simple, o desde el exportador de logs que ya usa.

  2. 2

    Se clasifica

    En medición, rumbo o posición — y un valor dirigido al tipo de sensor equivocado se rechaza, en lugar de guardarse como lo que no es.

  3. 3

    Se comprueba

    Las marcas de tiempo se sujetan a una ventana que usted configura, para que un emisor con el reloj mal puesto no pueda escribir en el año que viene.

  4. 4

    Se cuenta una sola vez

    Una lectura entregada dos veces se reconoce como la misma lectura, en lugar de desviar un promedio en silencio.

  5. 5

    Queda a su vista

    En un gráfico, un mosaico, un marcador de mapa o un plano de planta — allí donde usted apuntó algo hacia ella.

Mediciones, rumbos y posiciones

Tres tipos de lectura, mantenidos aparte a propósito. Un rumbo se promedia alrededor del círculo y no a través de la costura de 0°/360°, donde el promedio simple de 350° y 10° saldría rumbo sur.

Resumido a su manera

Cada gráfico y mosaico elige su propio resumen por intervalo: media, mínimo, máximo, suma, recuento, mediana y percentiles, envolventes de picos, desviación típica, deltas de contadores o cobertura de datos — los percentiles se precalculan al compactar cada día y cada mes, de modo que pedir un P95 cuesta lo que cuesta una media. Las direcciones reciben estadística circular de verdad — un rumbo de brújula, la distribución por sectores de una rosa de los vientos — y las posiciones se dibujan como trayectos en el tiempo, en lugar de promediarse en un punto que nunca fue visitado.

Texto y logs también

Los logs de aplicación y los contenidos de texto propios llegan por el mismo camino y aterrizan en el Explorador de logs — buscables por identificador, origen y tiempo, y marcados con sus grupos de resaltado.

Las pérdidas se cuentan, nunca se suponen

Cualquier cosa que sí se pierda se informa como tal, en lugar de olvidarse en silencio. Ese es el número sobre el que vale la pena alertar, y está en las páginas de monitorización y no enterrado.

Por lotes, cuando su pasarela los tiene

Cada transporte acepta un lote de lecturas por mensaje — una pasarela que vuelca de una vez un segundo de muestras de sus sensores — igual que una lectura cada vez. La forma por lotes es lo que permite a una sola instancia de ingesta absorber cientos de miles de lecturas por segundo.

Escuchas que se reparan solos

Un consumidor de broker atascado en una conexión muerta se detecta, se notifica en el punto de salud y se reinicia — en cada transporte, de la misma manera — en lugar de quedarse en silencio mientras las lecturas se acumulan sin que nadie lo vea.

Para los ingenieros

Bajo el capó: una canalización ETL en streaming

Si su equipo piensa en términos de ingeniería de datos, la ruta de ingesta es ETL — extraer, transformar, cargar — ejecutándose de forma continua y no en un horario nocturno. La transformación termina antes de que nada llegue al almacenamiento de largo plazo, así que lo que se guarda ya es la forma limpia y canónica que lee cada módulo.

Extraer

Las lecturas llegan desde los brókeres de mensajes que ya opera, o por HTTP simple. Los nombres de campo propios del productor se mapean a una única forma canónica en la puerta — nada aguas abajo ve jamás un formato específico de una fuente, y añadir una fuente nunca cambia lo que se almacena.

Transformar

Antes del almacenamiento, cada lectura se valida, su marca de tiempo se normaliza y se sujeta a la ventana aceptada, una reentrega se reconoce como la misma lectura y se decide su tipo — medición, rumbo o posición. Las lecturas se reducen entonces a resúmenes por minuto, calculados correctamente a través de todas las instancias receptoras, no por máquina.

Cargar

Un barrido separado escribe los minutos terminados en la base de datos, desacoplado de la llegada — un almacenamiento lento retrasa el almacenamiento, nunca la ingesta, y las páginas de monitorización muestran exactamente cuánto retraso lleva la etapa de carga. Al cierre de mes, los meses sellados se pliegan a una forma de consulta compacta dentro de la propia base de datos.

La canalización en streaming: los productores por MQTT, Kafka, Service Bus, Event Hubs, HTTP y logs convergen en extraer, transformar y el búfer confirmado, se cargan en la base de datos, y cada etapa informa a los monitores. frontera de durabilidad Sus productores MQTT Kafka Azure Service Bus Azure Event Hubs HTTP Logs (OTLP) 1 Extraer mapeo de campos en la puerta una forma canónica fuente nueva = configuración, nunca un cambio de almacenamiento 2 Transformar validación · ventana de tiempo duplicados contados una vez medición · rumbo · posición reducido a resúmenes por minuto Búfer ✓ confirmado al productor 3 Cargar barrido, desacoplado de la llegada historial por minuto plegado cada mes a una forma de consulta compacta Los módulos de monitorización aceptado · descartado y por qué · cola · retraso
El viaje completo de una lectura: muchas fuentes, una forma canónica, comprobada antes de conservarse — confirmada solo en la frontera de durabilidad, y vigilada en cada costura.

Las mismas tres etapas transportan texto y logs — extraídos de los mismos brókeres, del protocolo estándar de telemetría para logs y de HTTP simple, y cargados como archivos comprimidos en lugar de filas de base de datos, para que el volumen de logs nunca pese sobre la base de datos.