azure - 从流分析输入中选择部分数据

Question

我有一个流分析作业，它从 IOT 集线器接收输入并将数据写入 Azure SQL 数据库。我目前的查询如下

从 [输入] 中选择 [Column1,Column2...] INTO [Output]

是否可以只选择特定数量的行？我正在寻找类似以下的东西

从 [Input] 中选择 TOP 10 [Column1,Column2...] INTO [Output]

任何建议，将不胜感激。谢谢

Answer 1

如果你有一个窗口，你可以使用 LAG 函数，如下所示：

SELECT
CollectTop(10) OVER (ORDER BY column1 DESC) as topColumn1, CollectTop(10) OVER (ORDER BY column2 DESC) as topColumn2 INTO output FROM input
GROUP BY TumblingWindow(second, 5)

可在此处找到文档：https ://docs.microsoft.com/en-us/stream-analytics-query/collecttop-azure-stream-analytics