如何在 Azure 流分析中创建延迟滑动 window
How to create a delayed sliding window in Azure Stream Analytics
我想计算流中以下两个值之间的变化率：
- 100 万滑动窗口中的 AVG(值)
- 前一分钟 100 万滑动窗口中的 AVG(value)
我在文档中唯一找不到的是如何创建一个 "delayed" 滑动 window，这意味着它在实际时间之前 2 分钟开始并在实际时间之前 1 分钟结束，所以我可以一些计算，例如变化率。
分两步完成。
- 计算一分钟的 AVG 总和。
- 对上一个流的 AVG
使用 LAG
如下所示
WITH OneMinuteWindows AS
(
SELECT
Avg(Column1) AvgValue
FROM
InputEventHub
GROUP BY
TumblingWindow(mi, 1)
)
SELECT
System.TimeStamp [TimeStamp],
AvgValue [CurrentValue],
LAG(AvgValue) OVER (LIMIT DURATION(mi, 2)) [PreviousValue]
FROM
OneMinuteWindows
我想计算流中以下两个值之间的变化率：
- 100 万滑动窗口中的 AVG(值)
- 前一分钟 100 万滑动窗口中的 AVG(value)
我在文档中唯一找不到的是如何创建一个 "delayed" 滑动 window，这意味着它在实际时间之前 2 分钟开始并在实际时间之前 1 分钟结束，所以我可以一些计算，例如变化率。
分两步完成。
- 计算一分钟的 AVG 总和。
- 对上一个流的 AVG 使用 LAG
如下所示
WITH OneMinuteWindows AS
(
SELECT
Avg(Column1) AvgValue
FROM
InputEventHub
GROUP BY
TumblingWindow(mi, 1)
)
SELECT
System.TimeStamp [TimeStamp],
AvgValue [CurrentValue],
LAG(AvgValue) OVER (LIMIT DURATION(mi, 2)) [PreviousValue]
FROM
OneMinuteWindows