边缘计算¶

对于模型点，往往需要做一些预处理，或者执行某些简单计算，这些可以直接利用EnOS Edge边缘计算模块来执行。

EnOS Edge致力于沉淀IoT领域的流处理常用算法，开发者只需通过简单的模板配置即可完成流数据处理任务的开发及运维。此外，EnOS Edge边缘计算服务还提供一整套底层封装好的StreamSets算子，供开发者开发定制化的流数据处理任务，满足复杂的业务需求。

一般来说，数据的生成可以看作是一系列离散事件。在时间轴上绘制这些离散事件时，将形成事件流或数据流。流数据由这些连续的事件流组成。离线数据和流数据通常都被作为日志发送。与传统的离线数据不同，流数据是由许多数据源连续生成的。但是，流数据的数据量通常小于离线数据的量。流数据的常见数据源是连接到数据中心的设备、设备的遥测数据、以及移动应用或Web应用程序生成的日志文件。

应用场景¶

EnOS Edge边缘计算服务可以应用于如下场景：

资产原始数据的聚合计算：在大多数业务场景中，您可能需要过滤从设备接收到的原始数据，通过特定的算法对数据进行计算，并保存聚合计算后的数据以便作进一步分析。
设备状态计算：在某些业务场景中，您可能需要获取设备的状态参数以确认其状态。通过边缘计算的流数据处理，可维护设备和站点的状态 (系统将测量点值和设备连接状态更新为最新状态，如果设备测点停止上送数据，设备连接可能中断）。

功能特征¶

连续的实时数据流

流数据处理引擎需要处理的数据是实时和连续的。数据流按时间顺序由流数据处理服务订阅和消费。数据是连续生成的，所以数据流被连续地集成到流数据处理系统中。因此，流数据始终是实时的和连续的。

连续高效的计算

EnOS Edge边缘计算服务的计算模式是“事件触发”式的。触发器是前面提到的连续流数据。每当新的流数据发送到流数据处理系统，系统立即启动并执行计算任务。

实时流数据集成

流数据触发流数据处理之后，计算结果按照预配的存储策略，被连续记录到目标数据存储器中。

流数据处理流程¶

原始数据处理

测点原始数据由规约采集后，按照点映射模板转换为模型测点，再发送至边缘计算模块。边缘计算服务按指定的阈值过滤数据。超过阈值范围的数据将通过插值算法进行处理。
数据计算

经过阈值过滤之后的数据，由数据处理策略中定义的算法进行聚合计算。
输出计算结果

经流数据处理模块处理之后的数据会流入下游模块，并按照预先配置的存储策略，将其记录到时序数据库（TSDB）或其它目标存储系统中。用户可通过EnOS API查询存储的数据。

StreamSets算子¶

EnOS Edge边缘计算服务提供一整套底层封装好的StreamSets算子，供开发者基于业务需求开发定制化的流数据处理任务。有关EnOS Edge支持的StreamSets算子的详细信息，参见支持的StreamSets算子列表