azure-stream-analytics - 带有自定义窗口的 Azure 流分析

Question

我知道流分析有几个窗口功能。在我的情况下，我需要在一个时间窗口内聚合消息，每次字段（或字段组合）更改时，新窗口都应该启动。

具体来说：假设我有以下消息：

1. temp: 50, pressure: 5, productType: 车辆, alarmX:0
2. 温度：52，压力：4，产品类型：车辆，警报X：0
3. 温度：54，压力：3，产品类型：车辆，警报X：0
4. 温度：56，压力：2，产品类型：平面，警报 X：0
5. 温度：58，压力：3，产品类型：飞机，警报X：0
6. 温度：50，压力：5，产品类型：平面，警报 X：1
7. 温度：50，压力：5，产品类型：平面，警报 X：1
8. temp: 50, pressure: 5, productType: 车辆, alarmX:0
9. 温度：48，压力：5，产品类型：车辆，警报X：0

productType我想在一个由和/或的变化定义的窗口上进行聚合alarmX。所以我想汇总项目 (1,2,3) - (4,5) - (6,7) - (8,9)

使用流分析如何做到这一点？有替代方案吗？

Answer 1

您是否为此查看过会话窗口？您还需要某种时间戳列。