开发数据订阅任务¶
数据订阅服务是 EnOS 为提高应用 API 调用效率而推出的一种主动推送服务，推送内容包括资产时序数据、资产告警数据、资产事件数据和返回结果数据。基于该推送服务，应用获取资产数据无需不停轮询 API，大大提高 API 调用效率和降低 API 使用费用。
数据订阅操作流程图¶
本文分别介绍在 EnOS Cloud 和 EnOS Edge 创建数据订阅任务的操作流程，大致流程图如下：
注解
EnOS Cloud 支持多个 OU 订阅，Cloud 每个 OU 下最多可创建 15 个订阅任务。EnOS Edge 仅支持单个 OU 订阅, Edge 每个 App 最多能创建 5 个订阅任务。
创建 EnOS Cloud 订阅任务¶
具体步骤¶
进入 EnOS 管理控制台的 数据订阅 模块，点击 添加订阅 按钮进入订阅配置页面。
选择 订阅类型，详见 EnOS Cloud 配置说明。
手动填写或自动生成 订阅 ID，订阅 ID 格式支持英文大小写、下划线、中横线。
选择 SA 账号 用以 Consumer 鉴权及数据鉴权。SA (Service Account) 账号相关信息见 SA 账号。每个订阅任务都必须关联一个 SA 账号，当订阅关联的 SA 账号被删除，则该订阅失效。
注解
在关联订阅任务前，必须授权 SA 账号以获取资产数据，详见 管理服务账号。
选择 订阅通道。
填写 订阅描述。
选择 订阅客户。根据 SA 账号的客户数据权限（通过应用购买关系建立），可选择需要订阅的客户数据。当客户解除了对 SA 账号的授权，与此 SA 相关的订阅任务会自动解除对该客户数据的订阅。
配置过滤数据。当订阅配置的模型或测点被删除，订阅配置页面依旧能看到订阅配置信息，但是会提示相关配置项为未知对象。
EnOS Cloud 配置项¶
| 数据类型 | 描述 | 订阅通道 | 数据过滤条件 |
|---|---|---|---|
| 时序数据订阅 | 订阅资产上送或者计算产生的带时间戳的测点数据，包括资产实时数据和历史数据 |
|
|
| 告警数据订阅 | 订阅针对实时数据设置一定的告警规则，根据这些告警规则产生的告警数据 |
|
|
| 设备管理系统事件订阅 | 订阅 EnOS 设备接入服务内部发生的事件，如设备生命周期中的注册、删除、拓扑关系的变更、OTA 升级等事件 | 无 | 事件类型过滤：选择订阅的资产模型、设备资产、逻辑资产、OTA 固件文件、OTA 任务事件类型，以及每种类型中的具体事件 |
| 设备事件上报订阅 | 订阅 EnOS 设备接入服务中设备模型上报的事件信息（包括 Info、Warn、和 Error） | 无 |
|
创建 EnOS Edge 订阅任务¶
具体步骤¶
进入 EnOS 管理控制台的 Edge 管理 模块，点击进入Edge 详情 > 数据订阅，点击 添加订阅 按钮进入订阅配置页面。
选择 订阅类型，详见 EnOS Edge 配置说明。
手动填写或自动生成 订阅 ID，订阅 ID 格式支持英文大小写、下划线、中横线，命名规则还包括：
- 时序数据订阅 ID：以 DATASVC.SUB. 开头
- 返回结果订阅ID（设备异步控制）：以 DATASVC.CONTROL. 开头
- 返回结果订阅ID（设备异步设点）：以 DATASVC.SET. 开头
选择 SA 账号 用以 Consumer 鉴权及数据鉴权。SA (Service Account) 账号相关信息见 SA 账号。每个订阅任务都必须关联一个 SA 账号，当订阅关联的 SA 账号被删除，则该订阅失效。EnOS Edge 的服务账号 (SA) 显示为已在 EnOS Edge 上线的应用对应账号。
注解
本步骤前必须授权 SA 账号以获取资产数据，详见 管理服务账号。
选择 订阅通道。
填写 订阅描述。
配置过滤数据。当订阅配置的模型或测点被删除，订阅配置页面依旧能看到订阅配置信息，但是会提示相关配置项为未知对象。
EnOS Edge 配置项¶
| 数据类型 | 描述 | 订阅通道 | 数据过滤条件 |
|---|---|---|---|
| 时序数据订阅 | 订阅资产上送或者计算产生的带时间戳的测点数据，包括资产实时数据和历史数据 | 实时通道 |
|
| 告警数据订阅 | 订阅针对实时数据设置一定的告警规则，根据这些告警规则产生的告警数据 | 基础（2.0 版告警） |
|
| 返回结果订阅 | 订阅控制结果显示了控制或设点命令的执行结果 | 设备异步控制、设备异步设点 | 无 |
| Edge 设备事件订阅 | 订阅 EnOS Edge 设备内部发生的事件 | 无 | 事件类型过滤：只支持 Edge 发布事件 |
启动订阅任务¶
数据订阅任务配置完成后，点击 启动 按钮开启数据订阅任务。数据订阅服务会按照订阅任务配置，对数据进行分发，并写入相应的数据中间件中。