azure-stream-analytics - 带有自定义窗口的 Azure 流分析
问题描述
我知道流分析有几个窗口功能。在我的情况下,我需要在一个时间窗口内聚合消息,每次字段(或字段组合)更改时,新窗口都应该启动。
具体来说:假设我有以下消息:
- temp: 50, pressure: 5, productType: 车辆, alarmX:0
- 温度:52,压力:4,产品类型:车辆,警报X:0
- 温度:54,压力:3,产品类型:车辆,警报X:0
- 温度:56,压力:2,产品类型:平面,警报 X:0
- 温度:58,压力:3,产品类型:飞机,警报X:0
- 温度:50,压力:5,产品类型:平面,警报 X:1
- 温度:50,压力:5,产品类型:平面,警报 X:1
- temp: 50, pressure: 5, productType: 车辆, alarmX:0
- 温度:48,压力:5,产品类型:车辆,警报X:0
productType
我想在一个由和/或的变化定义的窗口上进行聚合alarmX
。所以我想汇总项目 (1,2,3) - (4,5) - (6,7) - (8,9)
使用流分析如何做到这一点?有替代方案吗?
解决方案
您是否为此查看过会话窗口?您还需要某种时间戳列。
推荐阅读
- go - Go Transport 中的 keep-alive TTL 从不关闭连接
- phpstorm - PhpStorm“rsa 密钥已损坏或版本错误”
- auth0 - Auth0 和 HostedPages
- javascript - 读取 JSON 并在 HTML 中实现
- rest - 使用 OAuth 注册一个 REST API
- sql - SQL Server 可以自动将随机 int 分配给 IDENTITY 列吗?
- c - atoi 似乎不适用于我的程序
- laravel - Laravel 创建 .po 和 .mo
- html - 使用 ngb-tabset 和选择器构建多步骤表单
- javascript - 使用 history.back() 函数时如何自动填充输入数据?