Asset Lookup*

支持查找指定设备的属性/标签/时区等资产主数据信息,具体功能如下:

  • 默认查找上一个算子输出 record 对应设备的信息

  • 支持自定义查询设备,并将该设备的查询信息写入每一个满足输入条件的 record 中

  • 支持指定需要查询的属性、标签

  • 详细信息封装在每条 record 的 /attr/tslAssetLookup 字段中

  • 与旧数据格式不兼容,即无法按 ModelId::PointId 进行数据过滤

配置详情

该算子的配置包括 GeneralBasicInput/OutputCriteria 的详细信息,各字段的配置如下:

General

名称

是否必须

描述

Name

Yes

算子名称

Description

No

算子描述

Stage Library

Yes

算子所属的库

Required Fields

No

数据必须包含的字段,如果未包含指定字段,则 record 将被过滤掉

Preconditions

No

数据必须满足的前提条件,如果不满足指定条件,则 record 将被过滤掉。例如:${record:value('/value') > 0}。有关 EL 语句的使用方法,参考 Expression Language

On Record Error

Yes

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

  • Discard:直接丢弃

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

  • Stop Pipeline:停止流任务运行

Basic

名称

是否必须

描述

Quality Filter

No

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

Input/Output

名称

是否必须

描述

Input/Output

Yes

查找规则,由于资产主数据信息是打在每一条 record 上的,所以每一条规则需设置要附加资产主数据信息的测点,最终结果需要用输出点进行承载

Input Measurement

Yes

单条规则的输入点,即需要附加资产主数据信息的测点

Output Measurement

Yes

单条规则的输出点,即承载输出结果的测点

Criteria

名称

是否必须

描述

Attribute

No

支持通过资产设备属性 ID 作为 key 进行查询

Tag

No

支持通过资产设备的标签作为 key 进行查询

Extra

No

支持通过资产设备的额外信息进行查询,支持的 key 包括 oumodelIdmodelIdPathtslInstanceNametslInstanceDesclabeltimezone,和 extraInfo

输出结果

该算子的输出结果包含在 attr 结构体中,各字段的描述如下:

名称

数据类型

描述

/attr/tslAssetLookup

Asset

资产主数据信息对象

Asset.attributes

Map

资产属性 key-value 列表

Asset.tags

Map

资产标签 key-value 列表

Asset.timezone

String

资产上绑定的时区

输出示例

../../../_images/tsl_asset_lookup_result11.png