Cas d’utilisation courants et modèles pour les graphes de flux de données

Choisissez un modèle en fonction de l’entrée que vous avez et de la sortie dont vous avez besoin. Toutes les valeurs d’exemple sont synthétiques.

Objectif Operation Implementation
Ajouter du contexte aux lectures Cherchez le dernier enregistrement par identifiant d’actif Enrichissement intégré ; une application gère le magasin d’état
Aligner et corréler les enregistrements Faire correspondre les relevés par horodatage ou identifiant d’article Exemple personnalisé avec état ou service externe
Réduction du bruit Moyenner un lot sans chevauchement Fenêtre basculante intégrée
Acheminer les lectures en fonction de leur gravité Filtrez les lectures impossibles et acheminez par gravité Filtre, branche, carte et concaténation intégrés
Acheminez plus de deux types de messages Sélectionnez un chemin pour chaque type de message, puis fusionnez les chemins Branche et concaténation intégrées
Acheminer les messages non valides vers une file d’attente de messages non distribuables Séparer les charges utiles rejetées afin qu’un consommateur puisse les conserver Branche, carte et concaténation intégrées
Prédiction et mises à jour du modèle Évaluer un modèle, gérer ses paramètres ou livrer une mise à jour Choisissez un modèle indépendant ci-dessous

Prédiction et mises à jour du modèle

Choisissez un modèle indépendant pour la prédiction, l’ajustement ou la distribution. Combinez-les selon les besoins.

Modèle À utiliser quand
Calculer une prédiction avec des coefficients connus Vous devez évaluer une formule existante, en utilisant les paramètres du message ou récupérés par enrichissement
Ajustez et activez un modèle approuvé Votre application doit ajuster et approuver de nouveaux paramètres, puis conserver l’enregistrement complet du modèle actif
Fournir des mises à jour de modèles approuvées via MQTT Vous devez envoyer les coefficients approuvés à un prédicteur spécifique pour des relevés ultérieurs

Prerequisites

Commencez par un déploiement Opérations Azure IoT existant, un profil de flux de données et un point de terminaison MQTT avec accès au broker. Suivez les instructions de la page Créer un graphe de flux de données pour les configurer.

Les exemples utilisent le profil default et le point de terminaison MQTT factory-mqtt dans l’espace de noms azure-iot-operations. Les transformations intégrées utilisent le default point de terminaison du registre.

Pour les patterns personnalisés, utilisez les manifestes prêts à appliquer ou le chart Helm dans les instructions de déploiement Azure Samples, incluant la configuration du registre et le déploiement en instance unique. Pour détecter le silence des capteurs, configurez le publisher d’horloge avec votre broker existant.