Nota:
El acceso a esta página requiere autorización. Puede intentar iniciar sesión o cambiar directorios.
El acceso a esta página requiere autorización. Puede intentar cambiar los directorios.
Operaciones de IoT de Azure proporciona dos maneras de procesar y enrutar datos: flujos de datos y gráficos de flujos de datos. Ambos utilizan infraestructura compartida, como endpoints, perfiles y configuración de origen y destino. Sin embargo, difieren en la estructura de la canalización, las capacidades de transformación y el soporte para puntos de conexión.
¿Qué son los flujos de datos?
Un flujo de datos es una canalización simple y lineal que mueve datos de un origen a un destino con transformaciones opcionales. La etapa de transformación ejecuta tres operaciones en un orden fijo: enriquecer, filtrar y mapear. Configure un flujo de datos mediante la interfaz web de la experiencia operativa, la CLI de Azure o las plantillas de Azure Resource Manager.
Los flujos de datos están disponibles con carácter general y admiten todos los tipos de punto de conexión.
¿Qué son los gráficos de flujo de datos?
Un gráfico de flujo de datos es una canalización compuesta basada en grafos que conecta varias transformaciones en cualquier topología que defina. Puede encadenar, bifurcar y combinar pasos de procesamiento. Cada transformación es una unidad de procesamiento predefinida, como mapeo, filtro, bifurcación, ventana, limitación o enriquecimiento, que se configura mediante reglas. Puede configurar un gráfico de flujo de datos mediante la interfaz de usuario web de experiencia de operaciones, las plantillas de CLI de Azure o Azure Resource Manager.
Los gráficos de flujo de datos admiten puntos de conexión MQTT, Kafka y OpenTelemetry.
Comparación
| Feature | Flujos de datos | Gráficos de flujo de datos |
|---|---|---|
| Forma de canalización | Corregido: enriquecer, filtrar, mapear | Flexible: cualquier topología de grafo |
| Transforms | Mapear, filtrar, enriquecer | Mapeo, filtro, bifurcación, concatenar, ventana (agregación), enriquecer |
| Ramificar y fusionar | No soportado | Bifurcar según condiciones, fusionar con concatenación |
| Agregación basada en tiempo | No soportado | Ventanas de saltos de tamaño constante con avg, min, max, count |
| Admisión de puntos de conexión (origen) | MQTT, Kafka | MQTT, Kafka |
| Admisión de puntos de conexión (destino) | MQTT, Kafka, ADLS, Fabric, ADX, almacenamiento local, OpenTelemetry | MQTT, Kafka, OpenTelemetry |
| Temas de destino dinámicos |
${inputTopic} (tránsito del tema de origen) |
$metadata.topic
+
${outputTopic} (enrutamiento basado en contenido) |
| Schema | Sobre fuente y transformación | En las conexiones de nodo |
| Persistencia de disco | Soportado | Soportado |
Infraestructura compartida
Los flujos de datos y los gráficos de flujo de datos comparten:
-
Puntos de conexión: ambos usan
DataflowEndpointrecursos para conectarse a agentes MQTT, Kafka, almacenamiento y otros servicios. Consulte Preparación de puntos de conexión. -
Perfiles: ambos hacen referencia a un
DataflowProfilepara el escalamiento y la configuración de instancias. Consulte Administración de perfiles de flujo de datos. - Configuración de origen: admiten las mismas opciones de punto de conexión de origen (agente predeterminado, recurso, punto de conexión personalizado) y configuración del origen de datos (tema). Consulte Configuración de un origen.
- Configuración de destino: admite temas de destino estáticos y dinámicos. Consulte Configuración de un destino.
-
Persistencia de disco: ambos admiten
requestDiskPersistencepara sobrevivir a los reinicios. Consulte Configuración de la persistencia de disco.
Cuándo usar qué
Use flujos de datos cuando:
- Necesitas una tubería sencilla de origen a destino con transformaciones básicas.
- Necesitas enviar datos a los puntos finales de almacenamiento (ADLS, Fabric, ADX, almacenamiento local).
- Quieres una solución disponible en general y lista para producción.
Use gráficos de flujo de datos cuando:
- Necesitas desviar mensajes a diferentes rutas de procesamiento según las condiciones.
- Necesita agregación basada en tiempo (ventanas de salto de tamaño constante).
- Necesitas varias transformaciones encadenadas en una topología personalizada.
- Estás trabajando solo con endpoints MQTT, Kafka u OpenTelemetry.
Para proyectos nuevos que usan tipos de endpoint compatibles, utiliza grafos de flujo de datos. Los flujos de datos siguen siendo totalmente compatibles con todos los escenarios y admiten la gama completa de tipos de punto de conexión.