检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
启动管道作业 功能介绍 提交管道作业到运行环境,实时接收数据源的数据并按用户定义的数据清洗逻辑对数据进行处理。 调试 您可以在API Explorer中调试该接口,支持自动认证鉴权。API Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST
基本概念介绍 为了构建物联网领域业务对象的数字孪生模型,IoT数据分析服务参考软件工程中面向对象的思想提供了“资产建模”能力,其中核心概念包括资产模型和资产,下面将对此概念进行介绍。 资产模型(AssetModel) 资产模型是对物理世界中同类事物的抽象定义,资产模型中包括属性和
新建作业 操作场景 实时分析是以作业为管理对象,您首先需要根据实时业务诉求创建实时分析作业。 IoT数据分析服务实时分析可使用数据管道与资产模型作为数据源,请您先确认已创建数据管道或资产模型,相关操作请参考数据管道、资产模型。 如果您所要求的实时任务需要发送数据到你申请的DIS云
^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 数据源ID: 配置项英文名:datasSourceId 说明: 数据源ID,指定Pipeline作业的IoTDA数据源ID。 数据源ID可以通过数据源接口: /v1/${project_id}/datasources?type=IOTDA
IoT设备接入数据源 API接入数据源 表1 算子支持表 算子类别 算子中文名称 算子英文名称 是否支持调试 是否展示输入数据 是否展示输出数据 输入类算子 IoT设备接入数据源 IoTDASource 是 否 是 API接入数据源 APISource 是 否 是 DIS数据源 DISSource
说明:扁平字段配置,配置需要进行扁平处理的字段列表。 必选: 是 子配置项:扁平字段配置包括如下子配置项:源数据路径、字段名称。 源数据路径: 配置项英文名:path 说明:源数据路径,以JSON Path格式来指定变量从消息中指定的JSON Path属性获取的取值。 类型:STRING
同类型的算子配置。各个算子配置的详细说明请参考”算子使用指南”。 产品过滤 “产品过滤”仅可添加在“IoT设备接入数据源”算子后,因此,仅在“IoT设备接入数据源”算子上点击右键时,可以看到“产品过滤”算子。 添加好算子节点后,在算子节点上点击鼠标左键,即可打开右侧的算子配置面板,如图:
消息头,必须模板默认值,用户不能修改。 是 projectId 租户id,必须模板默认值,用户不能修改。 是 dataSourceId 数据源id,必须模板默认值,用户不能修改。 是 pipelineId 管道任务id,必须模板默认值,用户不能修改。 是 rtaOutputName
约束: 只支持4种数据类型INTEGER、DOUBLE、STRING、OBJECT。 源属性: 配置项英文名:existingProperty 说明: 源属性,以JSON Path格式来指定源属性,以作为输出属性的取值。 类型: STRING 必选: 是 约束: 需要符合正则表达式:
资产数据输入(旧) 数据存储数据源(旧) 表1 算子类别 算子中文名称 算子英文名称 是否支持调试 是否展示输入数据 是否展示输出数据 输入算子 资产数据输入 AssetDataSource 是 否 是 AssetJobSource 是 否 是 数据存储数据源(旧) DataStoreSource
名称:产品过滤 功能说明:根据IoT设备接入服务(IoTDA)定义产品过滤出指定产品ID的设备数据。此算子仅在数据源为IoTDA时使用。 约束: 只允许跟在IoT设备接入数据源算子之后。 算子配置 基础配置项 算子名称: 配置项英文名:name 说明:算子名称,对算子进行个性化的命名,
Explorer可以自动生成SDK代码示例,并提供SDK代码示例调试功能。 URI POST /v1/{project_id}/streaming/jobs/{job_id}/start 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 项目ID 最小长度:1
创建数据管道”。 输入作业名称,描述,选择数据源“IoTDA”类型,单击“确定”进入作业编辑页面。 此处所选择数据源需要预先创建,即在前面已完成IoTDA服务授权配置。 进入管道作业编辑页面,系统默认为作业配置了“IoT设备接入数据源“,“产品过滤”,“数据存储输出” 3个算子,如下图所示。
删除属性 算子简介 名称:删除属性 功能说明:从数据中删除指定的属性。 约束:下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称: 配置项英文名:name 说明:算子名称,对算子进行个性化的命名,以辅助增加可读性。支持中文、英文、数字、中划线、下划线,长度小于等于64个字符。
选择属性 算子简介 名称:选择属性 功能说明:在输入数据中选择保留的属性,未选择的属性被删除。 约束:下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称: 配置项英文名:name 说明:算子名称,对算子进行个性化的命名,以辅助增加可读性。支持中文、英文、数字、中划线、下划线,长度小于等于64个字符。
数据过滤 算子简介 名称:数据过滤 功能说明:根据设置的条件过滤数据,满足条件的数据则输出,不满足条件的数据将被丢弃。 约束:下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称: 配置项英文名:name 说明:算子名称,对算子进行个性化的命名,以辅助增加可读性。支持中
T四种类型。 DIS输出 作业处理后的数据结果输出到您的DIS云服务。 说明: 请先进行DIS云服务授权配置,相关操作请参考数据源--添加DIS数据源 高级算子 去噪 去噪算子,对数据流中的数据根据窗口周期进行去噪。 主要算子配置项包括: 分区字段:指定用于窗口中数据分区的字段列
4096 data_type 是 String 数据类型,字符串(string)、整数(integer)、浮点数(double)、对象(object),系统支持的对象型存储大小为1MB,超过时不予存储 表6 AnalysisModelRequest 参数 是否必选 参数类型 描述 name
4096 data_type 是 String 数据类型,字符串(string)、整数(integer)、浮点数(double)、对象(object),系统支持的对象型存储大小为1MB,超过时不予存储 表6 AnalysisModelRequest 参数 是否必选 参数类型 描述 name
置计算公式,将摄氏温度计算转换成华氏度读数再赋予给原来的温度属性,或者可以选择将计算转换后的数值赋予一个新属性。 约束:下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称: 配置项英文名:name 说明:算子名称,对算子进行个性化的命名,以辅助增加可读性。支持中