Événement de limitation dans Azure Stream Analytics

Question

Je n'ai pas eu à consulter les flux dans Azure Stream Analytics, mais je sais que cela correspond aux capacités de l'outil. J'ai de petits messages qui vont entrer dans ma solution à partir de nombreuses sources et passera par une fonction pour "normaliser" les données avant d'aller à sa destination finale dans un Data Lake. J'ai besoin d'avoir des données qui traversent la solution qui répond à certains critères déclenchent une notification, mais doivent s'assurer que je ne crée pas trop de bruit dans la notification, je veux donc limiter une combinaison donnée à être envoyée une fois dans une période donnée .

Pour un exemple de ce que je voudrais faire, envisager un exemple de température:

{ 
    Location: "Server", 
    Temperature: 75 
} 

Si une lecture vient avec la température supérieure à 80, l'événement doit être sélectionné en tant que sortie au notificateur (probablement SendGrid), mais seulement si la même combinaison emplacement/température n'a pas été émise au cours de la dernière heure.

Le concept qui s'applique le mieux à ce que je cherche à faire, c'est réagir-throttle. Est-ce que quelqu'un peut me diriger vers des documents qui m'aideront à comprendre par où commencer?

Answer 1

Afin de réaliser ce scénario, vous pouvez utiliser notre opérateur IsFirst sur une période d'une heure. Cela garantira que seul le premier événement dans une fenêtre d'une heure déclenchera une notification.

SELECT *

alerte EN

de l'entrée

OÙ IsFirst (heure, 1) OVER (quand la température> 80) = 1

Plus d'info sur ce opérateur here. Informez-moi si vous avez d'autres questions.

Merci,

JS (Azure flux Analytics)