带有自定义窗口的 Azure 流分析

问题描述

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

为了具体说明：假设我有以下消息：

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

我想在 productType 和/或 alarmX 中的更改定义的窗口上进行聚合。所以我想聚合项目 (1,2,3) - (4,5) - (6,7) - (8,9)

如何使用流分析实现这一点？有没有替代品？

解决方法

您是否为此调查过 session windows？您还需要某种时间戳列。