Procesamiento de mensajes en una solución de IoT

En el diagrama siguiente se muestra una vista general de los componentes en una solución de IoT típica basada en el edge. Este artículo se centra en los componentes de procesamiento de mensajes de una solución de IoT basada en edge.

En el diagrama siguiente se muestra una vista general de los componentes en una solución típica de IoT basada en la nube. Este artículo se centra en los componentes de procesamiento de mensajes de una solución de IoT basada en la nube.

Para enrutar mensajes de tus elementos a varios puntos de conexión, Azure IoT Operations usa flujos de datos. Los puntos de conexión de destino pueden estar en la nube o en el borde. La lista de puntos de conexión de destino disponibles incluye:

La interfaz de usuario web de la experiencia de operaciones proporciona un entorno sin código para compilar y ejecutar los flujos de datos.

Para mejorar la seguridad en los datos que se enrutan a los puntos de conexión, los secretos sincronizados de nube o perimetral se usan en los puntos de conexión de flujo de datos para la autenticación.

Aunque los flujos de datos le permiten configurar el enrutamiento en el perímetro, también puede definir el enrutamiento en la nube. Si el flujo de datos entrega mensajes a Azure Event Grid, puede usar sus funcionalidades de enrutamiento para determinar dónde enviar los mensajes.

Para más información, consulte Procesamiento y enrutamiento de datos con flujos de datos.

Una instancia de Azure IoT Hub proporciona un punto de entrada en la nube para los mensajes de telemetría que envían los dispositivos. En una solución de IoT típica, estos mensajes se entregan a otros servicios de nivel inferior para el almacenamiento o el análisis.

Enrutamiento de IoT Hub

En IoT Hub, puede configurar el enrutamiento para entregar mensajes de telemetría a los destinos que prefiera. Entre los destinos se incluyen:

• Contenedores de almacenamiento
• Colas de Service Bus
• Temas de Service Bus
• Event Hubs

Cada centro de IoT tiene un destino predeterminado denominado punto de conexión integrado . Los servicios downstream pueden conectarse al endpoint integrado para recibir mensajes del hub de IoT.

Para más información, consulte Uso del enrutamiento de mensajes de IoT Hub para enviar mensajes del dispositivo a la nube a distintos puntos de conexión.

Puede usar consultas para filtrar los mensajes enviados a diferentes destinos.

Enrutamiento de IoT Central

Si usa Azure IoT Central, puede usar la exportación de datos para enviar mensajes de telemetría a otros servicios de bajada. Entre los destinos se incluyen:

• Contenedores de almacenamiento
• Colas de Service Bus
• Temas de Service Bus
• Event Hubs
• Explorador de Datos de Azure
• Webhooks

Una configuración de exportación de datos de IoT Central le permite filtrar los mensajes enviados a un destino.

Para más información, consulte Exportación de datos desde IoT Central.

Cuadrícula de Eventos

IoT Hub tiene integración integrada con Azure Event Grid. Un centro de IoT puede publicar un evento cada vez que recibe un mensaje de telemetría de un dispositivo. Puede usar Event Grid para enrutar estos eventos a otros servicios.

Para más información, consulte React to IoT Hub events by using Event Grid to trigger actions and Compare message routing and Event Grid for IoT Hub (Reacción a eventos de IoT Hub mediante Event Grid para desencadenar acciones y comparar el enrutamiento de mensajes y Event Grid para IoT Hub).

Los enriquecimientos y transformaciones se pueden aplicar a los datos durante la fase de procesamiento para realizar diversas operaciones. Estas operaciones pueden incluir:

• Proceso de nuevas propiedades: a partir de las propiedades existentes en el mensaje
• Cambio de nombre de las propiedades: para estandarizar o aclarar los datos
• Conversión de unidades: convertir valores en diferentes unidades de medida
• Estandarización de valores: escalar los valores de propiedad a un intervalo definido por el usuario
• Contextualización de datos: agregar datos de referencia a mensajes para el enriquecimiento y la generación de conocimientos

El registro de esquema almacena esquemas para los mensajes procedentes de los recursos. Los flujos de datos usan estos esquemas de mensajes para descodificar mensajes de varios formatos para que los flujos de datos los puedan procesar.

La interfaz de usuario web de la experiencia de operaciones proporciona un entorno sin código para compilar y ejecutar las transformaciones en los flujos de datos.

Para más información, consulte Enriquecimiento de datos mediante flujos de datos.

En Azure IoT Operations, puede implementar sus propias aplicaciones perimetrales de alta disponibilidad en el clúster de Kubernetes. Las aplicaciones perimetrales pueden interactuar con el agente MQTT integrado para:

• Use la lógica de procesamiento de mensajes personalizado en los mensajes MQTT.
• Cree lógica de aplicación personalizada para ejecutarse en el borde.
• Ejecute modelos de inteligencia artificial perimetral para el procesamiento de datos en tiempo real y la toma de decisiones en el origen de la generación de datos, lo que reduce la latencia y el uso del ancho de banda.

Para más información, consulte Desarrollo de aplicaciones de alta disponibilidad para el agente MQTT de Azure IoT Operations.

Para simplificar el procesamiento posterior, es posible que quiera agregar datos a los mensajes de telemetría o modificar su estructura.

Enriquecimiento de mensajes de IoT Hub

Los enriquecimientos de mensajes de IoT Hub permiten agregar datos a los mensajes enviados por los dispositivos. Puede agregar:

• Una cadena estática
• Nombre del centro de IoT que procesa el mensaje
• Información del dispositivo gemelo

Para obtener más información, consulte Enriquecimiento de mensajes para mensajes de IoT Hub del dispositivo a la nube.

Transformaciones de mensajes de IoT Central

IoT Central tiene dos opciones para transformar mensajes de telemetría:

• Use asignaciones para transformar datos complejos de telemetría de dispositivos en datos estructurados al ingresar a IoT Central.
• Use transformaciones para manipular el formato y la estructura de los datos del dispositivo antes de exportarlos a un destino.

Procesamiento de mensajes de IoT Edge

Un módulo de Azure IoT Edge puede procesar la telemetría desde un sensor o dispositivo conectado antes de enviarlo a un centro de IoT. Por ejemplo, antes de enviar datos a la nube, un módulo de IoT Edge puede:

• Filtrar datos
• Agregar datos
• Conversión de datos
• Realizar la clasificación de imágenes en el borde