Asset Lookup*

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

  • 默认查找上一个算子输出 record 对应设备的信息
  • 支持自定义查询设备，并将该设备的查询信息写入每一个满足输入条件的 record 中
  • 支持指定需要查询的属性、标签
  • 详细信息封装在每条 record 的 /attr/tslAssetLookup 字段中
  • 与旧数据格式不兼容，即无法按 ModelId::PointId 进行数据过滤

配置详情

该算子的配置包括 General，Basic，Input/Output，Criteria 的详细信息，各字段的配置如下：

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 包括 ou，modelId，modelIdPath，tslInstanceName，tslInstanceDesc，label，timezone，和 extraInfo

输出结果

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

名称 数据类型 描述
/attr/tslAssetLookup Asset 资产主数据信息对象
Asset.attributes Map 资产属性 key-value 列表
Asset.tags Map 资产标签 key-value 列表
Asset.timezone String 资产上绑定的时区

输出示例

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