Azure 流分析中的节流事件

Throttle event in Azure Stream Analytics

我不必查看 Azure 流分析中的流,但知道它在该工具的功能范围内。我有一些小消息,它们将从许多来源进入我的解决方案,并将通过一个函数传递给 "normalize" 数据,然后再到达数据湖中的最终目的地。我需要让满足特定条件的数据流经解决方案触发通知,但需要确保我不会在通知中产生太多噪音,因此想要将给定组合限制为在给定时间段内发送一次.

关于我想做的事情的例子,考虑一个温度例子:

{
    Location: "Server",
    Temperature: 75
}

如果温度超过 80 的读数出现,则应选择该事件作为通知程序(可能是 SendGrid)的输出,但 如果相同 location/temperature组合最近一小时未输出

最适用于我想要做的事情的概念是 react-throttle。

谁能给我指点帮助我了解从哪里开始的文档?

为了实现这种情况,您可以在 1 小时内使用我们的 IsFirst 运算符。这将确保只有 1 小时内的第一个事件 window 会触发通知。

SELECT *

INTO alert

FROM input

WHERE ISFIRST(hour, 1) OVER (WHEN temp > 80)=1

有关此运算符的更多信息 here

如果您还有其他问题,请告诉我。

谢谢,

JS(Azure 流分析)