IoT数据分析 IoTA-华为云

IoT数据分析 IoTA-新建作业:新建作业

新建作业图1 进入实时分析图2 查看作业图3 新建作业参数说明参数名称描述示例接收数据类型接收数据类型有“管道数据”、“资产数据”。管道数据：直接使用数据管道清洗后的数据进行实时分析，当您无需资产建模，直接使用设备数据进行实时分析时，可使用这种接收数据类型。资产数据：使用资产模型的数据进行实时分析，当您需要在资产模型中使用“分析任务”时，可使用这种接收数据类型。作业名称对作业进行命名火警实时检测描述描述作业的业务实时检测房间火灾告警图4 新建作业

IoT数据分析 IoTA 作业开发

IoT数据分析 IoTA-数据过滤

数据过滤算子简介名称：数据过滤功能说明：根据设置的条件过滤数据，满足条件的数据则输出，不满足条件的数据将被丢弃。约束：下游不允许对接数据源及产品过滤算子。算子配置基础配置项算子名称：配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字、中划线、下划线，长度小于等于64个字符。类型：STRING 必选：否约束：需要符合正则表达式： ^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 条件关系：配置项英文名：conditionRelationship 说明：条件关系，用于指定conditions下的各个条件之间的关系，可以是与、或。类型：STRING 必选：否，默认为 AND 约束：仅可填写 AND 或 OR 过滤条件：配置项英文名：conditions 说明：过滤条件，可以配置多个，多个过滤条件之间的关系由 conditionRelationship指定。必选：是子配置项：conditions包括如下子配置项：属性、计算符号、数值。属性：配置项英文名：property 说明：属性，以JSON Path格式来指定属性。类型：STRING 必选：是约束：需要符合正则表达式： ^.{1,1000}$ 计算符号：配置项英文名：symbol 说明：计算符号，如大于、小于、等于等，目前支持：MORE_THAN、MORE_THAN_EQUAL、LESS_THAN、LESS_THAN_EQUAL、EQUAL、NOT_EQUAL 类型：STRING 必选：是约束：必须是MORE_THAN、MORE_THAN_EQUAL、LESS_THAN、LESS_THAN_EQUAL、EQUAL、NOT_EQUAL中的一个。数值：配置项英文名：value 说明：数值，即条件的右值，如条件：大于100中的100即为value的值。类型：STRING 必选：是约束：需要符合正则表达式： ^.{0,50}$ 高级配置项并行数：配置项英文名：parallelism 说明：并行数，指定算子执行时的并行任务个数。对于性能要求越高的算子，可以设置较高的并行数，但是占用资源越多。如果此参数不设置，那么作业运行时本算子使用作业的并行数设置。类型：INTEGER 必选：否约束：最小值1，最大值 1024。父主题：转换类算子

IoT数据分析 IoTA

IoT数据分析 IoTA-服务控制台总览:流程介绍

流程介绍图1 流程介绍配置数据源数据分析服务会将数据源的数据存储并进行后续分析。点击图标即可进入数据源配置界面。创建数据管道数据管道是数据分析的基础功能，对进入数据分析的数据进行格式标准化、清洗等数据预处理。点击图标即可进入数据管道配置界面。配置存储数据的存储是数据分析的基础，点击图标即可进入存储配置界面。资产建模根据您的业务场景创建相应的数字资产模型，并基于该模型进行后续的数据分析，点击图标即可进入资产建模界面。数据分析可以结合业务数据进行针对性的业务洞察，发现业务价值。点击图标即可进入分析界面。结果导出您可以根据需要导出所需的原始以及分析后的数据。

IoT数据分析 IoTA

IoT数据分析 IoTA-存储

存储存储是保存数据的对象，通常来说，同一种设备的数据会保存在同一个存储中。存储中定义了设备的标签与设备的属性。其中设备ID（deviceId）就是最常用的一种标签（tag）。一个标签包括标签名与标签值，例如设备ID：标签名为 deviceId，而它的标签值则是具体的某个设备ID，设备的ID是通过设备数据上报到IoT数据分析服务而保存下来的。在查询中指定标签名与某个标签值（例如具体的某个设备ID），可以快速地找到对应的设备数据。创建存储删除存储父主题：存储管理

