Azure Stream Analytics: вычислить уклон из скользящего окна

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: Я хотел бы рассчитывать наклон в реальном времени каждый раз, когда новое скользящее окно вычисляется скользящим окном.

Answer 1

Возможный дубликат Как создать скользящее окно с задержкой в ​​Azure Stream Analytics

Вы можете сделать это в два этапа. Шаг 1 вычисляет скользящее окно, Шаг 2 вычисляет наклон, используя LAG.