数据订阅概述¶
数据订阅服务是 EnOS Cloud 为提高用户获取和利用资产数据效率而推出的一种数据主动推送服务。支持多数据源订阅、订阅任务管理以及调用数据订阅 SDK。基于该推送服务，应用获取资产数据无需不停轮询 API，大大提高 API 调用效率和降低 API 使用费用。推送内容包括：
资产时序数据
告警引擎数据
资产事件数据
返回结果数据
数据订阅服务的主要功能组成和架构，如下图所示：
原始数据流入数据订阅服务，用户可根据自身的业务需求自由配置数据订阅参数，主动推送的数据流入数据中间件, 下游可以通过 SDK 在应用上消费数据，实现数据生产与消费的解耦。
适用场景¶
IT/OT应用开发者可订阅资产实时和离线数据和告警数据。
产品优势¶
数据生产与消费解耦：多样化数据过滤规则，可订阅指定客户、指定设备的测点数据、告警数据、和事件数据。被订阅的数据会保存在数据中间件中，在数据消费客户端点击启动按钮后开始消费数据。
客户端流控：应用客户端消会在启动后主动从消息中间件d Topic 中拉取订阅的数据，可有效实现流量控制。
跨组织数据订阅：基于 Kafka 的 at-least-once 机制，确保数据至少被消费一次，不会造成数据丢失。通过应用授权（购买应用），支持订阅多个组织的资产数据。
集群消费数据：支持集群消费数据，即同一个 Topic 可以被同一个 Consumer Group 内的多个 Consumer Client 均摊消费（目前支持2个 Consumer Client），也可以被多个 Consumer Group 重复消费。
断点续传：支持断点续传，即 Consumer Client 停止消费数据后的 24 小时内，可使用相同的 Consumer Group 在断点处继续消费订阅的数据。订阅的数据在数据中间件中的存储时长默认为 3 天，所以订阅任务停止 3 天内，可以在上一次的消费位置继续消费订阅数据。
运行监控：支持查看和监控订阅任务的运行情况，对比产生订阅数据的速率和消费订阅数据的速率，查看是否有消费数据延迟，确保订阅数据被及时消费。
主要功能¶
多数据订阅¶
EnOS Cloud 提供多数据源订阅服务，可满足多客户使用多个订阅通道，支持如下数据订阅类型：
时序数据订阅
告警数据订阅
设备管理系统事件订阅
设备事件上报订阅
具体订阅步骤，参见 开发数据订阅任务。
订阅任务管理¶
你可以创建数据订阅任务、配置订阅内容、启停订阅任务以及查看订阅详情。
EnOS Cloud 支持查看订阅任务运行情况，参见 查看订阅任务的运行情况。创建和配置数据订阅任务的步骤，参见 开发数据订阅任务。
数据订阅SDK¶
开发者可使用配套的数据订阅 SDK 快速开发应用，消费订阅数据。EnOS Cloud 目前支持Java SDK。消费订阅数据的步骤，参见 消费订阅数据。
使用限制¶
使用数据订阅服务时，需要注意以下使用限制：
单 OU 内最多可创建 100 个数据订阅任务数。
单 OU 内单个订阅任务最多支持 100000 个模型点。
备注
以上限制为 OU 默认值，如需更改请联系系统管理员。