入门指引：订阅资产告警数据¶

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

前提条件¶

已被授权访问数据订阅模块
已接入设备并且已为设备配置告警规则
订阅数据的服务账号（SA）已被授权获取资产数据
已安装好IDE（Java或Python）的电脑

目标及数据准备¶

目标场景

实现的场景：对原始AI采集点 test_raw 进行告警配置，并订阅其告警数据。

数据准备

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

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

数据接入：test_raw为告警数据采集点，请参考设备连接来完成 test_raw 点数据的采集。
告警配置：请参考资产告警来完成 test_raw 点数据的告警配置。

操作步骤¶

订阅并消费告警数据的步骤如下：

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

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

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

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

注解

数据订阅关联的SA账号必须已被授权获取资产的数据，否则订阅任务会认证失败，而不能成功订阅数据。授权SA账号的详细信息，请参考管理服务账号。
输入对订阅任务的描述。
选择需要订阅的客户数据：每个SA可访问多个客户的数据（通过应用购买建立授权），订阅可根据需要进行客户选择。
选择模型过滤条件：本教程中选择 test_Model 这个模型作为条件，订阅系统则会过滤出符合模型条件的告警数据。
（可选）可根据业务需要，添加设备标签或资产树标签，过滤订阅的数据，仅订阅指定设备或指定资产树相关的告警数据。

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

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

第三步：线下使用订阅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);
IAlertService alertService = eosClient.getAlertService();

/* handler */
IAlertHandler alertHandler = new IAlertHandler(){
    @Override
   public void alertRead(Alert alert) {
        System.out.println(alert);
    }
};

/* subscribe */
alertService.subscribe(alertHandler, subId);

/* (Optional) subscribe with consumer group */
alertService.subscribe(alertHandler, subId, consumerGroup);

注解

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

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

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

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