IoT数据分析 IoTA

IoT数据分析 IoTA-删除属性

删除属性算子简介名称：删除属性功能说明：从数据中删除指定的属性。约束：下游不允许对接数据源及产品过滤算子。算子配置基础配置项算子名称：配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字、中划线、下划线，长度小于等于64个字符。类型：STRING 必选：否约束：需要符合正则表达式： ^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 属性：配置项英文名：properties 说明：属性，以JSON Path格式来指定删除的属性。可以允许设置多个属性，表示删除多个属性。类型：STRING 必选：是约束：需要符合正则表达式： ^.{1,1000}$。高级配置项并行数：配置项英文名：parallelism 说明：并行数，指定算子执行时的并行任务个数。对于性能要求越高的算子，可以设置较高的并行数，但是占用资源越多。如果此参数不设置，那么作业运行时本算子使用作业的并行数设置。类型：INTEGER 必选：否约束：最小值1，最大值 1024。父主题：转换类算子

IoT数据分析 IoTA

IoT数据分析 IoTA-选择属性

选择属性算子简介名称：选择属性功能说明：在输入数据中选择保留的属性，未选择的属性被删除。约束：下游不允许对接数据源及产品过滤算子。算子配置基础配置项算子名称：配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字、中划线、下划线，长度小于等于64个字符。类型：STRING 必选：否约束：需要符合正则表达式： ^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 属性：配置项英文名：properties 说明：属性，以JSON Path格式来指定保留的属性。类型：STRING 必选：是约束：需要符合正则表达式： ^.{1,1000}$。高级配置项并行数：配置项英文名：parallelism 说明：并行数，指定算子执行时的并行任务个数。对于性能要求越高的算子，可以设置较高的并行数，但是占用资源越多。如果此参数不设置，那么作业运行时本算子使用作业的并行数设置。类型：INTEGER 必选：否约束：最小值1，最大值 1024。父主题：转换类算子

IoT数据分析 IoTA

IoT数据分析 IoTA-支持云审计的关键操作:支持审计的关键操作列表

支持审计的关键操作列表表1 数据源支持审计的关键操作列表操作名称资源类型事件名称创建数据源 datasource createDataSource 修改数据源 datasource updateDatasource 删除数据源 datasource deleteDataSource 验证数据源 datasource validateDataSource 表2 资产模型支持审计的关键操作列表操作名称资源类型事件名称创建资产 asset createAsset 修改资产 asset updateAsset 删除资产 asset deleteAsset 创建测点 measurePoint createMeasurePoint 修改测点 measurePoint updateMeasurePoint 删除测点 measurePoint deleteMeasurePoint 创建视图 view createView 修改视图 view updateView 删除视图 view deleteView 刷新默认视图 view refreshDefaultView 发布视图 view publishView 另存视图 view saveAsView 创建资产模板 assetTemplate createAssetTemplate 修改资产模板 assetTemplate updateAssetTemplate 删除资产模板 assetTemplate deleteAssetTemplate 创建资产分类 assetCategory createAssetCategory 修改资产分类 assetCategory updateAssetCategory 删除资产分类 assetCategory deleteAssetCategory 创建测点分类 measureCategory createMeasureCategory 修改测点分类 measureCategory updateMeasureCategory 删除测点分类 measureCategory deleteMeasureCategory 表3 时序分析支持审计的关键操作列表操作名称资源类型事件名称更新温数据存储配置 warmStorage updateWarmStorage 保存时序分析收藏夹 tsiFavorites saveTsiFavorites 删除时序分析收藏夹 tsiFavorites deleteTsiFavorites 表4 实时分析支持审计的关键操作列表操作名称资源类型事件名称创建作业 realTimeJob createJob 更新作业 realTimeJob updateJob 删除作业 realTimeJob deleteJob 启动作业 realTimeJob startJob 停止作业 realTimeJob stopJob 启动测试 realTimeJob startDebug 停止测试 realTimeJob stopDebug 上传测试文件 realTimeJob uploadInputs

