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

告警是指针对实时数据设置一定的告警规则，根据这些告警规则产生的告警数据。本文介绍如何快速使用 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 Cloud：进入 EnOS 管理控制台的 数据订阅 模块，可查看当前组织创建的所有订阅任务。
EnOS Edge：进入 EnOS 管理控制台的 Edge 管理 模块，点击进入Edge 详情 > 数据订阅，可查看当前 Edge 设备创建的所有订阅任务。

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

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

备注

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

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

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

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

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

EnOS Cloud 消费示例¶

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

<dependency>
  <groupId>com.envisioniot</groupId>
  <artifactId>subscription-client</artifactId>
  <version>5.0.1</version>
</dependency>
<dependency>
  <groupId>com.envisioniot</groupId>
  <artifactId>enos-subscribe-impl</artifactId>
  <version>5.0.1</version>
</dependency>
<dependency>
  <groupId>com.google.code.gson</groupId>
  <artifactId>gson</artifactId>
  <version>2.8.0</version>
</dependency>
<dependency>
  <groupId>log4j</groupId>
  <artifactId>log4j</artifactId>
  <version>1.2.16</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);
IAlertService alertService = eosClient.getAlertService();

/* 在启动订阅之前需要创建订阅数据处理函数 */
IAlertHandler alertHandler = new IAlertHandler(){
    @Override
   public void alertRead(Alert alert) {
        System.out.println(alert);
    }
};

/* 调用subscribe函数创建订阅连接，调用后订阅连接被创建 */
alertService.subscribe(alertHandler, subId);

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

EnOS Edge 消费示例¶

在IDE中引用 EnOS Edge 对应的 Maven 仓库。IDE中Maven引用示例如下：

<dependency>
  <groupId>com.envisioniot.sub</groupId>
  <artifactId>enos-subscribe-impl</artifactId>
  <version>1.0.1</version>
</dependency>
<dependency>
  <groupId>com.google.code.gson</groupId>
  <artifactId>gson</artifactId>
  <version>2.8.0</version>
</dependency>
<dependency>
  <groupId>log4j</groupId>
  <artifactId>log4j</artifactId>
  <version>1.2.16</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, true);
IAlertService alertService = eosClient.getAlertService();

/* 在启动订阅之前需要创建订阅数据处理函数 */
IAlertHandler alertHandler = new IAlertHandler(){
    @Override
   public void alertRead(Alert alert) {
        System.out.println(alert);
    }
};

/* 调用subscribe函数创建订阅连接，调用后订阅连接被创建 */
alertService.subscribe(alertHandler, subId);

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

备注

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

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

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

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