Procesamiento de mensajes en una solución de IoT
En esta introducción se presentan los conceptos clave sobre el procesamiento de mensajes enviados desde sus dispositivos en una solución típica de Azure IoT. Cada sección incluye vínculos a contenido que proporciona más detalles e instrucciones.
En el diagrama siguiente se muestra una vista general de los componentes en una solución de IoT típica. Este artículo se centra en los componentes de procesamiento de mensajes de una solución de IoT.
En Azure IoT, el procesamiento de mensajes hace referencia a procesos como el enrutamiento y el enriquecimiento de mensajes de telemetría enviados por los dispositivos. Estos procesos se usan para controlar el flujo de mensajes a través de la solución de IoT y para agregar información adicional a los mensajes.
Enrutamiento de mensajes
Un centro de IoT 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 descendentes 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. Los destinos 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 descendentes se pueden conectar al punto de conexión integrado para recibir mensajes del centro 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 destinos diferentes.
Enrutamiento de IoT Central
Si usa IoT Central, puede usar la exportación de datos para enviar mensajes de telemetría a otros servicios descendentes. Los destinos 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 permite filtrar los mensajes enviados a un destino.
Para más información, consulte Exportación de datos de IoT Central.
Event Grid
IoT Hub tiene integración integrada con Azure Event Grid. Un centro de IoT puede publicar un evento cada vez que reciba mensajes de telemetría de un dispositivo. Puede usar Event Grid para enrutar estos eventos a otros servicios.
Para obtener más información, consulte React para eventos de IoT Hub mediante Event Grid para desencadenar acciones y Comparar el enrutamiento de mensajes y Event Grid para IoT Hub.
Enriquecer o transformar mensajes
Para simplificar el procesamiento descendente, es posible que desee agregar datos a los mensajes de telemetría o modificar su estructura.
Enriquecimiento de mensajes de IoT Hub
El enriquecimiento de mensajes de IoT Hub le permite agregar datos a los mensajes enviados por los dispositivos. Puede agregar:
- Una cadena estática
- El 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 las transformaciones para manipular el formato y la estructura de los datos del dispositivo antes de exportarlos a un destino.
Procesamiento de mensajes en el perímetro
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 IoT Edge puede:
- Filtrado de datos
- Adición de datos
- Conversión de datos
Otros servicios en la nube
Puede usar otros servicios de Azure para procesar mensajes de telemetría desde los dispositivos. Tanto IoT Hub como IoT Central pueden enrutar mensajes a otros servicios. Por ejemplo, puede reenviar mensajes de telemetría a:
Azure Stream Analytics es un motor de procesamiento de flujos administrado diseñado para analizar y procesar grandes volúmenes de datos de streaming. Stream Analytics puede identificar patrones en los datos y, como consecuencia, desencadenar acciones como la creación de alertas, el envío de información a una herramienta de informes o el almacenamiento de los datos transformados. Stream Analytics también está disponible en el entorno de ejecución de Azure IoT Edge, lo que permite procesar datos en el perímetro en lugar de en la nube.
Azure Functions es un servicio de proceso sin servidor que le permite ejecutar código en respuesta a eventos. Puede usar Azure Functions para procesar mensajes de telemetría desde los dispositivos.
Para obtener más información, consulte:
- Enlaces de Azure IoT Hub para Azure Functions
- Visualización de datos del sensor en tiempo real desde Azure IoT Hub mediante Power BI
- Extensión de Azure IoT Central con reglas personalizadas mediante Stream Analytics, Azure Functions y SendGrid
Pasos siguientes
Ahora que ha visto información general sobre la administración y el control de dispositivos en las soluciones de Azure IoT, algunos pasos siguientes sugeridos incluyen: