- 最新动态
- 产品介绍
- 用户指南
- 最佳实践
-
API参考
- 使用前必读
- 如何调用API
- API列表
-
错误码参考
-
错误码
-
公共错误码
- IoTA.99000001 Demo用户无操作权限
- IoTA.99000002 子用户无操作权限
- IoTA.99000003 未授权
- IoTA.99000004 帐号受限
- IoTA.99000005 帐号冻结
- IoTA.99000006 SDR用户无操作权限
- IoTA.99000007 未开通数据分析服务
- IoTA.99000008 数据分析服务被冻结
- IoTA.99000009 无该项目访问权限
- IoTA.99000010 请求参数不正确
- IoTA.99000011 系统繁忙
- IoTA.99000012 许可证已过期
- IoTA.99000013 超过许可资源使用量
- IoTA.99999998 网关服务内部错误
- IoTA.99999999 服务内部错误
-
业务面错误码
- 数据源相关错误码
-
数据管道相关错误码
- IoTA.03011001 作业定义错误
- IoTA.03011002 作业名称错误
- IoTA.03011003 作业描述错误
- IoTA.03011006 作业名已存在
- IoTA.03011007 作业数量超出限制
- IoTA.03011011 作业配置无法正常解析,请检查是否为JSON格式
- IoTA.03011012 作业不存在
- IoTA.03011013 数据源不存在
- IoTA.03011014 获取数据源失败
- IoTA.03011015 作业状态不允许当前操作
- IoTA.03011016 RTU个数不正确
- IoTA.03011018 作业未运行
- IoTA.03011019 作业启动失败
- IoTA.03011020 作业停止失败
- IoTA.03011022 作业无可用保存点
- IoTA.03011023 不允许触发savepoint
-
存储管理相关错误码
- IoTA.02010102 存储组名称重复
- IoTA.02010103 默认存储组名称禁止修改
- IoTA.02010104 老化时间非法
- IoTA.02010105 存储组类型错误
- IoTA.02010106 存储组数量超过单个项目的限制
- IoTA.02010107 存储组中包含存储,无法删除
- IoTA.02010108 指定的存储组不存在
- IoTA.02010201 此存储或存储组正在操作中,请稍后重试
- IoTA.02010202 存储名称重复
- IoTA.02010203 存储实例被数据管道使用中,无法删除
- IoTA.02010204 指定的存储不存在
- IoTA.02010205 存储数量已超过限制
- IoTA.02010206 不允许修改属性的数据类型
- IoTA.02010207 属性的类型应为 string、double、integer、object 其中之一
- IoTA.02010208 此标签或属性名称包含非法字符
- IoTA.02010209 此标签或属性名称已存在
- IoTA.02010210 标签数量超过限制
- IoTA.02010211 属性数量超过限制
-
资产建模相关错误码
- IoTA.01010012 不允许同时操作同一资产树下的资产
- IoTA.01010021 资产模型名称已存在
- IoTA.01010022 不能删除已有资产的资产模型
- IoTA.01010023 资产模型不存在
- IoTA.01010024 属性个数超过限制
- IoTA.01010025 分析任务个数超过限制
- IoTA.01010026 资产模型个数超过配额限制
- IoTA.01010027 资产模型存在循环依赖
- IoTA.01010028 资产个数超过配额限制
- IoTA.01010029 根资产个数超过配额限制
- IoTA.01010030 资产正在发布中
- IoTA.01010032 存在异常资产
- IoTA.01010033 模型已被其他模型引用
- IoTA.01010034 不能修改数据类型
- IoTA.01010035 子资产个数超过配额限制
- IoTA.01010036 属性引用深度超过配额限制
- IoTA.01010037 属性被引用数超过配额限制
- IoTA.01010038 实时分析作业类型不匹配或者作业不存在
- IoTA.01010039 实时分析作业状态不可用
- IoTA.01010040 属性已被引用
- IoTA.01010041 公式错误
- IoTA.01010042 属性名重复
- IoTA.01010043 输入参数名重复
- IoTA.01010045 分析任务名重复
- IoTA.01010046 聚合计算不能直接或间接引用聚合计算
- IoTA.01010047 文件大小超过30MB
- IoTA.01010048 资产总属性数超过配额限制
- IoTA.01010049 资产总分析任务数超过配额限制
- IoTA.01010050 资产正在导入中
- IoTA.01010051 导入资产任务不存在
- IoTA.01010052 文件不存在
- IoTA.01010053 当前状态下不能停止任务
- IoTA.01010054 资产正在导出中
- IoTA.01010055 导出资产任务不存在
- IoTA.01010056 引用的资产属性数超过限制
- IoTA.01010201 父资产不存在
- IoTA.01010202 资产不存在
- IoTA.01010203 资产名称已存在
- IoTA.01010204 资产树深度超过配额限制
- IoTA.01010307 查询的指标数超过限制
- IoTA.01010308 查询的属性数超过限制
- IoTA.01010309 属性不存在
- IoTA.01020301 公式语法错误
- IoTA.01020302 公式引用的函数不支持
- IoTA.01020303 分析任务不支持该类型函数
- IoTA.01020304 分析任务输出的属性在模型中不存在
- IoTA.01020305 “子资产”类型参数实际上引用不到子资产
- IoTA.01020306 分析任务中未配置具体引用的资产ID
- IoTA.01020307 “测量数据”类型属性未配置设备ID
- IoTA.01020308 “静态配置”类型属性未配置属性值
- IoTA.01020309 聚合计算不能直接或间接引用聚合计算
- IoTA.01020101 当前根资产正在操作中
-
实时分析相关错误码
- IoTA.03011001 作业定义错误
- IoTA.03011002 作业名称错误
- IoTA.03011003 作业描述错误
- IoTA.03011004 作业类型错误
- IoTA.03011006 作业名已存在
- IoTA.03011007 作业数量超出限制
- IoTA.03011009 该实时作业正在被资产模型使用,无法进行当前操作
- IoTA.03011010 从资产模型获取作业使用信息失败
- IoTA.03011011 作业配置无法正常解析,请检查是否为JSON格式
- IoTA.03011012 作业不存在
- IoTA.03011015 作业状态不允许当前操作
- IoTA.03011016 RTU个数不正确
- IoTA.03011018 作业未运行
- IoTA.03011019 作业启动失败
- IoTA.03011020 作业停止失败
- IoTA.03011021 作业监控失败
- IoTA.03011022 作业无可用保存点
- IoTA.03011023 不允许触发savepoint
-
公共错误码
-
错误码
- 常见问题
- 文档下载
- 通用参考
链接复制成功!
编排作业
操作场景
按照业务诉求,以算子编排的方式来开发实时作业。
- 实时作业是由“算子”和“数据流”组成一个DAG(有向无环图)。
- “算子”表示的是对数据的处理,本服务预制了多个算子供您使用,一个实时作业最多支持100个算子(即作业流图上显示的100个处理节点)。
- “数据流”表示在算子之间的传递数据,数据有明确的字段和格式,在编排界面,数据流以算子之间的连线表示。
- 算子分成3类,输入算子、转换算子和输出算子。一个完整的作业必须包含输入算子、转换算子和输出算子,否则不能正常执行。
- 输入算子:负责实时作业数据的输入,是作业的属性类型。
- 转换算子:负责对数据进行各种处理。
- 输出算子:负责把作业处理的结果输出到作业外部。
编排作业

