Ingesta de Sparkplug-B

Muchas flotas industriales y de automatización de edificios ya publican telemetría como Eclipse Sparkplug B sobre un broker MQTT que ellas mismas operan. DeviceChain puede ingerir directamente desde esas redes sin pedirles a los dispositivos que cambien nada: se une a tu entorno Sparkplug como una Host Application y traduce el tráfico de borde (edge) a los mismos eventos que produce cualquier otro transporte.

A diferencia de MQTT simple —donde DeviceChain es el broker— la ingesta de Sparkplug funciona al revés: DeviceChain se conecta hacia afuera, a tu broker, como cliente, se suscribe a los grupos de Sparkplug que configures, y sigue el protocolo de sesión de Sparkplug.

Qué hace

• Se anuncia como una Host Application. DeviceChain publica el mensaje STATE de Sparkplug para que los nodos de borde sepan que hay un consumidor en línea, y sigue el protocolo de negociación de nacimiento/muerte (birth/death) para saber en todo momento qué nodos y dispositivos están activos.

• Sigue la sesión de Sparkplug. Sparkplug es un protocolo con estado: los nodos de borde envían un certificado BIRTH que define sus métricas (y alias compactos), luego un flujo de mensajes DATA que los referencian, y un DEATH cuando quedan fuera de línea. DeviceChain ejecuta la máquina de sesión completa: rastrea los alias y la secuencia de mensajes de cada nodo, detecta un salto o un nacimiento (birth) perdido, y le pide al nodo que se vuelva a anunciar (un rebirth) cuando necesita resincronizarse —de modo que un mensaje descartado nunca corrompe silenciosamente lo que decodifica.

• Asigna identidades de borde a dispositivos. Cada {group}/{node} de Sparkplug (o {group}/{node}/{device} para un dispositivo bajo un nodo) se convierte en el externalId de un dispositivo de DeviceChain. Si habilitas el autorregistro para una fuente, se crea un dispositivo automáticamente la primera vez que se lo ve; en caso contrario, las identidades desconocidas se descartan y se contabilizan, así que mantienes el control de qué entra en tu registro. El tráfico de un inquilino que ha sido eliminado también se descarta mientras se recuperan sus datos, y se contabiliza por separado —así un operador que vigila los descartes puede distinguir "no está en el registro" de "el inquilino ya no existe".

• Produce presencia autoritativa. Un BIRTH de nodo o dispositivo marca al dispositivo correspondiente como en línea, y un DEATH lo marca como fuera de línea —inmediata y explícitamente. Esto hace de Sparkplug un transporte que afirma presencia, al igual que LwM2M: el estado en línea de un dispositivo Sparkplug es autoritativo, no inferido a partir de un tiempo de espera (timeout).

  DeviceChain es deliberadamente estricto sobre qué muertes aplica. Un DEATH se acepta solo cuando su número de secuencia de nacimiento se correlaciona con la sesión que está viva en ese momento, de modo que un will obsoleto o duplicado que quedó de una conexión anterior se ignora en lugar de derribar una sesión que un BIRTH más nuevo ya restableció. Un DEATH de dispositivo para un dispositivo que nunca nació no emite nada en absoluto —no hay presencia que terminar. Y la muerte de un nodo se propaga en cascada: marca fuera de línea al nodo y a todos los dispositivos conocidos bajo él, porque en Sparkplug la muerte de un nodo implica que sus dispositivos se van con él.

• Alimenta la misma canalización. Las mediciones decodificadas y los cambios de presencia fluyen hacia la canalización normal de decodificar → resolver → persistir, así que todo lo que viene después —historial, estado en vivo, paneles y el motor de detección— trata la telemetría de Sparkplug exactamente igual que cualquier otro transporte.

Multitenencia y configuración

Cada fuente de Sparkplug se configura para un inquilino: la URL del broker, las credenciales (suministradas como un secreto proyectado, nunca en configuración en texto plano), y los grupos a los que suscribirse. Todo mensaje que llega por una fuente se atribuye al inquilino de esa fuente —el inquilino queda fijado por qué broker recibió el mensaje, nunca leído del tópico de Sparkplug— así que la red de borde de un inquilino nunca puede confundirse con la de otro.

Alta disponibilidad

Solo una réplica del servicio de Sparkplug se conecta a un broker dado a la vez. Un Host de Sparkplug es propietario del estado de alias, secuencia y sesión por nodo, así que dos instancias conectadas verían cada una una parte del tráfico y publicarían STATE contradictorios — por eso la propiedad única no es aquí una opción de ajuste sino de correctitud, garantizada por un arrendamiento (lease) de propiedad con vallado y por un despliegue que se niega a renderizar más de una réplica.

Lo que aporta el arrendamiento es que el reemplazo es seguro y automático. Cuando el pod que sirve desaparece — una caída, un desalojo, la pérdida de un nodo, un despliegue nuevo — su reemplazo no puede empezar a servir hasta haber adquirido el arrendamiento, de modo que nunca hay una ventana con dos Hosts en el broker. Al adquirirlo, el nuevo líder restablece la sesión (pidiendo a los nodos que se vuelvan a anunciar) y reconcilia la presencia de los dispositivos, de modo que una desconexión ocurrida durante el relevo no se pierde y ningún dispositivo queda mostrado incorrectamente como en línea.

Por tanto la recuperación es automática pero no instantánea: tarda lo que el pod de reemplazo necesite para planificarse y arrancar, más hasta 30 segundos de la ventana de vallado del arrendamiento. No hay un standby en caliente manteniendo una segunda conexión — eso sería precisamente lo que la propiedad única existe para evitar.

Estado

La ingesta de Sparkplug-B está disponible como un servicio opcional (opt-in). Ingiere mediciones e impulsa la presencia de dispositivo autoritativa; se conecta a un broker por TLS o texto plano según la URL configurada. Un segundo protocolo de borde nativo de estándares, LwM2M, también está disponible. El CA personalizado / mTLS hacia un broker privado está planificado.

Cómo se opera

La conexión al broker es propiedad de una única réplica, lo que le da a la ingesta de Sparkplug algunas propiedades operativas que conviene conocer antes de depender de ella en producción: qué cuesta un relevo, por qué un dispositivo puede quedarse mostrando en línea, y qué te están diciendo los contadores de descartes. Todo ello se cubre en Cómo operar los servicios de borde.