产品简介
产品概述
数据分析服务是OneNET平台提供用户进行数据实时分析统计的核心服务,服务提供用户将多种数据源的数据接入数据分析服务,对数据进行分析处理,并将结果进行输出和可视化展示。
数据接入
目前,数据源接入数据分析服务支持三种方式:
- OneNET设备流接入,用户可以直接使用OneNET平台设备的数据点数据作为数据分析服务的数据源,从而对OneNET平台上的设备数据进行实时分析统计;
- API接入,数据分析服务提供通过rest API的方式将用户的第三方数据接入数据分析服务,从而满足用户对外部数据的实时分析统计;
- 外部数据库接入,数据分析服务提供通过客户端程序的方式可直接将用户数据库的数据接入数据分析服务,从而方便用户对自己数据库数据进行分析。
数据分析是基于Flink SQL搭建自己的实时数据分析和计算任务,支持组件拖拽的方式来编排SQL任务,对数据进行处理、过滤或分流。
数据输出
数据分析的结果目前支持两种方式的输出:
- API输出,数据分析服务提供了根据结果集元数据来生成API,用户可直接调用API来获取数据分析的结果
- OneNET-View可视化输出,OneNET-View是OneNET平台提供的一个大数据可视化组件,用户可将数据分析的结果输出到OneNET-View,进行直观的可视化展示结果。
产品架构
下图展示了数据分析服务的整体流程: