蓝流分析:从滑动窗口计算坡度

Question

数据结构： {sensorId: 1, temp: 20, timestamp: 1525119377241}

窗口查询：

SELECT
    System.Timestamp as WindowEnd,
    sensorId,
    AVG(temp) AS avgTemp,
FROM
    SensorStream TIMESTAMP BY timestamp
GROUP BY
    sensorId,
    SlidingWindow(second, 30)

我想实时计算实际avgTemp和avgTemp 30之间的斜率。

使用tumbling window可以通过使用LAG(avgTemp, 1)来工作，但这只能每30分钟输出一次。

TL;DR:，我想在每次滑动窗口计算新的avgTemp时实时计算斜率。

Answer 1

可能重复的How to create a delayed sliding window in Azure Stream Analytics

你可以分两步做。步骤1计算滑动窗口，步骤2使用滞后计算斜率。