检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
property_name 是 String 引用属性的名称 最大长度:64 表17 StreamOutput 参数 是否必选 参数类型 描述 name 是 String 输出参数名称,必须是接收数据类型为资产数据的实时分析作业中已定义的 最大长度:128 output_property 是 String
property_name 是 String 引用属性的名称 最大长度:64 表17 StreamOutput 参数 是否必选 参数类型 描述 name 是 String 输出参数名称,必须是接收数据类型为资产数据的实时分析作业中已定义的 最大长度:128 output_property 是 String
必选:是 约束:必须是MORE_THAN、MORE_THAN_EQUAL、LESS_THAN、LESS_THAN_EQUAL、EQUAL、NOT_EQUAL中的一个。 数值: 配置项英文名:value 说明:数值, 即条件的右值,如条件:大于100中的100即为value的值。 类型:STRING
允许固定时间延迟的分配器,适用于乱序但预先知道或只允许在流中将会遇到的最大延迟的场景。 AscendingTimestampExtractor:递增时间戳的分配器,适用于每个元素(elements)的时间在每个并行任务(parallel task)里是单调递增的场景。 IngestionTimeExtractor:
分区键,用于作为消息分区/分组的标识,具体填入的内容为消息中获取的JSON Path,比如可以选择消息中设备ID所在的JSON Path。 设置后,拥有该分区键数值相同的所有消息会进入一个分区,比如分区键选择了设备ID后,所有相同设备ID的消息进入一个分区。当选择多个字段时,按指定字段顺序组合成的字符作
参数类型 描述 project_id 是 String 项目ID 最大长度:128 asset_id 是 String 资产ID 最大长度:256 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 租户Token 最大长度:65535
允许固定时间延迟的分配器,适用于乱序但预先知道或只允许在流中将会遇到的最大延迟的场景。 AscendingTimestampExtractor:递增时间戳的分配器,适用于每个元素(elements)的时间在每个并行任务(parallel task)里是单调递增的场景。 IngestionTimeExtractor:
参数类型 描述 project_id 是 String 项目ID 最大长度:128 asset_id 是 String 资产ID 最大长度:256 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 租户Token 最大长度:65535
project_id 是 String 项目ID 最小长度:1 最大长度:128 data_store_id 是 String 存储ID 最小长度:1 最大长度:64 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 租户Token
数值计算,计算的结果赋值给当前输入消息的属性。 举例:消息中有上报机器的产品总产量,但没有相对上一个上报周期的增量产量。通过相邻消息计算算子,可以用本消息中的产品总量减去上一个消息中的产品总产量,得到的计算结果赋予一个新的属性,比如产品增量。那么经过本算子清洗后的消息中,都将携带产品增量属性了。
说明:计算配置,配置属性的计算表达式。 必选:是 子配置项:计算配置包括如下子配置项:属性、表达式。 属性: 配置项英文名:property 说明:属性名,表示计算表达式所计算的结果赋予的对象。 用户可以选择消息中已有的某个属性,或者自行输入新的内容,该内容需要满足Json path语法的要求 。
存储 存储是保存数据的对象,通常来说,同一种设备的数据会保存在同一个存储中。存储中定义了设备的标签与设备的属性。其中设备ID(deviceId)就是最常用的一种标签(tag)。一个标签包括标签名与标签值,例如设备ID:标签名为 deviceId,而它的标签值则是具体的某个设备ID
project_id 是 String projectid 最小长度:1 最大长度:256 datasource_id 是 String 数据源id 最小长度:1 最大长度:256 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String
允许固定时间延迟的分配器,适用于乱序但预先知道或只允许在流中将会遇到的最大延迟的场景。 AscendingTimestampExtractor:递增时间戳的分配器,适用于每个元素(elements)的时间在每个并行任务(parallel task)里是单调递增的场景。 Inges
说明:扁平字段配置,配置需要进行扁平处理的字段列表。 必选: 是 子配置项:扁平字段配置包括如下子配置项:源数据路径、字段名称。 源数据路径: 配置项英文名:path 说明:源数据路径,以JSON Path格式来指定变量从消息中指定的JSON Path属性获取的取值。 类型:STRING 必选:是 约束:需要符合正则表达式:
参数类型 描述 name 是 String 输出参数名称,formulas中定义的name 最大长度:128 output_static_asset_id 否 String 输出资产ID,填写模型中定义的输出模型对应的某资产ID;创建资产时,如果是输出到本资产的模型,且output_
header 测试数据头字段,必须是json格式。 是 projectId 租户id,必须模板默认值,用户不能修改。 是 dataSourceId 数据源id,必须模板默认值,用户不能修改。 是 body 数据体字段,必须是json格式,格式不能修改。 是 body.header Io
参数类型 描述 name 是 String 输出参数名称,formulas中定义的name 最大长度:128 output_static_asset_id 否 String 输出资产ID,填写模型中定义的输出模型对应的某资产ID;创建资产时,如果是输出到本资产的模型,且output_
project_id 是 String 项目ID 最小长度:1 最大长度:128 data_store_id 是 String 存储ID 最小长度:1 最大长度:64 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 租户Token
project_id 是 String 项目ID 最小长度:1 最大长度:128 pipeline_id 是 String 管道ID 最小长度:1 最大长度:100 表2 Query参数 参数 是否必选 参数类型 描述 parallel 否 Integer 运行管道的并发度 最小值:0