检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
转换类算子 产品过滤 数据计算 相邻消息计算 数据扁平 删除属性 选择属性 数据过滤 超时插补 数据聚合 父主题： 算子使用指南
创建SMT产线和设备资产模型 场景说明 为了构建物联网领域业务对象的数字孪生模型，IoT数据分析服务参考软件工程中面向对象的思想提供了“资产建模”能力，其中核心概念包括资产模型和资产，模型包括属性（类属性）和分析任务（类方法），对物理世界事物构建数字资产模型时，必须先定义好资产模
区，比如分区键选择了设备ID后，所有相同设备ID的消息进入一个分区。当选择多个字段时，按指定字段顺序组合成的字符作为算子并行处理的分区的Key。数据聚合策略会针对每个分区中的消息单独作用；举例：1）选择将设备ID作为分区键，那么本算子会将相同设备ID的消息进行分区，然后进行聚合。
约束：需要符合正则表达式： ^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ IoTDA上的资源空间ID： 配置项英文名：appId 说明：IoTDA上的资源空间ID。 类型：STRING 必选：是 约束：需要符合正则表达式：^.{1,64}$ 产品ID： 配置项英文名：productId
IoTA.01020303 分析任务不支持该类型函数 错误码描述 分析任务不支持该类型函数。 可能原因 转换计算类分析任务中使用了聚合计算类函数。 处理建议 请检查转换计算分析任务的公式中是否使用了聚合计算函数，若是请删除。 父主题： 资产建模相关错误码
此参数不设置，那么作业运行时本算子使用作业的并行数设置。 类型：INTEGER 必选：否 约束：最小值1， 最大值 1024。 父主题： 转换类算子
相邻消息计算 算子简介 名称：相邻消息计算 功能说明：基于前一消息和当前消息，按照表达式进行数值计算，计算的结果赋值给当前输入消息的属性。 举例：消息中有上报机器的产品总产量，但没有相对上一个上报周期的增量产量。通过相邻消息计算算子，可以用本消息中的产品总量减去上一个消息中的产品
此参数不设置，那么作业运行时本算子使用作业的并行数设置。 类型：INTEGER 必选：否 约束：最小值1， 最大值 1024。 父主题： 转换类算子
值给某个属性。举例：原消息中有温度属性，其数值是以摄氏度数值表示，可以通过本算子设置计算公式，将摄氏温度计算转换成华氏度读数再赋予给原来的温度属性，或者可以选择将计算转换后的数值赋予一个新属性。 约束：下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称： 配置项英文名：name
n认证。 AK/SK认证就是使用AK/SK对请求进行签名，在请求时将签名信息添加到消息头，从而通过身份认证。 AK(Access Key ID)：访问密钥ID。与私有访问密钥关联的唯一标识符；访问密钥ID和私有访问密钥一起使用，对请求进行加密签名。 SK(Secret Access
分析任务类型 分析任务有三种类型，“转换计算”和“聚合计算”这两种类型的计算公式在资产建模模块进行定义，而“流分析”类分析任务的计算过程通过编辑对应的实时分析作业来定义。 表1 分析任务的类型和功能 类型 功能说明 转换计算 转换计算表达式含义：对单个或多个参数的属性值进行常规数学计算，表达式中不能使用时间聚合。
此参数不设置，那么作业运行时本算子使用作业的并行数设置。 类型：INTEGER 必选：否 约束：最小值1， 最大值 1024。 父主题： 转换类算子
区，比如分区键选择了设备ID后，所有相同设备ID的消息进入一个分区。当选择多个字段时，按指定字段顺序组合成的字符作为算子并行处理的分区的Key。插补策略会针对每个分区中的消息单独作用；举例：1）选择将设备ID作为分区键，那么本算子会将相同设备ID的消息进行分区，然后进行单独插补。
ggg1BBIINPXsidG9rZ API同时支持使用AK/SK认证，AK/SK认证是使用SDK对请求进行签名，签名过程会自动往请求中添加Authorization（签名认证信息）和X-Sdk-Date（请求发送的时间）请求头。 AK/SK认证的详细说明请参见认证鉴权的“AK/SK认证”。 对于获取用户To
且上报的时间戳一样，则最终只会保留一条数据到系统。 如果有转换计算类型的分析任务引用了该属性作为入参，则该分析任务会被触发两次，并且会先后输出两次结果，最终保存一条还是多条，处理逻辑同上述描述。 父主题： 资产建模和分析常见问题
数据扁平 算子简介 名称：数据扁平 功能说明：数据扁平算子，把数据流中的嵌套Json字段转换为多个独立字段。 约束：下游不允许对接数据源及产品过滤算子。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明：算子名称，对算子进行个性化的命名，以辅助增加可读性。支持中文、
处于运行中状态，同时检查作业中也已经添加对应的产品的过滤和处理。 检查管理作业输出的所有属性字段的名称，数据类型，与资产模型中的属性定义是否一致，如果存在不一致会导致数据无法正确读取，计算和正常显示。 父主题： 资产建模和分析常见问题
过滤条件 示例： {"key":"xxx"} {"key1":"xxx","key2":"xxx"} {"key":{"eq|like":"xxx"}} {"key":{"in":["xxx","xxx"]}} {"or":{"key1":"xxx","key2":{"eq|like":"xxx"}
查询过滤器 示例： {"key":"xxx"} {"key1":"xxx","key2":"xxx"} {"key":{"eq|like":"xxx"}} {"key":{"in":["xxx","xxx"]}} {"or":{"key1":"xxx","key2":{"eq|like":"xxx"}
以算子之间的连线表示。 算子分成3类，输入算子、转换算子和输出算子。一个完整的作业必须包含输入算子、转换算子和输出算子，否则不能正常执行。 输入算子：负责实时作业数据的输入，是作业的属性类型。 转换算子：负责对数据进行各种处理。 输出算子：负责把作业处理的结果输出到作业外部。 编排作业
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
