Выбор частичных данных из входных данных аналитики потока

Question

У меня есть задание потоковой аналитики, которое получает данные из концентратора IOT и записывает данные в базу данных SQL Azure. Мой текущий запрос выглядит следующим образом

Выберите [Column1, Column2 ...] INTO [Output] из [Input]

Можно ли выбрать только определенное количество строк? Я ищу что-то вроде следующего

Выберите TOP 10 [Column1, Column2 ...] INTO [Output] из [Input]

Любые предложения будут оценены. Спасибо

Answer 1

Если у вас есть окно, вы можете использовать функцию LAG, как показано здесь:

SELECT
CollectTop (10) OVER (ORDER BY column1 DESC) как topColumn1, CollectTop (10) OVER (ORDER BY column2 DESC) как topColumn2 В выход С входа
Окно GROUP BY Tumbling (второе, 5)

Документацию можно найти здесь: https://docs.microsoft.com/en-us/stream-analytics-query/collecttop-azure-stream-analytics