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

Posted 2023-05-08

【中文标题】从流分析输入中选择部分数据

【英文标题】：Selecting partial data from stream analytics input

【发布时间】：2018-11-10 08:16:57

【问题描述】：

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

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

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

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

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

【问题讨论】：

好吧，首先告诉我，您想通过 Azure 流分析实现什么目标？基于这个问题，我想知道你知道它是为了什么而构建的。

【参考方案1】：

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

选择 CollectTop(10) OVER (ORDER BY column1 DESC) 作为 topColumn1， CollectTop(10) OVER (ORDER BY column2 DESC) as topColumn2 进入 输出 来自输入 GROUP BY TumblingWindow(second, 5)

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