我正在使用 Azure 流分析进行实时分析,但我遇到了一个基本问题。我有一个字段,我想计算消息的数量。json 格式如下:
{ categoryId: 100, name: 'hello' }
我想按类别查看计数,因此我假设 Azure 流分析中的查询应该是:
SELECT
categoryId,
count(*) as categoryCount
INTO
categoriesCount
FROM
categoriesInput
GROUP BY
categoryId
问题是我必须将 TumblingWindow 或 SlidingWindows 添加到 group by 子句中。有没有办法避免这种情况并让计算无限期地运行?我还需要确保将输出写入 SQL 服务器。