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 流分析)
我不必查看 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 流分析)