ASA Lag возвращает результат извне заданной продолжительности

Question

Я пытаюсь использовать потоковую аналитику Azure для фильтрации результатов, которые слишком далеки от последних 2 чтений. Однако, если время последнего чтения превышает 720 минут (по времени чтения), я не хочу отказываться от текущего чтения из-за этой разницы.

Я заметил, что следующее возвращает чтение из 900 минут назад, что, насколько я понимаю, неожиданно:

LAG(Reading,2) 
OVER (PARTITION BY RegisterNumber LIMIT DURATION(minute, 720)) 
[BeforeLastReading]

Я могу игнорировать это чтение в моем запросе выбора, но я предпочитаю понять причину, прежде чем отказаться от использования функции продолжительности ...

Answer 1

Вы пытались использовать предложение TIMESTAMP BY? Вы можете найти больше документации по этому вопросу здесь: https://docs.microsoft.com/en-us/stream-analytics-query/timestamp-by-azure-stream-analytics