概述


数据订阅功能是 EnOS 为提高用户获取和利用资产数据效率而推出的一种数据主动推送服务。推送的内容包括时序数据(资产实时数据和历史数据)、告警数据、和设备管理系统事件数据。基于该推送服务,应用获取资产数据不再需要轮询 API,订阅的数据会被主动推送到应用,大大提高应用消费数据的效率、降低 API 使用费用。


数据订阅服务的主要功能组成和架构,如下图所示:


_images/subscription_arch.png


原始数据流入数据订阅服务,用户可根据自身的业务需求自由配置数据订阅参数,主动推送的数据流入 Kafka Topic, 下游可以通过 SDK 在应用上消费数据,实现数据生产与消费的解耦。

数据订阅使用流程


_images/data_subscription_process.png