Azure 流分析：从滑动窗口计算斜率

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 30s 之前的斜率。

使用tumbling window 可以使用LAG(avgTemp, 1)，但这只会每30 秒输出一次。

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

Answer 1

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

您可以分两步完成。 Step 1 计算滑动窗口，Step 2 使用 LAG 计算斜率。