Virtual Record Generator

根据配置的条件产生新的数据（Record），具体功能如下：

  • 按照固定的触发频率生成所需要的 Record。支持多频率触发。

  • 根据各种过滤条件（模型 ID、资产标签），确定要计算的设备（Asset ID）及其测点（Point ID）的数据集合，即一个 Map<assetId,Set<point>>。

  • 根据以上的数据集合，按固定的技术频率，模拟生成触发点数据。

配置详情

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

General

名称

是否必须

描述

Name

Yes

算子名称

Description

No

算子描述

Stage Library

Yes

算子所属的库

On Record Error

Yes

对错误数据的处理方式，可选：

  • Discard：直接丢弃

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

  • Stop Pipeline：停止流任务运行

Output

名称

是否必须

描述

Generate Type

Yes

选择产生数据集合的方式，可选：

  • By ModelIDs：通过模型 ID 匹配测点

  • By Asset Tags：通过资产标签匹配测点

Trigger Frequency

Yes

指定生成 Record 的触发频率，可选：

  • 1 Second

  • 10 Seconds

  • 30 Seconds

  • 1 Minute

  • 5 Minutes

  • 10 Minutes

  • 30 Minutes

Model

No

当选择 By ModelIDs 条件时，输入模型 ID；对应的 Output Point 中的数据输出点名称，格式为：{模型标识}::{测点标识}

AssetTag Key::Value

No

当选择 By Asset Tags 条件时，输入资产标签键值对；对应的 Output Point 中的数据输出点名称，格式为：{模型标识}::{测点标识} 或 {测点标识}

Output Point

Yes

数据输出点名称，格式为：{模型标识}::{测点标识}

输出结果

该算子的输出结果为新的 Records。Record 中包括：

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

输出示例

../../../_images/virtual_record_generator_result.png