IoT数据分析 IoTA

IoT数据分析 IoTA-数据计算

数据计算算子简介名称：数据计算功能说明：按照表达式进行数值计算，计算的结果赋值给某个属性。举例：原消息中有温度属性，其数值是以摄氏度数值表示，可以通过本算子设置计算公式，将摄氏温度计算转换成华氏度读数再赋予给原来的温度属性，或者可以选择将计算转换后的数值赋予一个新属性。约束：下游不允许对接数据源及产品过滤算子。算子配置基础配置项算子名称：配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字、中划线、下划线，长度小于等于64个字符。类型：STRING 必选：否约束：需要符合正则表达式： ^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 变量：配置项英文名：variables 说明：变量，把输入消息中的属性作为变量在表达式中使用。对变量进行定义，设置变量名称和变量的取值。必选：否子配置项：变量配置包括如下子配置项：变量名称、变量取值。变量名称：配置项英文名：variable 说明：变量名称，用户可自定义一个变量名称，计算时使用，以免配置计算表达式时使用jsonPath。类型：STRING 必选：是约束：需要符合正则表达式： ^[a-zA-Z]\w{0,20}$ 变量取值：配置项英文名：value 说明：变量取值，以JSON Path格式来指定变量从消息中指定的JSON Path属性获取的取值。类型：STRING 必选：是约束：需要符合正则表达式： ^.{0,1000}$ 计算配置：配置项英文名：calculates 说明：计算配置，配置属性的计算表达式。必选：是子配置项：计算配置包括如下子配置项：属性、表达式。属性：配置项英文名：property 说明：属性名，表示计算表达式所计算的结果赋予的对象。用户可以选择消息中已有的某个属性，或者自行输入新的内容，该内容需要满足Json path语法的要求。类型：STRING 必选：是约束：需要符合正则表达式： ^.{1,1000}$ 表达式：配置项英文名：expression 说明：计算表达式，支持的表达式详细说明请参考：表达式说明。类型：STRING 必选：是约束：需要符合正则表达式： ^.{0,1000}$ 高级配置项并行数：配置项英文名：parallelism 说明：并行数，指定算子执行时的并行任务个数。对于性能要求越高的算子，可以设置较高的并行数，但是占用资源越多。如果此参数不设置，那么作业运行时本算子使用作业的并行数设置。类型：INTEGER 必选：否约束：最小值1，最大值 1024。父主题：转换类算子

IoT数据分析 IoTA

IoT数据分析 IoTA-数据扁平

数据扁平算子简介名称：数据扁平功能说明：数据扁平算子，把数据流中的嵌套Json字段转换为多个独立字段。约束：下游不允许对接数据源及产品过滤算子。算子配置基础配置项算子名称：配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字、中划线、下划线，长度小于等于64个字符。类型：STRING 必选：否约束：需要符合正则表达式： ^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 扁平字段配置：配置项英文名：flatFiedConfig 说明：扁平字段配置，配置需要进行扁平处理的字段列表。必选：是子配置项：扁平字段配置包括如下子配置项：源数据路径、字段名称。源数据路径：配置项英文名：path 说明：源数据路径，以JSON Path格式来指定变量从消息中指定的JSON Path属性获取的取值。类型：STRING 必选：是约束：需要符合正则表达式： ^.{1,1000}$ 字段名称：配置项英文名：field 说明：字段名称，输出字段的字段名称。如果字段名与上游输入字段名相同，则此字段被重新赋值。类型：STRING 必选：是约束：需要符合正则表达式： ^[a-z_A-Z]\w{0,64}$ 高级配置项并行数：配置项英文名：parallelism 说明：并行数，指定算子执行时的并行任务个数。对于性能要求越高的算子，可以设置较高的并行数，但是占用资源越多。如果此参数不设置，那么作业运行时本算子使用作业的并行数设置。类型：INTEGER 必选：否约束：最小值1，最大值 1024。父主题：转换类算子

