检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
字段取值为null。 类型： STRING 必选： 是 约束： 必须为INTEGER、LONG、FLOAT、DOUBLE之一 。 被汇聚字段： 配置项英文名：aggregateField 说明： 被汇聚字段，指定需要进行汇聚计算的字段。 类型： STRING 必选： 是 约束：
IoTDA实时数据源选择同一个IoT设备接入服务实例。 IoTDA实时数据源的“立即授权”、以及添加数据源功能由于需要访问IAM服务，因此必须使用华为云租户主账号进行操作。 父主题： 数据源配置
资产模型（AssetModel） 资产模型是对物理世界中同类事物的抽象定义，资产模型中包括属性和分析任务。对物理世界事物构建数字资产模型时，必须先定义好资产模型、然后再创建资产。 属性（Property） 属性是指物理世界事物的状态数据，属性有3种类型，包括静态配置、测量数据和分析任务。
须知： 缓存的字段必须是本算子中条件中右值的字段。 仅缓存的字段的最新取值。 需要指定缓存的索引字段，算子根据索引来查找对应缓存，索引字段支持多个数据字段组合。 数据去重 为了过滤掉重复数据，使用本算子。支持指定字段是否相同来判断是否是重复数据，比如指定温度字段没有变化则是重
数据存储，如果需要把管道输出数据保存，则需要指定存储。如果没有指定存储，管道输出数据则不保存。 必选： 是 子配置项： 数据存储配置包含如下子配置项： 存储组ID、存储组名称、数据存储ID、数据存储名称、数据存储属性。 存储组ID： 配置项英文名：dataStorageGroupId 说明： 指定输出到数据存储
配置项英文名：datasSourceId 说明： 指定管道的输入IoT数据接入云服务数据源。 类型： STRING 必选： 是 约束： 需要符合正则表达式： ^[a-zA-Z0-9][\w_-]{1,64}$ 事件时间： 配置项英文名：eventTime 说明： 事件时间，以JSON Path格式来指定事件时间的获取
利用资产模型对资产进行实例化时，该参数实际上是引用该资产实例的下一层子资产中，符合指定资产模型的那一些子资产的属性，此时入参对应的属性是个数组，如下图示例。 参数限制 同一个“分析任务”中不能有名称相同的参数。 当参数类型为”引用子资产属性“时，要求对应的资产实例下面，必须有至少一个匹配的子资产。 聚合计算的输入参数
点击IoT数据分析服务控制台左侧导航栏的数据源，进入数据源页面，点击“实时数据源”。 实时点击“添加数据源”，在弹出的页面中输入消息通知服务的连接参数，各参数说明详见表1。 表1 添加实时数据源参数说明 参数名 说明 取值样例 数据源名称 数据源的名称 DISNotify 项目ID 项目ID
^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 数据源ID： 配置项英文名：datasSourceId 说明： DIS数据源ID，此数据源必须在本服务被授权访问。 数据源ID可以通过数据源接口： /v1/${project_id}/datasources?type=DIS获取。 类型：
^[\u4E00-\u9FA5A-Za-z0-9_-]{1,64}$ 事件时间： 配置项英文名：eventTime 说明： 事件时间，以JSON Path格式来指定事件时间的获取来源。如果没有指定，则使用接受消息时的系统时间作为消息产生的事件时间。 必选： 是 子配置项：事件时间包括如下子配置项：JSON路径、时间样式、时区。
获取管道作业详情 功能介绍 获取指定管道作业的详情 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/pipelines/{pipeline_id}
获取实时作业详情 功能介绍 获取指定作业的详情 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/streaming/jobs/{job_id}
删除管道作业 功能介绍 删除用户指定的管道作业 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI DELETE /v1/{project_id}/pipelines/{pipeline_id}
删除实时作业 功能介绍 删除用户指定的作业 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI DELETE /v1/{project_id}/streaming/jobs/{job_id}
实时分析输出 算子简介 将经过数据管道清洗后的数据输出到实时分析，作为实时分析的数据来源。 算子配置 算子配置项如图所示： 算子名称：用户指定这个算子的名称。 管道输出数据名称：用户声明这个输出的名称，以便在实时分析作业的“管道数据输入”算子中使用。 属性：用户选择需要将哪些属性输出给实时分析进行后续的分析任务。
type 数据类型，必须模板默认值，用户不能修改 是 message 消息体，必须模板默认值，用户不能修改 是 projectId 租户id，必须模板默认值，用户不能修改 是 jobId 当前实时分析任务id，必须模板默认值，用户不能修改 是 context 资产信息，必须模板默认值，用户不能修改
] } } } header 测试数据头字段，必须是json格式。 是 projectId 租户id，必须模板默认值，用户不能修改。 是 dataSourceId 数据源id，必须模板默认值，用户不能修改。 是 body 数据体字段，必须是json格式，格式不能修改。 是 body
说明：属性，以JSON Path格式来指定删除的属性。可以允许设置多个属性，表示删除多个属性。 类型：STRING 必选：是 约束：需要符合正则表达式： ^.{1,1000}$。 高级配置项 并行数： 配置项英文名：parallelism 说明：并行数，指定算子执行时的并行任务个数。对于
产品过滤 算子简介 名称：产品过滤 功能说明：根据IoT设备接入服务（IoTDA）定义产品过滤出指定产品ID的设备数据。此算子仅在数据源为IoTDA时使用。 约束： 只允许跟在IoT设备接入数据源算子之后。 算子配置 基础配置项 算子名称： 配置项英文名：name 说明：算子名称
更新管道作业 功能介绍 更新管道作业时，需要在URL中指定是更新哪一个作业，将在body中附带完整的作业信息。（管道作业详细配置，每个作业可选择不同的算子进行组合，各算子的使用方法详见：数据管道算子使用指南。） check参数表示是否需要对作业配置进行检查，若为false，则不检
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
