数据流分析服务
数据流分析服务
概述
数据流分析分为实时数据分析和历史数据分析
实时数据分析通过订阅实时数据流，对收到的实时数据进行及时分析和处理
历史数据分析则通过定期调用分析任务，对数据库中的历史数据进行查询和分析处理
实时流分析
通过对数据流实时数据进行分析获取分析结果
实时统计任务
通过对数据库进行复杂查询实时获取统计结果
历史数据分析
通过定时任务，对最近周期内的历史数据进行查询和分析
定时任务
通过定时对数据库进行查询和统计，获取统计结果
任务流程
- 创建定时任务
- 进入定时任务
- 查询一段时间的数据
- 统计数据结果
- 保存数据结果
- 退出定时任务
任务参数
名称这个任务的名称类型系统任务系统级适用于所有账号的任务用户任务只适用于指定账号的任务
时间计划这个任务的执行计划时间操作这个任务的执行内容操作类型统计周期这个任务用于统计的数据的周期操作参数
操作类型
- 日志记录
- 调用 HTTP API
- 调用内置方法
内置方法
固件升级
升级列表:
- 待升级的设备, 由用户选择
- 待升级固件, 由用户选择
- 正在升级的设备, 由设备报告
- 已完成升级的设备, 由设备报告
任务流程:
- 定时执行，周期为 1 分钟
- 检查升级列表
- 发送升级请求
- 收到设备报告，更新升级状态
配置参数分发
分发列表:
- 待下发的设备, 由用户选择
- 待下发的参数, 由用户选择
- 已完成下发的设备, 由设备报告
用电统计
设备在线状态维护
在线状态类型:
- 实时在线, 设备和平台保持长连接或者可以随时接受服务端请求消息
- MQTT 在线
- CoAP 保存心跳
- 最近在线，设备最近上报过数据给平台
- 通过 HTTP 上报
- 离线，设备最近没有和平台有通信
- 从未连接，设备从未和平台有过通信
统计内容:
- 实时在线和离线设备数
- 设备上线和离线事件
- 设备离线告警
- 按天统计在线设备数
- 按账号统计在线设备数
- 按地点统计在线设备数
- 按设备类型统计在线设备数