Règles d’activateur de structure

Une fois que vous avez apporté des données de diffusion en continu dans un activateur ou affecter des événements à des objets, vous pouvez créer des règles pour agir sur vos données. Les règles définissent les conditions que vous souhaitez détecter sur vos objets et les actions à entreprendre lorsque ces conditions sont remplies. Par exemple, une règle sur un objet congélateur peut détecter quand la température augmente au-dessus d’un seuil sûr et envoyer automatiquement une alerte par e-mail au technicien affecté.

Chaque activateur inclut une ou plusieurs règles, qui sont évaluées en continu. Il peut s’agir de comparaisons simples (value < threshold) ou d’expressions avec état telles que BECOMES, DECREASES, INCREASES, EXIT RANGE, ou l’absence de données (pulsation). L’activateur garantit le suivi de l’état par objet, ce qui permet la détection de modèles complexes au fil du temps.

Actions

Lorsque les conditions d’une règle sont remplies et qu’une action est lancée, la règle est dite activée. Les cibles prises en charge pour les actions sont les suivantes :

• Infrastructures de pipelines (pour le déplacement et l'enrichissement des données)

• Notebooks Fabric (pour le machine-learning scoring, les diagnostics)

• Tâches Spark Fabric (pour les tâches par lots/en continu)

• Fonctions fabric (pour une logique métier personnalisée avec du code)

• Flux de travail Power Automate (pour l’intégration de processus métier)

• Notifications Teams (en utilisant la messagerie basée sur des modèles)

• Notifications par e-mail

Il existe trois types de règles : les règles sur les événements, les règles sur les événements ajoutés à un objet et les règles sur les propriétés d’un objet.

Créer des règles sur les événements

La création de règles sur les événements vous permet d’obtenir une activation pour chaque événement qui se produit sur un flux d’événements. Lorsque vous créez ces types de règles, vous pouvez suivre l’état de quelque chose au fil du temps. Par exemple:

• Vous recevez une alerte chaque fois qu’un nouvel événement arrive sur un flux d’événements, contenant des mesures d’un seul capteur IoT.
• Vous recevez une alerte chaque fois qu’un nouvel événement arrive et que la valeur d’une colonne dans cet événement remplit la condition que vous avez définie.

Créer des règles sur les événements d’objet

Les objets sont créés à partir de données de streaming et sont identifiés par des colonnes uniques dans un ou plusieurs flux. Vous choisissez des colonnes spécifiques et la colonne unique à regrouper dans un objet. Ensuite, au lieu de créer des règles sur l’arrivée des événements, vous créez des règles qui surveillent les événements et signalent l’arrivée de cet objet ou l’arrivée d’un objet qui répond à une condition définie. Votre règle s’active chaque fois qu’un nouvel événement se trouve sur l’objet eventstream. Vous pouvez également identifier l’instance pour laquelle l’événement s’est produit.

Créer des règles sur les propriétés

La création de règles sur les propriétés vous permet de surveiller une propriété sur des objets au fil du temps. Si vous souhaitez surveiller l’état d’une propriété sur un objet, créez une règle sur une propriété. Par exemple, vous pouvez surveiller la température sur un package et vérifier si elle reste dans une plage définie au fil du temps.

Règles sans état et avec état

Les règles de l’activateur peuvent être sans état ou avec état :

• Les règles sans état évaluent chaque événement isolé (par exemple, valeur < 50).
• Les règles avec état conservent la mémoire entre les événements par objet (par exemple, value DECREASES, BECOMES, EXIT RANGE)

L’évaluation avec état s’appuie sur :

• Détection delta : effectue le suivi des modifications entre les valeurs d’événement antérieures et actuelles.
• Séquencement temporel : évalue les conditions temporelles comme l’absence d’événements (détection de pulsations)
• Transitions d’état : les règles se déclenchent uniquement lors de l’entrée dans un nouvel état, empêchant les déclenchements répétés dans des conditions inchangées

Chaque condition de règle est compilée dans un graphique d’exécution qui est évalué en continu, en mémoire et presque instantanément. Le système est optimisé pour la latence de décision en sous-seconde après l’arrivée de l’événement.

Considérations clés relatives à la conception

• Logique avec état et filtrage sans état : les filtres sans état (par exemple, la valeur < 5) peuvent être trop bruyants. Privilégiez l'utilisation de la logique transitionnelle comme DIMINUE ou DEVIENT pour réduire les faux positifs et le spam.
• Cardinalité de clé d’objet : chaque clé d’objet unique (par exemple, ID d’appareil) entraîne le suivi de la mémoire et du calcul. Les implémentations à cardinalité élevée (>10 000 objets uniques) doivent être soigneusement profilées pour maintenir les performances.
• Combinaison de règles : activateur prend en charge la logique AND et OR. Utilisez-les pour créer des arborescences de détection complexes (par exemple, la température diminue ET l’état devient « critique »).
• Gestion de la fatigue des alertes - Règles de conception à déclencher uniquement sur les transitions de périphérie. L’activateur supprime automatiquement les alertes répétées, sauf si un nouvel état est entré, mais une bonne conception réduit davantage le bruit.

Étape suivante