数据流¶
接入IoT Hub¶
如下图所示, 设备可以直连或通过网关连接至EnOS™ IoT Hub。EnOS支持基于以下协议的设备接入：
MQTT
CoAP
HTTP
备注
设备连接网关设备后，网关设备与IoT Hub之间的通信是基于MQTT协议的。
IoT Hub支持基于MQTT协议从第三方系统集成历史消息，基于HTTP协议从第三方系统集成实时消息。
如果用户没有真实设备，也可以使用 EnOS管理门户 的 设备管理 > 设备模拟器 创建模拟器，产生模拟数据来接入平台，以验证概念。
数据归一化¶
如上图，设备数据接入EnOS之后，各协议的broker及消息集成服务会分别接收设备基于各协议上送的数据，将数据归一化为物模型中定义的标准数据（测点、属性、服务、事件）并发送至IoT Hub服务器。
数据的应用¶
IoT Hub服务器根据需要，将归一化数据发送至告警引擎；用户也可以在EnOS上订阅这些数据流，数据经过规则引擎会被分发到相应的Kafka topic，供EnOS数据资产管理的相关功能调用。
数据通过IoT Hub上送至EnOS Cloud中会由规则引擎分发至不同组件中用于以下用途：
实时数据库redis，时序数据管理，及归档数据库。
redis数据库存放所有最新时间点的设备数据；
时序数据管理根据存储策略的定义存储访问频次较高的用户指定测点的数据，存储时间为用户指定时长，如1个月，6个月，1年，的设备数据。EnOS默认只通过redis存储最新的设备数据，你必须配置存储策略才能将一段时间内的数据存至时序数据管理，并通过时序数据管理对应的API访问数据。了解更多信息>>
归档数据库根据存储策略的定义访问访问频次较低的历史相对更加久远的数据；
告警引擎，根据配置的触发条件生成告警记录。
流式计算引擎，根据配置的流式计算处理逻辑对实时数据进行处理并返回给数据中心以供其他服务模块使用或API获取。EnOS提供了简单易用的图形界面的流式分析IDE以帮助提升流数据分析处理的效率。了解更多信息>>
设备接入数据流中涉及以下功能模块及概念：