检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
算子使用指南 输入类算子 输出类算子 转换类算子 表达式说明 父主题： 数据管道
输出类算子 数据存储输出 DIS输出 实时分析输出 父主题： 算子使用指南
输入类算子 IoT设备接入数据源 DIS数据源 API数据源 父主题： 算子使用指南
转换类算子 产品过滤 数据计算 相邻消息计算 数据扁平 删除属性 选择属性 数据过滤 超时插补 数据聚合 父主题： 算子使用指南
父主题： 算子使用指南
数据扁平 算子简介 名称：数据扁平 功能说明：数据扁平算子，把数据流中的嵌套Json字段转换为多个独立字段。 约束：下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文
选择属性 算子简介 名称：选择属性 功能说明：在输入数据中选择保留的属性，未选择的属性被删除。 约束：下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字、中划线
数据聚合 算子简介 名称： 数据聚合 功能说明： 数据聚合算子，将数据按窗口周期进行汇聚计算，以达到规约数据的目的。 约束：下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明： 算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文
数据计算 算子简介 名称：数据计算 功能说明：按照表达式进行数值计算，计算的结果赋值给某个属性。举例：原消息中有温度属性，其数值是以摄氏度数值表示，可以通过本算子设置计算公式，将摄氏温度计算转换成华氏度读数再赋予给原来的温度属性，或者可以选择将计算转换后的数值赋予一个新属性。 约束
数据过滤 算子简介 名称：数据过滤 功能说明：根据设置的条件过滤数据，满足条件的数据则输出，不满足条件的数据将被丢弃。 约束：下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文
DIS输出 算子简介 名称： DIS输出，IoT数据分析服务仅在华为云部署形态支持DIS数据源 功能说明： 数据输出到DIS云服务。 约束：下游不允许接任何算子。
数据存储输出 算子简介 名称： 数据存储输出 功能说明： 数据输出到指定的数据存储。 约束：下游不允许接任何算子。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明： 算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字、中划线、下划线，长度小于等于
API数据源 算子简介 名称： API接入数据源 功能说明： 通过API进行数据上报到pipeline的数据源。 约束：下游不允许对接数据源。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明： 算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字
DIS数据源 算子简介 名称： DIS数据源，IoT数据分析服务仅在华为云部署形态支持DIS数据源。 功能说明： 使用DIS云服务作为pipeline的数据源，从DIS中获取数据。 约束： 下游不允许对接数据源，目前有：IoT设备接入数据源、DIS数据源，及产品过滤算子。
删除属性 算子简介 名称：删除属性 功能说明：从数据中删除指定的属性。 约束：下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字、中划线、下划线，长度小于等于
产品过滤 算子简介 名称：产品过滤 功能说明：根据IoT设备接入服务（IoTDA）定义产品过滤出指定产品ID的设备数据。此算子仅在数据源为IoTDA时使用。 约束： 只允许跟在IoT设备接入数据源算子之后。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明：算子名称，
相邻消息计算 算子简介 名称：相邻消息计算 功能说明：基于前一消息和当前消息，按照表达式进行数值计算，计算的结果赋值给当前输入消息的属性。 举例：消息中有上报机器的产品总产量，但没有相对上一个上报周期的增量产量。通过相邻消息计算算子，可以用本消息中的产品总量减去上一个消息中的产品总产量
超时插补 算子简介 名称： 超时插补 功能说明： 提供基于时间的数据插补功能。时间支持延迟等待时长，以及指定固定时间点。插补数据为上一条实际数据，但是事件时间为插补计算出的时间。 约束： 下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称： 配置项英文名：name
实时分析输出 算子简介 将经过数据管道清洗后的数据输出到实时分析，作为实时分析的数据来源。 算子配置 算子配置项如图所示： 算子名称：用户指定这个算子的名称。 管道输出数据名称：用户声明这个输出的名称，以便在实时分析作业的“管道数据输入”算子中使用。 属性：用户选择需要将哪些属性输出给实时分析进行后续的分析任务
IoT设备接入数据源 算子简介 名称： IoT设备接入数据源 功能说明： 使用IoTDA云服务作为pipeline的数据源，接入IoTDA的数据。 约束：下游仅允许接产品过滤算子。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明： 算子名称，对算子进行个性化的命名，
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
