产品定价 立即试用
社区版
aggregate stream(聚合流)
入门 文档 指南 安装 架构 API 常见问题

aggregate stream(聚合流)

Since TB Version 2.1

image

根据入站数据流计算MIN/MAX/SUM/AVG/COUNT/UNIQUE。 按消息originator id(如设备、Asset、Customer)、aggregation function(如 “Average”、”Sum”、”Min”、”Max”)、aggregation interval value(如1分钟、6小时)将入站数据流分组为 Intervals

Intervals按 interval persistence policyinterval check value 定期持久化。Intervals按 Interval TTL value 缓存在内存中。 Intervals状态按 state persistence policystate persistence value 作为时序实体持久化。 若某实体无数据,可为这些实体生成默认值。勾选 Create intervals automatically 并配置 Interval entities 可查找这些实体。

为各interval的聚合结果生成 POST_TELEMETRY_REQUEST 消息。

以下配置将计算每小时平均温度,在小时interval结束后一分钟内持久化。 若某interval有延迟telemetry到达,规则节点会从内部缓存或telemetry中查找。

image

聚合结果每分钟写入数据库一次。也可在每条新消息时持久化interval,以避免服务器故障时的数据丢失。 若某建筑下的设备未上报温度读数,可勾选 “Create Intervals automatically” 并指定 “Buildings” 实体组,从而在每个interval为这些建筑生成默认值(零)。

image

Since TB Version 3.3.3 可选择队列名:

image