azure - 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 之间的斜率。

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

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

标签： azurebigdataazure-stream-analyticscomplex-event-processingstream-analytics

Answer 1

如何在 Azure 流分析中创建延迟滑动窗口的可能重复项

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