Casos de uso y patrones comunes para grafos de flujo de datos

Elige un patrón basado en la entrada que tengas y la salida que necesitas. Todos los valores de ejemplo son sintéticos.

Objetivo	Operation	Implementation
Añade contexto a las lecturas	Busca el registro más reciente por ID de activo	Enriquecimiento incorporado; una aplicación mantiene el almacén de estado
Alinear y correlacionar los registros	Haga coincidir las lecturas por marca de tiempo o ID del elemento	Muestra con estado personalizada o un servicio externo
Reducción de ruido:	Calcular la media de un lote sin solapamiento	Ventana de saltos de tamaño constante integrada
Enrutar lecturas por gravedad	Filtra lecturas imposibles y redirige por severidad	Funciones integradas de filtrado, ramificación, asignación y concatenación
Enruta más de dos tipos de mensajes	Selecciona una ruta para cada tipo de mensaje y luego fusiona rutas	Bifurcación y concatenación integradas
Enrutamiento de mensajes no válidos a una cola con mensajes fallidos	Cargas útiles rechazadas separadas para que el consumidor las conserve	Funciones integradas de ramificación, asignación y concatenación
Predicción y actualizaciones del modelo	Evalúa un modelo, gestiona sus parámetros o entrega una actualización	Elige un patrón independiente a continuación

Predicción y actualizaciones del modelo

Elija un patrón independiente para predicción, ajuste o entrega. Combínalos según sea necesario.

Pattern	Se utiliza cuando
Calcular una predicción con coeficientes conocidos	Necesitas evaluar una fórmula existente, usando parámetros en el mensaje o recuperados mediante enriquecimiento
Ajusta y activa un modelo aprobado	La aplicación debe ajustarse y aprobar nuevos parámetros, y luego conservar el registro completo de modelo activo
Entregar actualizaciones aprobadas de modelos a través de MQTT	Necesitas enviar los coeficientes aprobados a un predictor personalizado para lecturas posteriores

Prerequisites

Empieza con un despliegue existente de Operaciones de IoT de Azure, un perfil de flujo de datos y un endpoint MQTT con acceso al broker. Siga los pasos descritos en Crear un gráfico de flujo de datos para configurarlos.

En los ejemplos se usa el perfil default y el punto de conexión de MQTT factory-mqtt en el espacio de nombres de azure-iot-operations. Las transformaciones integradas utilizan el endpoint del registro default.

Para patrones personalizados, utiliza los manifiestos listos para aplicar o el chart de Helm en las instrucciones de despliegue de Azure Samples, incluyendo la configuración del registro y el despliegue de instancia única. Para comprobar el silencio del sensor, configure el publicador de reloj con su agente existente.