如何在Azure流分析中创建延迟的滑动窗口 [英] How to create a delayed sliding window in Azure Stream Analytics

问题描述

我想计算流中以下两个值之间的变化率:

I would like to calculate the rate of change between the two following values in my stream:

• SlidingWindow中的AVG(值)为100万
• 前一分钟的SlidingWindow中的AVG(值)为100万

我在文档中唯一找不到的就是如何创建延迟的"滑动窗口，这意味着它在实际时间之前开始2百万，在实际时间之前结束1百万，因此我可以进行一些计算，例如变化率

The only thing I can't find in the documentation is how to create a "delayed" sliding window, meaning that it begins 2mn before and ends 1mn before the actual time so I can make some calculations such as the rate of change.

推荐答案

您可以完成两个步骤.

1. 计算一分钟的AVG总量.
2. 使用 LAG 在上一个视频流的AVG上

1. Compute one minute aggregates of AVG.
2. Use LAG over previous stream's AVG

类似下面的内容

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

这篇关于如何在Azure流分析中创建延迟的滑动窗口的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！