logo
概览
产品文档
教程
开发资源
报告安全问题
2.4.4
简体中文
menu
EnOS 流数据处理

EnOS 流数据处理

流数据处理介绍

  • 概述
  • 应用场景
  • 主要功能

操作指南

  • 入门指引
  • 使用算法模板开发流数据处理任务
  • 使用算子进行开发
  • 运维流数据处理任务
  • 监控集群资源

参考

  • 流数据处理常见问题
  • 流任务运维常见问题
  • API 参考
  • 时间窗口参考说明
  • 电量计算逻辑
  • 算子参考说明
    • Operator Library 0.1.0 参考文档
    • Operator Library 0.2.0 参考文档
    • Operator Library 0.3.0 参考文档
      • 数据源算子
      • 资产主数据算子
      • 数据处理算子
        • Normalizer
        • Point Selector
        • Record Generator
        • Virtual Record Generator
        • Related Record Obtainer
          • 配置详情
            • General
            • Basic
            • Input/Output
            • Data Generation
          • 输出结果
            • 输出示例
              • Same Asset 配置示例
              • Child On Tree 配置示例
        • Partitioner
        • Record Sorter By Time
        • Fixed Time Window Aggregator
        • Sliding Time Window Aggregator
        • Batch Merger
        • Last Changed Record Appender
        • Latest Record Merger
        • Record Capturer
        • Record Restorer
        • Python Evaluator
        • JavaScript
        • Internal HTTP Client
      • 数据质量算子
      • 电量计算算子
      • 目标算子
      • 算子性能说明
    • Operator Library 0.4.0 参考文档

最近更新 2024-08-31

可用的 EnOS 功能取决于 License 和账号权限。如果某些功能在你的环境中不可用,可咨询系统管理员。
  • 文档
  • 算子参考说明
  • Operator Library 0.3.0 参考文档
  • Related Record Obtainer
  • 编辑

Related Record Obtainer¶

根据配置的条件读取设备测点的最新值,产生新的数据(Record)。具体功能如下:

  • 设备获取方式支持当前设备和从资产树获取设备

  • 从资产树获取设备支持设备节点递归

  • 支持逻辑资产树

  • 依赖 Redis 服务获取设备测点最新值。若测点不存在或测点无值,则不输出。

  • 输出结果按照 Output Point 输出配置进行分组


注意事项:

  • 根据资产树标签(tree tag)获取资产树时,仅支持单个标签,需保证标签有效。

  • 由于合并输出结果,如按照资产树获取大量设备且设置多个相关点输出,有可能造成最终 Record 膨胀。需评估资源使用情况,避免导致内存使用的问题。

配置详情¶

该算子的配置包括 General,Basic,Input/Output,和 Data Generation 的详细信息,各字段的配置如下:

General¶

名称

是否必须

描述

Name

Yes

算子名称

Description

No

算子描述

Stage Library

Yes

算子所属的库

On Record Error

Yes

对错误数据的处理方式,可选:

  • Discard:直接丢弃

  • Send to Error:发送至错误中心

  • Stop Pipeline:停止流任务运行

Basic¶

名称

是否必须

描述

Quality Filter

No

根据数据质量过滤处理数据,只有符合质量条件的 record 才会进行此次处理

Input/Output¶

名称

是否必须

描述

Related Type

Yes

选择获取设备的方式,可选:

  • Same Asset:当前设备

  • Child On Tree:从资产树获取设备(用于场站计算)

Asset Tag

No

当选择 Child On Tree 条件时,选择根据资产树标签搜索资产树

Input Point

Yes

输入数据点名称,格式为:{模型标识}::{测点标识}

Related Point

Yes

数据相关点名称,格式为:{模型标识}::{测点标识},标识待获取的设备测点

Output Point

Yes

数据输出点名称,格式为:{模型标识}::{测点标识},如果配置内输出点重复,将分组后输出

Data Generation¶

名称

是否必须

描述

Data Source

Yes

通过 Redis 服务查询测点数据,数据过期策略参见 Redis API

Last Update Interval Filter Enabled

No

选择是否按一定的时间间隔从 Redis 获取测点最新数据

Last Update Interval in Minutes

No

当选择按一定的时间间隔获取数据时,输入时间间隔的值

None Existing Point Handle

Yes

当未获取到测点数据时,忽略该测点,不输出

输出结果¶

该算子的输出结果为新的 records,record 中包括:

  • 通用字段(如 assetId、pointId、modelId、time、value 等),其中 value 无实际意义,值为 0。

  • Stage 配置属性字段:attr/relatedRecordObtainer,该字段数据类型为 map。map 中的 key 为设备 ID(字符串类型),value 为一个 map(map 的key 为测点,value 为该测点的详细信息)。

输出示例¶

Same Asset 配置示例¶

../../../_images/related_record_obtainer_config_1.png


输出示例:

../../../_images/related_record_obtainer_result_1.png

Child On Tree 配置示例¶

../../../_images/related_record_obtainer_config_2.png


输出示例:

../../../_images/related_record_obtainer_result_2.png
Previous Next

预览:

0  字
评论
  • 按正序
  • 按倒序
本页内容
    • 配置详情
      • General
      • Basic
      • Input/Output
      • Data Generation
    • 输出结果
      • 输出示例
        • Same Asset 配置示例
        • Child On Tree 配置示例
© 2025 远景智能版权所有。 | 隐私声明 用户协议