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