入门指引：订阅资产实时数据¶

本文介绍如何快速使用EnOS数据订阅配置界面进行数据订阅任务配置，并使用数据订阅SDK（Java或Python）消费订阅数据。

前提条件¶

已被授权访问数据订阅模块
已接入设备并且设备已经在发送数据
订阅数据的服务账号（SA）已被授权获取资产数据
已安装好IDE（Java或Python）的电脑

目标及数据准备¶

目标

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

数据准备

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

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

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

操作步骤¶

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

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

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

进入 EnOS管理门户 > 数据订阅 模块，可查看当前组织创建的所有数据订阅任务；请参考如下步骤完成实时数据订阅任务的创建及配置：

创建订阅：点击 添加订阅 按钮，可添加订阅任务，本教程中选择 时序数据订阅。
选择系统自动生成订阅ID。
选择订阅关联的SA账号：每个订阅实例都必须关联一个SA账号，目前EnOS平台上只有创建应用才能生成一个SA账号，具体SA生成方法，请参考管理应用。

备注

数据订阅关联的SA账号必须已被授权获取资产的数据，否则订阅任务会认证失败，而不能成功订阅数据。授权SA账号的详细信息，请参考管理服务账号。
选择订阅数据的消息通道，本教程中选择 实时通道。
输入对订阅任务的描述。
选择需要订阅的客户数据：每个SA可访问多个客户的数据（通过应用购买建立授权），订阅可根据需要进行客户选择。
选择模型点过滤条件：本教程中选择 test_Model 的 test_raw 测点，订阅系统则会过滤出符合模型测点条件的数据。

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

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

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

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

在IDE中引用对应的Maven地址，Java SDK的Maven仓库地址是：https://mvnrepository.com/artifact/com.envisioniot/enos-subscribe。IDE中Maven引用示例如下：

<dependency>
  <groupId>com.envisioniot</groupId>
  <artifactId>enos-subscribe</artifactId>
  <version>2.6.0</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";   /* Optional */

/* service */
EOSClient eosClient = new EOSClient(sub_server_host, sub_server_port, accessKey, secretKey);
IDataService dataService = eosClient.getDataService();

/* handler */
IDataHandler dataHandler = new IDataHandler(){
    @Override
    public void dataRead(StreamMessage message) {
        System.out.println(message);
    }
};
/* subscribe */
dataService.subscribe(dataHandler, subId);

/* (Optional) subscribe with consumer group */
dataService.subscribe(dataHandler, subId, consumerGroup);

备注

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

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

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

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