入门指引：订阅时序数据¶

时序数据指资产上送或者计算产生的带时间戳的测点数据，包括资产实时数据。本文介绍如何快速使用EnOS数据订阅配置界面进行数据订阅任务配置，并使用数据订阅 SDK（Java）消费订阅数据。

前提条件¶

已被授权访问数据订阅模块
已接入设备并且设备已经在发送数据
已获取数据订阅关联的服务账号（SA）。有关服务账号的更多信息，参见获取服务账号
已安装好IDE（Java）的电脑

目标及数据准备¶

目标

实现的场景：订阅AI原始数据采集点test_raw的数据。

数据准备

模型配置：使用的模型（test_Model）配置如下：

功能类型	名称	标识符	测点类型	数据类型
测点	test_raw	test_raw	AI	DOUBLE

数据接入：请参考设备连接来完成设备连接，采集 test_raw 测点的数据。

操作步骤¶

订阅并消费资产实时数据的步骤如下：

创建并配置实时数据订阅任务
保存并启动数据订阅任务
使用订阅SDK消费订阅数据
查看数据消费结果

第一步：创建并配置实时数据订阅任务¶

进入 EnOS 应用门户 > 开发者控制台的 数据订阅 模块，可查看当前 OU 创建的所有订阅任务。

请参考如下步骤完成告警数据订阅任务的创建及配置：

创建订阅：点击 添加订阅 按钮，可添加订阅任务，本教程中选择 时序数据订阅。
手动填写或选择系统自动生成订阅ID。
选择订阅关联的服务账号 (SA) ：每个订阅实例都必须关联一个服务账号 (SA) 。
选择订阅数据的消息通道，本教程中选择 实时通道。
输入对订阅任务的描述。
选择需要订阅的客户：每个SA可访问多个客户的数据（通过应用购买建立授权），订阅可根据需要进行客户选择。
选择模型点过滤条件：本教程中选择 test_Model 的 test_raw 测点，订阅系统则会过滤出符合模型测点条件的数据。

第二步：保存并启动订阅任务¶

配置好订阅任务之后，点击保存，返回至订阅任务列表页面，启动创建的订阅任务，开始数据的生产。

第三步：线下使用订阅 SDK 消费订阅数据¶

EnOS数据订阅服务提供对应的数据订阅SDK，帮助你快速进行线下应用开发并消费订阅数据。以下示例以Java SDK为例，介绍线下应用开发的步骤：

在IDE中引用 EnOS Cloud 对应的 Maven 地址。IDE中Maven引用示例如下：

<dependency>
   <groupId>com.enos-iot</groupId>
   <artifactId>subscription-client</artifactId>
   <version>2.4.11</version>
 </dependency>
 <dependency>
   <groupId>com.enos-iot</groupId>
   <artifactId>enos-subscribe-impl</artifactId>
   <version>2.4.11</version>
 </dependency>
<dependency>
 <groupId>com.google.code.gson</groupId>
 <artifactId>gson</artifactId>
 <version>2.10.1</version>
</dependency>
<dependency>
 <groupId>log4j</groupId>
 <artifactId>log4j</artifactId>
 <version>1.2.17</version>
</dependency>

使用IDE进行线下开发；本教程示例代码如下：

String sub_server_host ="sub_server_host";
int sub_server_port ="sub_server_port";
String accessKey ="access_Key";
String secretKey ="secret_Key";
String subId = "subscriptionId";
String consumerGroup = "consumerGroup";   /*可选*/

/*根据订阅类型获取相应的服务*/
EosClient eosClient = new EosClient(sub_server_host, sub_server_port, accessKey, secretKey);
IDataService dataService = eosClient.getDataService();

/* 在启动订阅之前需要创建订阅数据处理函数 */
IDataHandler dataHandler = new IDataHandler(){
   @Override
   public void dataRead(StreamMessage message) {
       System.out.println(message);
   }
};
/* 调用subscribe函数创建订阅连接，调用后订阅连接被创建 */
dataService.subscribe(dataHandler, subId);

/* （可选）同时指定订阅分组，关于订阅分组的概念见订阅SDK参考说明 */
dataService.subscribe(dataHandler, subId, consumerGroup);

备注

在以上示例中，subscriptionId 需要被替换为在EnOS 应用门户 > 开发者控制台创建的订阅任务的订阅ID； sub_server_host 和 sub_server_port 需要被替换为EnOS订阅服务的地址和端口号。由于不同的EnOS服务和实例的地址和端口号不同，请联系远景智能项目经理或技术支持获取对应的服务和端口信息。

有关数据订阅SDK的详细信息，阅读数据订阅SDK参考。

第四步：查看数据消费结果¶

运行订阅消费程序，通过运行日志查看应用是否已消费实时数据。