入门指引:订阅时序数据¶
时序数据指资产上送或者计算产生的带时间戳的测点数据,包括资产实时数据。本文介绍如何快速使用EnOS数据订阅配置界面进行数据订阅任务配置,并使用数据订阅 SDK(Java或Python)消费订阅数据。
前提条件¶
已被授权访问数据订阅模块
已接入设备并且设备已经在发送数据
订阅数据的服务账号(SA)已被授权获取资产数据。有关授权服务账号的更多信息,参见 管理服务账号
已安装好IDE(Java或Python)的电脑
目标及数据准备¶
目标
实现的场景:订阅AI原始数据采集点test_raw的数据。
数据准备
模型配置:使用的模型(test_Model)配置如下:
功能类型 |
名称 |
标识符 |
测点类型 |
数据类型 |
---|---|---|---|---|
测点 |
test_raw |
test_raw |
AI |
DOUBLE |
数据接入:请参考 设备连接 来完成设备连接,采集 test_raw 测点的数据。
操作步骤¶
订阅并消费资产实时数据的步骤如下:
创建并配置实时数据订阅任务
保存并启动数据订阅任务
使用订阅SDK消费订阅数据
查看数据消费结果
第一步:创建并配置实时数据订阅任务¶
EnOS Cloud:进入 EnOS 管理控制台的 数据订阅 模块,可查看当前 Cloud 组织创建的所有订阅任务。
EnOS Edge:进入 EnOS 管理控制台的 Edge 管理 模块,点击进入Edge 详情 > 数据订阅,可查看当前 Edge 设备创建的所有订阅任务。
请参考如下步骤完成告警数据订阅任务的创建及配置:
创建订阅:点击 添加订阅 按钮,可添加订阅任务,本教程中选择 时序数据订阅。
选择系统自动生成订阅ID。
选择订阅关联的服务账号 (SA) :每个订阅实例都必须关联一个服务账号 (SA) ,目前EnOS平台上只有创建应用才能生成一个服务账号 (SA)。EnOS Edge 的服务账号 (SA) 显示为已在 EnOS Edge 上线的应用对应账号。
备注
数据订阅关联的服务账号 (SA) 必须已被授权获取资产的数据,否则订阅任务会认证失败,而不能成功订阅数据。授权服务账号 (SA) 的详细信息,请参考 管理服务账号。
选择订阅数据的消息通道,本教程中选择 实时通道。
输入对订阅任务的描述。
选择需要订阅的客户(仅 EnOS Cloud):每个SA可访问多个客户的数据(通过应用购买建立授权),订阅可根据需要进行客户选择。
选择模型点过滤条件:本教程中选择 test_Model 的 test_raw 测点,订阅系统则会过滤出符合模型测点条件的数据。
第二步:保存并启动订阅任务¶
配置好订阅任务之后,点击 保存,返回至订阅任务列表页面,启动创建的订阅任务,开始数据的生产。
第三步:线下使用订阅 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.2</version> </dependency> <dependency> <groupId>com.envisioniot</groupId> <artifactId>enos-subscribe-impl</artifactId> <version>5.0.2</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); 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);
EnOS Edge 消费示例¶
在IDE中引用 EnOS Edge 对应的 Maven 仓库。IDE中Maven引用示例如下:
<dependency> <groupId>com.envisioniot</groupId> <artifactId>subscription-client</artifactId> <version>5.0.2</version> </dependency> <dependency> <groupId>com.envisioniot</groupId> <artifactId>edge-subscribe-impl</artifactId> <version>1.0.5</version> </dependency> <dependency> <groupId>com.google.code.gson</groupId> <artifactId>gson</artifactId> <version>2.8.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"; /*可选*/ /*根据订阅类型获取相应的 service*/ EosClient eosClient = new EosClient(sub_server_host, sub_server_port, accessKey, secretKey, true); 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参考。
第四步:查看数据消费结果¶
运行订阅消费程序,通过运行日志查看应用是否已消费实时数据。