IoT数据分析 IoTA

IoT数据分析 IoTA-数据源--添加DIS数据源:操作步骤

操作步骤点击IoT数据分析服务控制台左侧导航栏的数据源，进入数据源页面，点击“实时数据源”。实时点击“添加数据源”，在弹出的页面中输入消息通知服务的连接参数，各参数说明详见表1。表1 添加实时数据源参数说明参数名说明取值样例数据源名称数据源的名称 DISNotify 项目ID 项目ID 根据实际值填写通道名称 DIS通道根据实际值填写访问密钥(AK) 访问密钥的KEY 根据实际值填写私有访问密钥(SK) 访问密钥的密码根据实际值填写点击“连接测试”按钮，测试数据源是否可访问。如果测试失败，请确认项目ID、访问密钥、私有访问密钥是否正确，修改后请重新测试。点击“确定”按钮，完成数据接入服务数据源的添加。

IoT数据分析 IoTA

IoT数据分析 IoTA-预览列表展示:预览列表控制属性分析操作

预览列表控制属性分析操作在预览列表区，支持对所选属性做勾选、分析、移除操作，以控制该属性在图表分析区的展示，其中分析操作包含如下内容：聚合类型：对所选属性的时序数据按采样间隔进行聚合计算，当前支持的聚类操作包括AVG、MIN、MAX、SUM、COUNT共计5种；时间偏移：对所选属性按时间做偏移，会在预览列表新增一条记录，常用于同一测点不同时间的对比分析；显示类型：支持阶梯图，最小/最大范围，显示数据点，仅对折线图有效。图3 预览列表分析操作

IoT数据分析 IoTA 时序洞察

IoT数据分析 IoTA-使用DIS数据源

使用DIS数据源点击导航栏上的“数据管理”标签，进入数据管道页面，在“管理列表”部分有一按钮“创建数据管道”，如图所示：点击“创建数据管道”按钮，弹出“创建数据管道”对话框，用户可自行填写“作业名称”（注意：同一用户所创建的作业名称不可重复）、“描述”，并选择数据源（若列表为空，请跳转到“创建数据源”链接创建数据源，详见数据源章节），如下图所示：目前可支持的数据源两种类型：IoTDA数据源、DIS数据源。使用DIS数据源时，需要用户自行配置数据源及数据处理流程，如图所示：且不再需要“产品过滤”算子：父主题：创建数据管道

IoT数据分析 IoTA

IoT数据分析 IoTA-数据源配置

数据源配置 IoTDA数据源在画布上选中“IoT设备接入数据源”算子，在右侧配置面板处，可修改算子名称、选择数据源、填写事件时间字段路径、时间格式，如图。使用IoTDA数据源时，系统会自动根据所选择的数据源生成这些配置，用户可检查这些配置是否正确，根据自己的需要进行修改。 DIS数据源配置在画布上选中“DIS数据源”算子，在右侧配置面板处，可修改算子名称、选择数据源、填写事件时间字段路径、时间格式、时区，如图。父主题：编辑处理流程

IoT数据分析 IoTA

IoT数据分析 IoTA-使用IoTDA数据源:操作步骤

操作步骤访问“IoT数据分析”服务产品页，点击“立即使用”进入"IoT数据分析"服务控制台。在左侧导航栏选择“数据管理”，进入数据管道页面，在“管理列表”点击“创建数据管道”。弹出“创建数据管道”对话框，您可自行填写“作业名称”（注意：同一用户所创建的作业名称不可重复）、“描述”，并选择数据源（若列表为空，请跳转到“创建数据源”链接创建数据源，详见数据源章节），如下图所示。使用IoTDA数据源时，系统会自动读取该数据源的相关信息及相关的产品信息，生成作业执行流程，如图所示。上图所示示例中，所选择的IoTDA数据源包含两种设备：烟感设备与水表，系统自动生成了两个处理分支，分别用于处理这两种设备上报的数据。这两个分支各自以一个“产品过滤”算子作为起始点，分别过滤出这两种设备的数据，以便于后续处理流程仅处理某一种产品的数据，如图所示。系统还自动根据这两种设备的产品信息（该产品信息以安全的方式从IoTDA获取），生成了默认的输出配置。请用户自行选择存储组，并填写存储名称，补齐配置内容即可保存，如图所示。

