实时消息集成¶
用户可以通过实时消息集成功能，将第三方系统中设备实时上报的数据导入EnOS。并设置策略，对集成进来的数据进行处理、存储和计算。
实时消息集成支持对文件类型数据的集成，不仅支持数据从设备传输到EnOS，也支持设备从EnOS下载文件、删除储存在EnOS上的文件。
EnOS提供了实时消息集成API以集成设备实时上报的测点、属性、事件数据。与EnOS API类似，这些API也使用Service Account + Access Token的鉴权方式。
消息源类型¶
实时消息集成目前支持第三方系统作为客户端，通过下列协议、格式或方式将历史数据和离线缓存数据导入EnOS：
- HTTP。实时消息集成使用的HTTP协议版本、鉴权方式、消息集成API使用说明，参见 基于HTTP协议的消息集成（实时消息）。
流程概述¶
基于HTTP协议，将接入第三方系统的设备的实时数据集成至EnOS的流程如下：
- 在EnOS创建模型、产品；
- 预先在EnOS上创建需要导入实时消息的设备；
- 在 EnOS 管理控制台 > 应用注册 注册一个应用，获得其Service Account (SA)，包括以下参数：
- AccessKey
- SecretKey
- 在 身份与授权 > 服务账号 对SA进行授权；
- 在接入第三方系统的设备上做好相应配置，以调用实时集成的相关API；
- 设备调用API，向EnOS发起请求，请求中可以携带文件类型的数据；设备也可以请求下载或删除存储在EnOS上的文件；
- EnOS会验证设备携带的SA。验证通过后，将会保存设备上传的数据（包括文件）、或者返回待下载文件二进制数据流、或删除指定路径下的文件；
注解
对于设备上传的文件，你也可以在 EnOS 管理控制台 ，选择 设备管理 > 设备资产 或 逻辑资产 ，在 资产详情 的 文件管理 标签页，查看、下载、或删除该设备上传的文件。
实时消息的应用¶
第三方系统的实时消息集成到EnOS之后，应用程序可以通过EnOS API调用这些数据，参见API相关文档；同时，用户也可以在EnOS上订阅实时消息数据流，数据经过规则引擎会被分发到相应的Kafka topic，供EnOS数据资产管理的相关功能调用。