检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
产品过滤 算子简介 名称:产品过滤 功能说明:根据IoT设备接入服务(IoTDA)定义产品过滤出指定产品ID的设备数据。此算子仅在数据源为IoTDA时使用。 约束: 只允许跟在IoT设备接入数据源算子之后。 算子配置 基础配置项 算子名称: 配置项英文名:name 说明:算子名称
具体内容可参考 数据源配置 2. 配置数据管道:通过配置数据管道,用户可指定数据存储的位置,如果需要,也可以在管道中实现对数据的实时清洗。具体内容可参考数据管道 3. 配置存储:通过配置存储,用户可指定存储管理的策略,比如设置温存储各自的老化周期。 具体内容可参考存储管理 完成
string、double、integer、object 其中之一。 可能原因 属性的类型填写错误。 处理建议 请根据实际业务需要,将属性的数据类型指定为4中系统可支持的数据类型之一。 父主题: 存储管理相关错误码
获取实时作业详情 功能介绍 获取指定作业的详情 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/streaming/jobs/{job_id}
超时插补 算子简介 名称: 超时插补 功能说明: 提供基于时间的数据插补功能。时间支持延迟等待时长,以及指定固定时间点。插补数据为上一条实际数据,但是事件时间为插补计算出的时间。 约束: 下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称: 配置项英文名:name
获取管道作业详情 功能介绍 获取指定管道作业的详情 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/pipelines/{pipeline_id}
删除管道作业 功能介绍 删除用户指定的管道作业 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI DELETE /v1/{project_id}/pipelines/{pipeline_id}
删除实时作业 功能介绍 删除用户指定的作业 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI DELETE /v1/{project_id}/streaming/jobs/{job_id}
更新实时作业 功能介绍 更新作业时,需要在URL中指定是更新哪一个作业,将在body中附带完整的作业信息。 check参数表示是否需要对作业配置进行检查:若为false,则不检查,将作业保存为草稿;若为true,则对作业配置进行检查,当检查不通过时,返回失败及错误信息,检查通过时,将作业状态修改为就绪,并返回成功。
数据存储,如果需要把管道输出数据保存,则需要指定存储。如果没有指定存储,管道输出数据则不保存。 必选: 是 子配置项: 数据存储配置包含如下子配置项: 存储组ID、存储组名称、数据存储ID、数据存储名称、数据存储属性。 存储组ID: 配置项英文名:dataStorageGroupId 说明: 指定输出到数据存储
实时分析输出 算子简介 将经过数据管道清洗后的数据输出到实时分析,作为实时分析的数据来源。 算子配置 算子配置项如图所示: 算子名称:用户指定这个算子的名称。 管道输出数据名称:用户声明这个输出的名称,以便在实时分析作业的“管道数据输入”算子中使用。 属性:用户选择需要将哪些属性输出给实时分析进行后续的分析任务。
仅缓存的字段的最新取值。 需要指定缓存的索引字段,算子根据索引来查找对应缓存,索引字段支持多个数据字段组合。 数据去重 为了过滤掉重复数据,使用本算子。支持指定字段是否相同来判断是否是重复数据,比如指定温度字段没有变化则是重复数据,而事件时间字段每条数据取值不同。 支持指定去重超时时长,在超
^[a-zA-Z0-9][\w_-]{1,64}$ 事件时间: 配置项英文名:eventTime 说明: 事件时间,以JSON Path格式来指定事件时间的获取来源。如果没有指定,则使用接受消息时的系统时间作为消息产生的事件时间。 必选: 是 子配置项:事件时间包括如下子配置项:JSON路径、时间样式。
配置项英文名:datasSourceId 说明: 指定管道的输入IoT数据接入云服务数据源。 类型: STRING 必选: 是 约束: 需要符合正则表达式: ^[a-zA-Z0-9][\w_-]{1,64}$ 事件时间: 配置项英文名:eventTime 说明: 事件时间,以JSON Path格式来指定事件时间的获取
“ProductLine01_LaserMarking01” 显示名称:“产线01_镭雕机01” 选择模型:“laser_marking” 输入设备ID:XXXX (参见如何从IoTDA上获取设备ID) 1. 产线下的所有产品和设备需要在IoTDA上要预先创建完成,每条产线已预创建了7个设备,直接根据下表中的资产名称在IoTDA上查询设备ID即可。
说明:属性,以JSON Path格式来指定删除的属性。可以允许设置多个属性,表示删除多个属性。 类型:STRING 必选:是 约束:需要符合正则表达式: ^.{1,1000}$。 高级配置项 并行数: 配置项英文名:parallelism 说明:并行数,指定算子执行时的并行任务个数。对于
^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 事件时间: 配置项英文名:eventTime 说明: 事件时间,以JSON Path格式来指定事件时间的获取来源。如果没有指定,则使用接受消息时的系统时间作为消息产生的事件时间。 必选: 是 子配置项:事件时间包括如下子配置项:JSON路径、时间样式、时区。
更新管道作业 功能介绍 更新管道作业时,需要在URL中指定是更新哪一个作业,将在body中附带完整的作业信息。(管道作业详细配置,每个作业可选择不同的算子进行组合,各算子的使用方法详见:数据管道算子使用指南。) check参数表示是否需要对作业配置进行检查,若为false,则不检
单输出:分析任务的结果只能输出到本资产模型的某个属性上,且实例化成资产时固定输出到本资产。 多输出:分析任务的结果可以输出到多个不同资产模型的不同属性上,且实例化成资产时需要指定输出资产ID。 聚合计算 同转换计算 流计算 计算结果支持多输出,但实例化成资产时只能输出到本资产。 父主题: 分析任务定义
新建管道作业 功能介绍 新建管道作业时,需要在URL中指定是更新哪一个作业,将在body中附带完整的作业信息。(作业中各算子的详细配置请参考算子使用指南章节。) check参数表示是否需要对作业配置进行检查,若为false,则不检查,将作业保存为草稿;若为true,则对作业配置进