IoT数据分析 IoTA 创建数据管道

IoT数据分析 IoTA-超时插补

超时插补算子简介名称：超时插补功能说明：提供基于时间的数据插补功能。时间支持延迟等待时长，以及指定固定时间点。插补数据为上一条实际数据，但是事件时间为插补计算出的时间。约束：下游不允许对接数据源及产品过滤算子。算子配置基础配置项算子名称：配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、英文、数字、中划线、下划线，长度小于等于64个字符。类型： STRING 必选：否约束：需要符合正则表达式： ^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 分区键：配置项英文名：keys 说明：分区键，用于作为消息分区/分组的标识，具体填入的内容为消息中获取的JSON Path，比如可以选择消息中设备ID所在的JSON Path。设置后，拥有该分区键数值相同的所有消息会进入一个分区，比如分区键选择了设备ID后，所有相同设备ID的消息进入一个分区。当选择多个字段时，按指定字段顺序组合成的字符作为算子并行处理的分区的Key。插补策略会针对每个分区中的消息单独作用；举例：1）选择将设备ID作为分区键，那么本算子会将相同设备ID的消息进行分区，然后进行单独插补。比如设备ID为1的所有消息会进入一个分区，设备ID为2的所有消息会进入另一个分区，插补策略会审视每一个分区中的消息进行单独插补； 2）选择消息中的设备ID与设备状态为分区键，那么相同设备ID与设备状态的消息会进入一个分区，然后进行单独插补。比如设备ID为1、设备状态为正常的所有消息会进入一个分区，设备ID为1、设备状态为异常的所有消息进入另一个分区，插补策略会审视每一个分区中的消息进行单独插补。类型： STRING 必选：是约束：需要符合正则表达式： ^.{1,1000}$ 插补时间类型：配置项英文名：timeType 说明：插补时间类型，目前支持两种： RELATIVE：相对时间，表示按相对前一条数据偏移时长插补。 ABSOLUTELY：绝对时间，表示按照固定时间插补。类型： STRING 必选：是约束：仅可填写RELATIVE 或 ABSOLUTELY。相对时间插补周期：配置项英文名：relativePeriod 说明：相对时间插补周期，在插补时间类型为“相对时间”时有效，单位为S。类型： INTEGER 必选：否约束：最小值0，最大值为2147483647。绝对时间插补周期：配置项英文名：absolutelyPeriod 说明：绝对时间插补周期，参考java或crontab定时器时间表达式，在插补时间类型为“绝对时间”时有效。类型： INTEGER 必选：否约束：需要符合正则表达式： ^.{1,100}$ 绝对周期的等待时长：配置项英文名：delay 说明：绝对周期的等待时长，单位秒。即在绝对时间等待一段后再插补消息，避免由于真实消息传送延迟，在插补时间类型为“绝对时间”时有效。类型： INTEGER 必选：否约束：最小值0，最大值为2147483647。存活时长：配置项英文名：ttlTime 说明：如果一个设备长期没有报消息，pipline要停止上一个上报消息的插补定时器。存活时长的单位为秒，最小清除时间为1s，最大清除时间为30天，如果不设置此参数表示永远不清除。当算子每次接收了消息，更新延长存活时长。类型： INTEGER 必选：否约束：最小值1，最大值为2592000。高级配置项并行数：配置项英文名：parallelism 说明：并行数，指定算子执行时的并行任务个数。对于性能要求越高的算子，可以设置较高的并行数，但是占用资源越多。如果此参数不设置，那么作业运行时本算子使用作业的并行数设置。类型： INTEGER 必选：否约束：最小值1，最大值 1024。父主题：转换类算子

IoT数据分析 IoTA

云服务器内容精选

IoT数据分析 IoTA

7*24

备案

专业服务

退订

建议反馈

售前咨询热线