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

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

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

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

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

1 ответ

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

Другие вопросы по тегам