Dev Raw Data Source¶
根据用户提供的数据,生成原始数据。仅支持 Debug 阶段使用。
该算子为 StreamSets 原生算子,更多信息,可参考 Development Stages。
配置详情¶
使用该算子时,需要将 pipeline 的 Execution Mode 设置为 Standalone
,如下图所示:
该算子的配置包括 General,Raw Data,Data Format 的详细信息,各字段的配置如下:
General¶
名称 |
是否必须 |
描述 |
---|---|---|
Name |
Yes |
算子名称 |
Description |
No |
算子描述 |
On Record Error |
Yes |
对错误数据的处理方式,可选:
|
Raw Data¶
名称 |
是否必须 |
描述 |
---|---|---|
Raw Data |
Yes |
输入原始数据(格式可参考以下示例) |
Stop After First Batch |
No |
指定是否在生成第一批数据后即停止 |
原始数据示例¶
{
"orgId": "xxx",
"modelId": "Model",
"modelIdPath": "/rootModel/Model",
"assetId": "qXupozjG",
"pointId": "Point_A",
"time": 1567292293000,
"value": 1.2,
"quality": 0,
"attr": {}
}{
"orgId": "xxx",
"modelId": "Model",
"modelIdPath": "/rootModel/Model",
"assetId": "qXupozjG",
"pointId": "Point_B",
"time": 1567292292000,
"value": 1.2,
"quality": 0,
"attr": {}
}
Data Format¶
名称 |
是否必须 |
描述 |
---|---|---|
Data Format |
Yes |
选择生成数据的格式,可选 JSON,Log,Text,XML 等,推荐选择 JSON |
Compression Format |
Yes |
选择数据压缩格式,推荐选择 None |
其它选项 |
No |
根据输入的原始数据和选择生成数据的格式,完成相应的配置 |
输出结果¶
根据输入的原始数据和设置的数据格式,输出结果。