Sincronización de cargas útiles de dispositivos con Eclipse Vorto: guía práctica

Alexander Edelmann

你好 (chino para «Hola»), soy Alexander Edelmann, basado en Singapur y ingeniero de software en Robert Bosch desde 2006. Apasionado por el IoT y defensor de estándares abiertos que permitan interoperabilidad fluida de dispositivos entre plataformas. Contribuyo activamente al proyecto Eclipse IoT Vorto, que ofrece herramientas basadas en la nube para descripción uniforme de dispositivos e integración en diversos ecosistemas IoT. Fuera de la ingeniería, disfruto de la cocina asiática, practicando mis habilidades con palillos y el tenis.

En un entorno carente de un estándar global, fabricantes de dispositivos IoT, integradores y proveedores de plataformas luchan con la gran variedad de formatos de carga útil, APIs y protocolos propietarios.

Eclipse Vorto aborda este reto ofreciendo editores basados en la nube que abstraen cargas útiles específicas de proveedor en bloques de función Vorto reutilizables. Estos bloques se ensamblan en un Modelo de Información Vorto que define el gemelo digital de un dispositivo. Tanto los Modelos de Información como los Bloques de Función se escriben en vortolang, una gramática concisa que especifica la interfaz entre un dispositivo físico y su gemelo digital. Las soluciones IoT se comunican exclusivamente a través de estos bloques de función abstractos y sus esquemas de datos relacionados, desacoplando así de los dispares formatos de datos de dispositivos. La conversión de datos brutos de dispositivos en estas interfaces abstractas se logra mediante Especificaciones de Mapeo Vorto, que codifican las instrucciones necesarias para armonizar cargas útiles específicas de cada dispositivo.

Normalización de cargas útiles en general

La normalización de datos puede realizarse en varios puntos de la pila IoT, permitiendo a las partes interesadas mantener el control sobre dónde se transforman los datos propietarios en una forma estandarizada.

1. En el nodo del dispositivo — Un dispositivo inteligente, como un horno inteligente de Bosch, procesa datos de sensores localmente, los normaliza y puede exponer analíticas que se agregan en un data lake en la nube.
2. En el nodo gateway — Un gateway que agrega múltiples sensores o dispositivos mediante drivers de protocolo diversos (BLE, GPIO, etc.) normaliza los datos entrantes para proporcionar analíticas a nivel de gateway u otras funciones de negocio.
3. En el nodo de plataforma IoT — Similar a un gateway, una plataforma IoT en la nube normaliza la telemetría recibida a través de adaptadores de protocolo (MQTT, CoAP, etc.) para impulsar servicios de gestión de dispositivos o analíticas.
4. En el nodo de aplicación — Una aplicación normaliza datos para permanecer agnóstica a dispositivos específicos, enfocándose en la lógica de negocio en lugar de decodificadores específicos de dispositivo.

Cuando un dispositivo no puede realizar el mapeo de carga útil —quizás por potencia de procesamiento limitada o restricciones de ancho de banda—, un motor de mapeo separado debe ejecutar este paso en un nodo intermedio, gateway, plataforma o aplicación.

La normalización de datos puede manejarse en un nodo de dispositivo (1), nodo gateway (2), nodo de plataforma IoT (3) o nodo de aplicación (4).

Tim Grossmann

Como estudiante alemán de informática, he completado proyectos en tres departamentos diferentes de Bosch en el último año y medio. Mis intereses están en tecnologías Open Source y EduTech. Creo que IoT y automatización tienen un potencial inmenso para transformar la vida diaria. Soy un aprendiz y desarrollador dedicado, y mantengo el bot de automatización de Instagram open‑source gratuito más grande del mundo. En mi tiempo libre, disfruto escalando y viajando al extranjero.

Cómo Eclipse Vorto aborda la normalización

Eclipse Vorto proporciona una biblioteca de runtime que, cuando se configura con un Modelo de Información Vorto, aplica la especificación de mapeo para transformar cargas útiles brutas de dispositivos en su forma normalizada. La especificación de mapeo está versionada y almacenada junto con el Modelo de Información del dispositivo en el Repositorio Vorto, permitiendo su reutilización en diferentes nodos de despliegue —dispositivo, gateway, plataforma o aplicación. La biblioteca está disponible actualmente para Java y Node.js. Lea más sobre la biblioteca Vorto Payload Mapping.

Ejemplo: Normalización de datos industriales usando Eclipse Vorto

Para ilustrar estos conceptos, considere un escenario donde telemetría CSV de un motor síncrono de imán permanente (PMSM) se transmite a un conector MQTT de Eclipse Hono.

El middleware Vorto Payload Normalization consume estos datos de Hono, los enruta a través del Motor de Mapeo de Carga Vorto y publica los datos armonizados como un tópico AMQP. Cualquier suscriptor AMQP 1.0 puede entonces consumir los datos estandarizados independientemente del dispositivo original, aprovechando una plataforma de gemelo digital como Bosch IoT Things.

En este ejemplo, empleamos Eclipse Ditto, un servicio de gemelo digital open‑source, para ingerir y almacenar los datos normalizados. El Vorto Dashboard consulta la API de Ditto y presenta la información usando widgets de UI predefinidos compatibles con Vorto.

La configuración conceptual completa de nuestro pipeline de mapeo de carga de dispositivos.

Si desea observar todo el pipeline de mapeo en acción, visite la demostración del Vorto Dashboard.

Este artículo ofrece una breve visión general de Payload Mappings. Para una guía completa paso a paso para configurar su propio pipeline, consulte nuestro tutorial detallado.