主要功能¶
EnOS 流数据处理服务提供以下主要功能：
连续的流数据处理
流数据处理引擎需要处理的数据是实时和连续的。数据流按时间顺序由流数据处理服务订阅和消费。数据是连续生成的，所以数据流被连续地集成到流数据处理系统中。因此，流数据始终是实时的和连续的。
连续高效的计算
EnOS 流数据处理服务的计算模式是“事件触发”式的。触发器是前面提到的连续流数据。每当新的流数据发送到流数据处理系统，系统立即启动并执行计算任务。因此，流数据处理是一个连续的过程，并且很高效。
实时流数据集成
流数据触发流数据处理之后，计算结果按照预配的存储策略，被连续记录到目标数据存储器中。
能源领域算法模板
EnOS 流数据处理服务沉淀了多套能源领域算法模板，用户可按需安装算法模板，并快速配置流数据处理任务。包括
- 时间窗口聚合模板
- 电量计算模板（按表读数）
- 电量计算模板（按瞬时功率）
- 电量计算模板（按平均功率）
原生算子库
EnOS 流数据处理服务提供多套底层封装好的原生算子库，供开发者按需安装后，基于业务需求开发定制化的流数据处理任务。更多信息，参考 算子参考说明。