如何解决Azure Stream Analytics中滑动窗口的累积求和异常问题

DevOps 小满

2026-6-22

需求说明

需按col1和col2进行聚合：

若status字段值为ended或completed，则对应col2的取值为0；
若status为started或connected，则对应col2取值为1；
最终按col1汇总这些取值的总和。

输入数据

col1	col2	status	flag
Q1	P1	started	1
Q1	P1	connected	1
Q1	P1	ended	0
Q1	P1	completed	0
Q1	P2	started	1
Q1	P2	connected	1
Q1	P2	ended	0
Q1	P2	completed	0
Q2	P3	started	1
Q2	P3	connected	1

预期输出

col1	count
Q1	0
Q2	1

问题场景

我已经通过滑动窗口计算出col2级别的flag最小值，但在按col1聚合时，使用slidingwindow(day,1)出现了累积求和，得不到预期结果。我的SQL代码如下：

with min_val as (
select col1, 
col2,
min(flag) as val 
from cte 
group by col1,col2, slidingwindow(day,1))

select col1
,sum(val)
from min_val
group by col1, slidingwindow(day,1) -- 这里的滑动窗口导致了累积求和

解决方案

问题出在两次聚合都嵌套了滑动窗口slidingwindow(day,1)，导致第二次聚合时触发了累积求和逻辑。根据你的需求和示例数据，其实不需要滑动窗口的累积效果，直接去掉即可：

修正后的SQL

with min_val as (
select col1, 
col2,
min(flag) as val 
from cte 
group by col1, col2)

select col1,
sum(val) as count
from min_val
group by col1

逻辑说明

第一步聚合min_val：按col1和col2分组取flag的最小值，刚好匹配需求逻辑——只要col2对应记录里有0（存在ended/completed状态），val就为0；若全是1（只有started/connected状态），则val为1。
第二步聚合：按col1直接汇总val的和，就能得到预期结果。