Azure stream analytics with custom windows

Question

I know stream analytics has several window funcitons. In my case I need to aggregate messages over a time window where a new window should start every time a field (or a combination of fields) change.

To make this concrete: suppose I have the following messages:

1. temp: 50, pressure: 5, productType: vehicles, alarmX:0
2. temp: 52, pressure: 4, productType: vehicles, alarmX:0
3. temp: 54, pressure: 3, productType: vehicles, alarmX:0
4. temp: 56, pressure: 2, productType: planes, alarmX:0
5. temp: 58, pressure: 3, productType: planes, alarmX:0
6. temp: 50, pressure: 5, productType: planes, alarmX:1
7. temp: 50, pressure: 5, productType: planes, alarmX:1
8. temp: 50, pressure: 5, productType: vehicles, alarmX:0
9. temp: 48, pressure: 5, productType: vehicles, alarmX:0

I want to aggregate over a window defined by a change in productType and/or alarmX. So I want to aggregate over items (1,2,3) - (4,5) - (6,7) - (8,9)

How is this possible using stream analytics? Is there an alternative?

Answer 1

Have you looked into session windows for this ? You'll need some sort of timestamp column as well .