序号 |
区域 |
描述 |
---|---|---|
1 |
算子货架窗口 |
算子列表,提供多种输入算子、转换算子、输出算子,以及高级算子。 |
2 |
画布窗口 |
在画布上通过算子和线来编排实时作业。 |
3 |
算子参数配置窗口 |
点击画布上某个算子后,显示此算子的参数。 |
算子类型 |
算子名称 |
描述 |
---|---|---|
输入算子 |
管道数据输入 |
使用数据管道清洗过的数据作为实时分析的数据源。 算子配置项如图所示: |
资产数据输入 |
接收来自于资产模型的数据,以便进一步使用实时分析算子对资产数据进行分析,并将分析后的结果返回给资产模型,丰富资产模型内容。 注意:使用该算子后,数据输出算子只可选择“资产数据输出”。 算子配置项如图所示:
注意:每个“资产数据输入”算子只可指定一个参数,若原作业中使用了多个参数,则需要使用多个“资产数据输入”算子。 |
|
转换算子 |
数据过滤 |
实现了根据条件进行数据过滤。支持多个条件过滤数据,条件间是“与”或“或”的关系。当需要按单条数据本身的字段取值来决定是否过滤数据时使用本算子。 |
数据扁平 |
把数据流中的嵌套Json字段转换为多个独立字段。如果测点类型是Object,那么是一个嵌套结构,需要把结构中的每个字段提取出来,成为数据流中的独立字段,这样数据流的所有字段都是字符串、数字等简单数据类型。 |
|
数据嵌套 |
把数据流中的字段打包成嵌套的Json格式字段,在实时作业输出数据时,如果需要输出嵌套的Json格式,那么使用此算子。 |
|
数据聚合 |
对多条数据进行聚合计算。支持算法为,求和(SUM),求平均(AVERAGE),求最大值(MAX),求最小值(MIN),求最旧值(FIRST),求最新值(LAST),求个数(COUNT),组装数组(ARRAY)。
须知:
求和(SUM),求平均(AVERAGE),求最大值(MAX),求最小值(MIN)算法支持STRING、INTEGER、LONG、FLOAT、DOUBLE数据类型,不支持其他数据类型。求最旧值(FIRST),求最新值(LAST),求个数(COUNT)支持所有数据类型。配置如果类型不匹配,输出此字段为null。 聚合使用数据窗口,支持窗口类型为: 滚动窗口:窗口数据无重叠,需要指定窗口大小。比如每5分钟统计数据条数,那么每5分钟一个窗口,不会有重复统计。 滑动窗口:窗口有数据重叠,需要指定窗口大小,以及窗口移动大小。比如每1分钟统计最近5分钟数据条数,那么1分钟一个窗口,窗口大小为5分钟,重叠了4分钟数据。 会话窗口:窗口无固定大小,以多长时间没有没有数据作为窗口间隔。 |
|
数据计算 |
需要生成新的字段或者改变字段的取值时使用。通过表达式配置(表达式配置与”数据管道”相同,详见 表达式说明)新字段的取值计算方式
须知:
对于新增加字段,在本算子的输出字段配置项中需要手工添加此字段,并且字段类型要和实际表达式计算结果的类型一致,如果不一致,算子会按照输出算子配置强制转换,如果转换失败,输出此字段为null。 |
|
数据状态计算 |
支持以最新数据取值来进行条件计算。数据可能来自不同时间点,比如温度测点上报了温度,烟感测点上报了烟状态,因为这2个测点是不同数据中字段,并且不是同一时间点,使用其他算子不能进行组合判断,而本算子可以把数据缓存起来,在任意数据有变更时触发条件检测。
须知:
|
|
数据去重 |
为了过滤掉重复数据,使用本算子。支持指定字段是否相同来判断是否是重复数据,比如指定温度字段没有变化则是重复数据,而事件时间字段每条数据取值不同。 支持指定去重超时时长,在超时后,收到的第一条数据不按去重处理,然后重新开始去重计时以及去重检查。用于避免长时间数据字段值没有变化导致数据都被丢弃而不能产生数据。 |
|
数据选择 |
对数据的字段进行过滤,选择的字段名字才输出,过滤掉不在字段列表中的字段。 |
|
输出算子 |
资产数据输出 |
将实时分析的计算结果输出到资产模型,用于在资产模型中使用实时分析作业进行分析任务计算的结果。 注意:使用该算子后,数据输入算子只可选择“资产数据输入”。 算子配置项如图所示: |
DIS输出 |
作业处理后的数据结果输出到您的DIS云服务。 |
|
高级算子 |
去噪 |
去噪算子,对数据流中的数据根据窗口周期进行去噪。 主要算子配置项包括:
|
算子如果配置正确,提示为:
算子如果配置错误,提示为: