入门指引¶
资源准备 ¶
配置和运行流数据处理任务前,需确保组织已经通过 EnOS 管理控制台 > 资源管理 页面申请 流数据处理 资源。流数据处理 资源包含以下几种资源模式,分别用于开发和运行流数据处理任务:
- 设计态资源:用于安装流数据处理算法模板、系统算子包、或自定义算子包,创建和设计流数据处理任务。
- Standalone模式:用于以 Standalone 模式运行流数据处理任务。
- 集群模式:用于以集群模式运行流数据处理任务。
有关申请 流数据处理 资源的详细信息,参见 流数据处理资源规格说明。
当业务不再需要运行流数据处理任务,可通过 资源管理 页面删除和释放已申请的流数据处理资源,降低资源使用成本。
安装算法模板和算子包 ¶
开发流数据处理任务之前,需要安装对应的算法模板和算子包。
安装算法模板 ¶
通过以下步骤安装算法模板:
登录 EnOS 管理控制台,在 企业数据平台 分类下选择 流数据处理 > 包管理。
点击 算法模板 标签,查看可安装的算法模板。目前支持安装以下算法模板:
- 时间窗口聚合模板:支持对单设备单测点数值类型数据的聚合处理
- 电量计算模板(按表读数):支持按电能表读数计算天级电量
- 电量计算模板(按瞬时功率):支持按瞬时功率计算天级电量
- 电量计算模板(按平均功率):支持按平均功率计算天级电量
确定需要安装的算法模板后,点击 安装,系统会自动开始安装算法模板。
安装系统算子包¶
通过以下步骤安装系统算子库:
登录 EnOS 管理控制台,在 企业数据平台 分类下选择 流数据处理 > 包管理。
在 算子Libs 标签下,查看可安装的算子库。
确定需要安装的算子包后,点击 安装,系统会自动开始安装算子包。
安装自定义算子包¶
登录 EnOS 管理控制台,在 企业数据平台 分类下选择 流数据处理 > 包管理。
在 自定义算子Libs 标签下,点击 添加算子lib,上传和安装自定义算子包。
- 分别输入算子包的名称、版本、和描述(算子包名称可重复,但算子包版本需高于已有算子包的版本)。
- 上传算子包文件(需封装为 .tar.gz 文件格式,且不能超过300M)。
- 上传元数据文件(需封装为 .zip 文件格式,且不能超过5M)。
点击 确定,系统会开始上传算子包文件和元数据文件。上传完成后,算子包将会显示在自定义算子包列表中,其状态为 未安装。
点击 安装,系统会自动开始安装自定义算子包。
数值型数据聚合处理教程¶
本教程能帮助你快速学习如何使用 时间窗口聚合模板 对数值类型流数据进行聚合处理。
前提条件¶
- 账号已获取流数据处理服务的访问权限。如未获取,联系系统管理员。
- 组织已申请流数据处理资源。更多信息,参见 资源准备。
- 已安装时间窗口聚合算法模板。更多信息,参见 安装算法模板。
- 已接入设备并且设备已经在发送数据。有关接入设备的更多信息,参见 设备连接及云端设备管理。
教程目标及数据准备¶
教程目标
本教程要实现的场景是:将原始采集点 test_raw 的数据进行每5分钟取最大值,取值结果输出给新点 test_5min。
数据准备
- 模型配置:本教程使用的模型 (test_Model) 配置如下:
功能类型 | 名称 | 标识符 | 测点类型 | 数据类型 |
---|---|---|---|---|
测点 | test_raw | test_raw | AI | DOUBLE |
测点 | test_5min | test_5min | AI | DOUBLE |
注解
- 其中 test_raw 为原始数据采集点,test_5min 是原始点要经过流数据处理聚合后输出的数据点名称。
- 必须保证需要处理的输入点和输出点的测点类型相同。
第一步:创建并配置流数据处理任务¶
- 登录 EnOS 管理控制台,点击 流数据处理 > 流开发 菜单可浏览当前组织所有已创建的流数据处理任务。双击某一任务,可进行详情查看并编辑。
- 在任务列表上方,点击 + 添加新任务。选择常规流类型、新建流数据处理任务,并输入任务的名称和描述。
- 从 模板 下拉菜单中,选择已安装的 时间窗口聚合模板 和对应的模板版本号。
- 选择 实时通道 为数据通道,用于处理资产实时数据,然后点击 确认。
- 配置流数据处理任务窗口策略
- 窗口类型,选择滚动窗口:表示按固定的时间窗口对数据做聚合运算,窗口连续且不重叠。
- 延迟设置,选择:0 second 表示窗口不延迟,超出时间窗口到达的数据不被加入计算。
- 配置数据处理策略。点击 新增策略,列表会新增一条记录。记录的配置项描述如下:
- 输入点:选择AI原始数据采集点,本教程中选择 test_Model的test_raw 测点
- 阈值限定:对参与计算的数据点进行阈值过滤,本教程设置为 [0,10]
- 插补策略:对超出阈值范围的数据进行插补,目前只能选择 Ignore,即超出阈值范围的数据不参与聚合计算
- 聚合算法:设定数据处理算法,当某一时间窗口在销毁时,会对已到达的该窗口的数据进行处理,本教程选择 max 算法
- 窗口大小:设定聚合算法作用的时间区间,本教程中选择 5 minutes
- 输出点:选择聚合结果输出点,本教程中选择 test_5min
- 点击 操作 列中的 保存 图标,保存数据处理策略
第二步:保存并发布流数据处理任务¶
任务配置完成后,需要对配置进行保存,保存后可激活发布按钮。点击 发布,将任务发布上线。下图为任务配置示例:
第三步:配置流数据处理任务运行资源¶
进入 流数据处理 > 流运维 页面,查看已发布的流数据处理任务,其默认状态为 PUBLISHED。在启动流数据处理任务前,需要配置流数据处理任务所需的运行资源。
通过以下步骤,配置流数据处理任务运行资源:
- 从 操作 列中,选择 … > 运行配置。
- 在弹窗中,选择 Standalone模式 作为运行模式,输入数据读取速率,然后输入运行任务所需的CU数。
- 点击 确定 完成运行资源配置。
注解
配置流数据处理任务运行资源,需确保组织已申请相应模式的运行资源。如需申请计算资源,请参考 快速申请资源。
第四步:启动流数据处理任务¶
为保证流数据处理任务能够正常运行,需要先启动相关的系统流任务。本教程需启动 Data Reader RealTime 系统流任务。
通过以下步骤,启动流数据处理任务:
- 在 流运维 页面,点击 系统流任务列表 标签,启动对应运行模式的系统流任务。
- 点击 用户流任务列表 标签,启动已发布的流数据处理任务。
第五步:查看任务运行结果¶
流数据处理任务启动后,在任务列表的 名称 一栏中,点击已启动的流数据处理任务名称,可查看任务运行情况:
- Summary: 查看任务运行情况总结,比如整体处理记录统计、各个时间段聚合情况。
- Log: 点击页面右上角 View Logs 图标,可查看任务运行日志。
- Results: 可通过接口 Get Asset AI Data with Aggregation Logic 来获取输出点 test_5min 的分钟级归一化数据。调用用Open API的代码示例,请前往 EnOS 管理控制台 > EnOS API,查看API文档。