Qué es
Azure Event Hub es un servicio de streaming de eventos de alta capacidad, gestionado y completamente elástico. Su modelo de abstracción es el de un log de eventos distribuido y particionado: los productores escriben eventos al final del log; los consumidores leen a su propio ritmo desde cualquier punto en el tiempo, dentro del período de retención configurado.
En la arquitectura de IN-SIGHT, el Event Hub recibe la telemetría de todos los vehículos de la flota a través del punto de conexión integrado de Azure IoT Hub (built-in endpoint), sin necesidad de ningún servicio intermediario. Desde el Event Hub, tres consumer groups independientes procesan los datos en paralelo para tres propósitos distintos.
Desacoplamiento garantizado: El Event Hub actúa como buffer entre la tasa de producción de los Pods IoT y la tasa de consumo de ADX. Si ADX experimenta latencia por una ingesta pesada, los mensajes se acumulan en el Event Hub sin pérdida, y se procesan cuando el consumidor recupera ritmo.
Rol en IN-SIGHT
El Event Hub es el único punto de entrada de telemetría a la capa cloud. Tres consumer groups leen el mismo flujo para propósitos diferenciados:
- Consumer group: adx-ingest — Azure Data Explorer consume los eventos directamente mediante una data connection nativa (sin ETL intermedio). La telemetría aterriza en ADX en menos de 5 segundos desde la emisión por el Pod.
- Consumer group: realtime-alerts — Una función Azure Stream Analytics evalúa cada evento contra las reglas de alerta configuradas en el Portal IN-SIGHT. Si un valor supera los umbrales del EKF, genera una alerta clasificada (CRITICAL / WARNING / INFO) en menos de 2 segundos.
- Consumer group: archive — Azure Blob Storage recibe una copia comprimida de todos los eventos para retención a largo plazo (mínimo 12 meses), independientemente de la política de retención del Event Hub.
Flujo de telemetría end-to-end
El recorrido completo de un paquete de telemetría desde el sensor hasta el dashboard:
Pod IoT (CM4 a bordo del vehículo)
│ JSON compacto · MQTT sobre TLS 1.3
▼
Azure IoT Hub
│ Enruta mensajes D2C al built-in endpoint
│ Device Twin sincronizado en paralelo
▼
Azure Event Hub ← punto de distribución
│
├── [adx-ingest] → ADX (latencia <5 s)
│ KQL queries · EKF cloud
│
├── [realtime-alerts] → Stream Analytics
│ Reglas → alertas Portal
│
└── [archive] → Azure Blob Storage
Retención 12 meses+
Esquema de particionado
Los eventos se particionan por vehicleId, lo que garantiza que todos los mensajes de un mismo vehículo sean procesados en orden por el mismo consumer, preservando la secuencia temporal necesaria para el análisis del EKF.
Partition key: vehicleId
Partición 0 → TMB-5000-01, TMB-5000-02, ...
Partición 1 → TMB-5000-05, TMB-5000-06, ...
Partición 2 → RC-447-201, RC-447-202, ...
Partición 3 → RC-447-205, RC-447-206, ...
Con 4 particiones por defecto en la configuración estándar de IN-SIGHT, el sistema puede procesar hasta 4 MB/s de telemetría de forma sostenida, con escalado automático hasta 20 MB/s mediante throughput units adicionales.