- 文档
- 算子参考说明
- 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 |
对错误数据的处理方式,可选:
|
Basic¶
名称 |
是否必须 |
描述 |
---|---|---|
Quality Filter |
No |
根据数据质量过滤处理数据,只有符合质量条件的 record 才会进行此次处理 |
Input/Output¶
名称 |
是否必须 |
描述 |
---|---|---|
Related Type |
Yes |
选择获取设备的方式,可选:
|
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 配置示例¶
输出示例:
Child On Tree 配置示例¶
输出示例: