基于数据中台的电力数据流向监控分析方法

摘要

本发明涉及电力监控的技术领域，提供了基于数据中台的电力数据流向监控分析方法，将电网内部所有电力监控端分为若干监控端集合，并对每个监控端集合配置存储端；还通过数据中台控制监控端集合向存储端传输电力数据的状态，保证数据中台下属所有电力监控端均能够将自身的电力数据完整及时地传输至存储端，避免电力数据遗漏保存和保证电力监控端与存储端的通信效率；再根据存储端的存储数据量，调整存储端与数据中台之间的电力数据流传输模式，提高存储端的数据存储效率；分析数据中台接收到的电力数据流，生成若干电力数据包，以此分配传输至数据处理端，利用数据中台对电力监控端生成的电力数据进行分流传输控制，保证电力数据的高效传输。

说明书

技术领域

本发明涉及电力监控的技术领域，特别涉及基于数据中台的电力数据流向监控分析方法。

背景技术

为了保证电网的正常运行，会在电网设置若干电力监控端来对电网内部不同片区进行电力数据的采集，并将采集得到的电力数据发送至数据处理平台进行处理，从而根据对电力数据的处理结果识别电网内部存在的故障问题。电网内部的电路结构复杂，每个电力监控端采集得到的电力数据量较大，现有技术都是采用中心化的方式来处理电力数据，即利用单一数据处理平台集中处理所有电力数据，这对数据处理平台的数据处理性能提出较高的要求，一旦数据处理平台发生故障，将无法保证对电力数据的及时处理，从而影响电网的正常稳定工作。

发明内容

针对现有技术存在的缺陷，本发明提供了基于数据中台的电力数据流向监控分析方法，其将电网内部所有电力监控端分为若干监控端集合，并对每个监控端集合配置存储端，对所有电力监控端生成的电力数据进行实时保存；还通过数据中台控制监控端集合向存储端传输电力数据的状态，保证数据中台下属所有电力监控端均能够将自身的电力数据完整及时地传输至存储端，避免电力数据遗漏保存和保证电力监控端与存储端的通信效率；再根据存储端的存储数据量，调整存储端与数据中台之间的电力数据流传输模式，提高存储端的数据存储效率；对数据中台接收到的电力数据流进行分析，生成若干电力数据包，以此分配传输至数据处理端，利用数据中台对电力监控端生成的电力数据进行分流传输控制，保证电力数据能够高效地传输到相应数据处理端进行及时处理，提高电力数据的传输和处理的效率及可靠性。

本发明提供基于数据中台的电力数据流向监控分析方法，包括如下步骤：

步骤S1，对电网内部所有电力监控端进行识别，得到每个电力监控端的工作状态信息；基于所述工作状态信息，将所有电力监控端分为若干监控端集合，并在所述电网内部对每个监控端集合分别配置相应的存储端；

步骤S2，通过数据中台向所述监控端集合发送电力数据传输指令，控制所述监控端集合下属所有电力监控端向相应的存储端传输电力数据的状态；并基于每个电力监控端的电力数据生成实况信息，调整所述存储端与不同电力监控端的通信通道状态；

步骤S3，获取所有存储端各自的实时存储数据量变化信息，基于所述实时存储数据量变化信息，确定所有存储端与所述数据中台之间的电力数据流传输模式；基于每个存储端向所述数据中台的电力数据流传输结果，调整每个存储端的电力数据存储状态；

步骤S4，对所述数据中台接收到的电力数据流进行分类，生成若干电力数据包；基于所述数据中台当前连接的所有数据处理端各自的工作状态，将所有电力数据包分配传输至相应的数据处理端。

在本申请公开的一个实施例中，在所述步骤S1中，对电网内部所有电力监控端进行识别，得到每个电力监控端的工作状态信息，包括：

向电网内部所有电力监控端分别发送工作日志调取指令，得到每个电力监控端的工作日志；对所述工作日志进行分析，得到每个电力监控端当前监控的电力设备的类型信息以及每个电力设备在所述电网内部的位置信息。

在本申请公开的一个实施例中，在所述步骤S1中，基于所述工作状态信息，将所有电力监控端分为若干监控端集合，并在所述电网内部对每个监控端集合分别配置相应的存储端，包括：

基于每个电力监控端当前监控的电力设备的类型信息，将所有电力监控端分为若干第一监控端集合；其中，每个第一监控端集合下属的所有电力监控端均对同一类型的电力设备进行电力数据的监控，并且不同第一监控端集合监控的电力设备类型互不相同；

基于每个电力设备在所述电网内部的位置信息，将每个第一监控端集合分为若干第二监控端集合；其中，每个第二监控端集合下属的所有电力监控端中任意两个电力监控端在所述电网内部的间距均小于或等于预设距离阈值；

基于每个第二监控端集合下属的所有电力监控端的电力数据生成历史记录，在所述电网内部对每个第二监控端集合下属的所有电力监控分配共用的存储端。

在本申请公开的一个实施例中，在所述步骤S1中，基于每个第二监控端集合下属的所有电力监控端的电力数据生成历史记录，在所述电网内部对每个第二监控端集合下属的所有电力监控端分配共用的存储端，包括：

对每个第二监控端集合下属的所有电力监控端的电力数据生成历史记录进行分析，得到每个电力监控端在历史电力数据监控过程中单位时间内的电力数据生成量；

将每个第二监控端集合下属的所有电力监控端的电力数据生成量与所述电网内部所有存储端各自的数据接收带宽进行对比，再基于所述对比的结果，在所述电网内部对每个第二监控端集合下属的所有电力监控端分配共用的存储端，并构建所述第二监控端集合下属的所有电力监控端各自与所述共用的存储端之间的通信通道。

在本申请公开的一个实施例中，在所述步骤S2中，通过数据中台向所述监控端集合发送电力数据传输指令，控制所述监控端集合下属所有电力监控端向相应的存储端传输电力数据的状态，包括：

基于所述监控端集合下属的所有电力监控端各自对相应电力设备的监控工作时间区间，通过数据中台向所述监控端集合发送电力数据传输指令，控制所述监控端集合下属的所有电力监控端向相应的存储端进行电力数据传输的执行时间区间。

在本申请公开的一个实施例中，在所述步骤S2中，基于每个电力监控端的电力数据生成实况信息，调整所述存储端与不同电力监控端的通信通道状态，包括：

获取所述监控端集合下属的所有电力监控端各自在单位时间内的电力数据生成数据量，当所述监控端集合下属的某一电力监控端向相应的存储端传输电力数据时，基于所述电力监控端在单位时间内的电力数据生成数据量，调整所述存储端与所述电力监控端的通信通道数据传输带宽。

在本申请公开的一个实施例中，在所述步骤S3中，获取所有存储端各自的实时存储数据量变化信息，基于所述实时存储数据量变化信息，确定所有存储端与所述数据中台之间的电力数据流传输模式，包括：

获取所有存储端各自的剩余可用存储空间值和存储数据量增加速度，基于所述剩余可用存储空间值和所述存储数据量增加速度，确定所有存储端各自完全消耗自身存储空间的所需时间；

基于所有存储端各自完全消耗自身存储空间的所需时间由小到大的顺序，确定所有存储端与所述数据中台之间的电力数据流传输顺序。

在本申请公开的一个实施例中，在所述步骤S3中，基于每个存储端向所述数据中台的电力数据流传输结果，调整每个存储端的电力数据存储状态，包括：

获取每个存储端向所述数据中台的电力数据流传输进度信息，基于所述电力数据流传输进度信息，判断所述存储端是否已经完成向所述数据中台传输电力数据流；

若所述存储端已经完成向所述数据中台传输电力数据流，则删除所述存储端内部相应的电力数据；若所述存储端未完成向所述数据中台传输电力数据流，则保持所述存储端内部的相应的电力数据的存储状态不变。

在本申请公开的一个实施例中，在所述步骤S4中，对所述数据中台接收到的电力数据流进行分类，生成若干电力数据包，包括：

基于所述数据中台接收到的电力数据流的生成时间，对所述数据中台接收到的电力数据流进行分类，生成若干电力数据包；其中，每个电力数据包下属的所有电力数据均在相同时间段内生成。

在本申请公开的一个实施例中，在所述步骤S4中，基于所述数据中台当前连接的所有数据处理端各自的工作状态，将所有电力数据包分配传输至相应的数据处理端，包括：

基于所述数据中台当前连接的所有数据处理端各自的待处理任务数据量和可用内存空间，从所有数据处理端中识别处于空闲状态的所有数据处理端，再将所有电力数据包随机分配传输至处于空闲状态的数据处理端。

相比于现有技术，该基于数据中台的电力数据流向监控分析方法将电网内部所有电力监控端分为若干监控端集合，并对每个监控端集合配置存储端，对所有电力监控端生成的电力数据进行实时保存；还通过数据中台控制监控端集合向存储端传输电力数据的状态，保证数据中台下属所有电力监控端均能够将自身的电力数据完整及时地传输至存储端，避免电力数据遗漏保存和保证电力监控端与存储端的通信效率；再根据存储端的存储数据量，调整存储端与数据中台之间的电力数据流传输模式，提高存储端的数据存储效率；对数据中台接收到的电力数据流进行分析，生成若干电力数据包，以此分配传输至数据处理端，利用数据中台对电力监控端生成的电力数据进行分流传输控制，保证电力数据能够高效地传输到相应数据处理端进行及时处理，提高电力数据的传输和处理的效率及可靠性。

本发明的其它特征和优点将在随后的说明书中阐述，并且，部分地从说明书中变得显而易见，或者通过实施本发明而了解。本发明的目的和其他优点可通过在所写的说明书、权利要求书、以及附图中所特别指出的结构来实现和获得。

下面通过附图和实施例，对本发明的技术方案做进一步的详细描述。

附图说明

为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。

图1为本发明提供的基于数据中台的电力数据流向监控分析方法的流程示意图。

具体实施方式

下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。

参阅图1，为本发明实施例提供的基于数据中台的电力数据流向监控分析方法的流程示意图。该基于数据中台的电力数据流向监控分析方法包括：

步骤S1，对电网内部所有电力监控端进行识别，得到每个电力监控端的工作状态信息；基于该工作状态信息，将所有电力监控端分为若干监控端集合，并在该电网内部对每个监控端集合分别配置相应的存储端；

步骤S2，通过数据中台向该监控端集合发送电力数据传输指令，控制该监控端集合下属所有电力监控端向相应的存储端传输电力数据的状态；并基于每个电力监控端的电力数据生成实况信息，调整该存储端与不同电力监控端的通信通道状态；

步骤S3，获取所有存储端各自的实时存储数据量变化信息，基于该实时存储数据量变化信息，确定所有存储端与该数据中台之间的电力数据流传输模式；基于每个存储端向该数据中台的电力数据流传输结果，调整每个存储端的电力数据存储状态；

步骤S4，对该数据中台接收到的电力数据流进行分类，生成若干电力数据包；基于该数据中台当前连接的所有数据处理端各自的工作状态，将所有电力数据包分配传输至相应的数据处理端。

该基于数据中台的电力数据流向监控分析方法将电网内部所有电力监控端分为若干监控端集合，并对每个监控端集合配置存储端，对所有电力监控端生成的电力数据进行实时保存；还通过数据中台控制监控端集合向存储端传输电力数据的状态，保证数据中台下属所有电力监控端均能够将自身的电力数据完整及时地传输至存储端，避免电力数据遗漏保存和保证电力监控端与存储端的通信效率；再根据存储端的存储数据量，调整存储端与数据中台之间的电力数据流传输模式，提高存储端的数据存储效率；对数据中台接收到的电力数据流进行分析，生成若干电力数据包，以此分配传输至数据处理端，利用数据中台对电力监控端生成的电力数据进行分流传输控制，保证电力数据能够高效地传输到相应数据处理端进行及时处理，提高电力数据的传输和处理的效率及可靠性。

优选地，在该步骤S1中，对电网内部所有电力监控端进行识别，得到每个电力监控端的工作状态信息，包括：

向电网内部所有电力监控端分别发送工作日志调取指令，得到每个电力监控端的工作日志；对该工作日志进行分析，得到每个电力监控端当前监控的电力设备的类型信息以及每个电力设备在该电网内部的位置信息。

在上述技术方案中，电网内部不同位置分别安装有若干电力监控端，每个电力监控端能够对其自身所在电网内部的相应区域进行电力数据的采集检测；其中，该电力监控端可为但不限于是电流传感器或电压传感器，相应地采集检测得到的电力数据可为但不限于是电流数据或电压数据。每个电力监控端在电网内部进行电力数据过程中会形成相应的工作日志，该工作日志用于记录电力监控端进行电力数据采集对应的电力设备的设备类型信息（比如变压器或谐波处理器等）以及电力监控端在电网内部对应的位置信息，便于对电力监控端在电网内部负责进行电力数据检测的片区进行定位，从而对每个电力监控端的电力数据检测状态进行标识确定。

优选地，在该步骤S1中，基于该工作状态信息，将所有电力监控端分为若干监控端集合，并在该电网内部对每个监控端集合分别配置相应的存储端，包括：

基于每个电力监控端当前监控的电力设备的类型信息，将所有电力监控端分为若干第一监控端集合；其中，每个第一监控端集合下属的所有电力监控端均对同一类型的电力设备进行电力数据的监控，并且不同第一监控端集合监控的电力设备类型互不相同；

基于每个电力设备在该电网内部的位置信息，将每个第一监控端集合分为若干第二监控端集合；其中，每个第二监控端集合下属的所有电力监控端中任意两个电力监控端在该电网内部的间距均小于或等于预设距离阈值；

基于每个第二监控端集合下属的所有电力监控端的电力数据生成历史记录，在该电网内部对每个第二监控端集合下属的所有电力监控分配共用的存储端。

在上述技术方案中，电网内部设置所有电力监控端各自对应检测的电力设备类型和进行电力数据检测对应的电网片区位置并不完全相同，先基于每个电力监控端当前监控的电力设备的类型信息，将所有电力监控端分为若干第一监控端集合，这样能够将对同一类型电力设备进行电力数据检测的电力监控端进行整合，便于后续一个存储端只保存一种类型的电力数据。再基于每个电力设备在电网内部的位置信息，对每个第一监控端集合进行二次划分，将第一监控端集合分成若干第二监控端集合，这样能够将在相应范围内且对同一类型电力设备进行电力数据检测的电力监控端进行整合，便于后续一个存储端只保存一个电网片区内的同一类型的电力数据，避免存储端发生电力数据保存串扰和提高存储端的电力数据保存可靠性。

优选地，在该步骤S1中，基于每个第二监控端集合下属的所有电力监控端的电力数据生成历史记录，在该电网内部对每个第二监控端集合下属的所有电力监控端分配共用的存储端，包括：

对每个第二监控端集合下属的所有电力监控端的电力数据生成历史记录进行分析，得到每个电力监控端在历史电力数据监控过程中单位时间内的电力数据生成量；

将每个第二监控端集合下属的所有电力监控端的电力数据生成量与该电网内部所有存储端各自的数据接收带宽进行对比，再基于该对比的结果，在该电网内部对每个第二监控端集合下属的所有电力监控端分配共用的存储端，并构建该第二监控端集合下属的所有电力监控端各自与该共用的存储端之间的通信通道。

在上述技术方案中，对每个第二监控端集合下属的所有电力监控端的电力数据生成历史记录进行分析，得到每个第二监控端集合下属的每个电力监控端在历史电力数据监控过程中单位时间内的电力数据生成量，这样能够对每个电力监控端的电力数据生成多寡进行经验分析，从而大致估计每个第二监控端集合整体在单位时间内的电力数据生成量。再将每个第二监控端集合下属的所有电力监控端在单位时间内的电力数据生成量与该电网内部所有存储端各自的数据接收带宽进行对比，从中选择一个具有合适数据接收带宽的存储端与第二监控端集合进行匹配，使得第二监控端集合下属的所有电力监控端均能够向该存储端传输电力数据。其中，选择的存储端所具有的数据接收带宽应当大于或等于第二监控端集合下属的所有电力监控端在单位时间内的电力数据生成量，从而保证第二监控端集合向存储端传输电力数据的顺畅性和效率。

优选地，在该步骤S2中，通过数据中台向该监控端集合发送电力数据传输指令，控制该监控端集合下属所有电力监控端向相应的存储端传输电力数据的状态，包括：

基于该监控端集合下属的所有电力监控端各自对相应电力设备的监控工作时间区间，通过数据中台向该监控端集合发送电力数据传输指令，控制该监控端集合下属的所有电力监控端向相应的存储端进行电力数据传输的执行时间区间。

在上述技术方案中，获取该监控端集合下属的所有电力监控端各自对相应电力设备的监控工作时间区间，即该监控端集合下属的每个电力监控端各自进行电力数据采集检测对应的工作时间分布范围，再通过数据中台向该监控端集合发送电力数据传输指令，该电力数据传输指令用于控制该监控端集合下属的所有电力监控端向相应的存储端进行电力数据传输的执行时间区间，即只有当电力监控端进行电力数据采集检测时，对应的电力监控端才向存储端传输采集检测得到的电力数据，保证电力监控端及时全面将电力数据传输到存储端，避免所有电力监控端同时与存储端连接而导致存储端的通信压力过大。

优选地，在该步骤S2中，基于每个电力监控端的电力数据生成实况信息，调整该存储端与不同电力监控端的通信通道状态，包括：

获取该监控端集合下属的所有电力监控端各自在单位时间内的电力数据生成数据量，当该监控端集合下属的某一电力监控端向相应的存储端传输电力数据时，基于该电力监控端在单位时间内的电力数据生成数据量，调整该存储端与该电力监控端的通信通道数据传输带宽。

在上述技术方案中，获取该监控端集合下属的所有电力监控端各自在单位时间内的电力数据生成数据量，当该监控端集合下属的某一电力监控端向相应的存储端传输电力数据时，基于该电力监控端在单位时间内的电力数据生成数据量，调整该存储端与该电力监控端的通信通道数据传输带宽，这样能够使得当存储端连接的电力监控端生成的电力数据量发生变化时，能够适应性调整与电力监控端的通信通道数据传输带宽，提高存储端对来自电力监控端的电力数据的接收效率。

优选地，在该步骤S3中，获取所有存储端各自的实时存储数据量变化信息，基于该实时存储数据量变化信息，确定所有存储端与该数据中台之间的电力数据流传输模式，包括：

获取所有存储端各自的剩余可用存储空间值和存储数据量增加速度，基于该剩余可用存储空间值和该存储数据量增加速度，确定所有存储端各自完全消耗自身存储空间的所需时间；

基于所有存储端各自完全消耗自身存储空间的所需时间由小到大的顺序，确定所有存储端与该数据中台之间的电力数据流传输顺序。

在上述技术方案中，基于所有存储端各自的剩余可用存储空间值和存储数据量增加速度，确定所有存储端各自完全消耗自身存储空间的所需时间，从而对每个存储端自身的可用存储空间的消耗快慢程度进行定量计算。再基于所有存储端各自完全消耗自身存储空间的所需时间由小到大的顺序，确定所有存储端与该数据中台之间的电力数据流传输顺序，这样数据中台能够优先接收可用存储空间的消耗速度较快的存储端传输的电力数据。

优选地，在该步骤S3中，基于每个存储端向该数据中台的电力数据流传输结果，调整每个存储端的电力数据存储状态，包括：

获取每个存储端向该数据中台的电力数据流传输进度信息，基于该电力数据流传输进度信息，判断该存储端是否已经完成向该数据中台传输电力数据流；

若该存储端已经完成向该数据中台传输电力数据流，则删除该存储端内部相应的电力数据；若该存储端未完成向该数据中台传输电力数据流，则保持该存储端内部的相应的电力数据的存储状态不变。

在上述技术方案中，当存储端向数据中台传输自身保存的电力数据时，对存储端的电力数据流传输进度进行分析，判断存储端是否已经完成向该数据中台传输电力数据流，从而准确掌握存储端的电力数据流传输状态。当该存储端已经完成向该数据中台传输电力数据流，则删除该存储端内部相应的电力数据，这样可以使存储端能够腾出存储空间用于接收来自电力监控端新采集的电力数据；当该存储端未完成向该数据中台传输电力数据流，则保持该存储端内部的相应的电力数据的存储状态不变，这样能够保持存储端向数据终中台传输电力数据的连续性。

优选地，在该步骤S4中，对该数据中台接收到的电力数据流进行分类，生成若干电力数据包，包括：

基于该数据中台接收到的电力数据流的生成时间，对该数据中台接收到的电力数据流进行分类，生成若干电力数据包；其中，每个电力数据包下属的所有电力数据均在相同时间段内生成。

在上述技术方案中，基于该数据中台接收到的电力数据流的生成时间，对该数据中台接收到的电力数据流进行分类，生成若干电力数据包，这样能够对数据中台接收到的所有电力数据进行规范化的划分，便于后续准确分析处理电力数据。

优选地，在该步骤S4中，基于该数据中台当前连接的所有数据处理端各自的工作状态，将所有电力数据包分配传输至相应的数据处理端，包括：

基于该数据中台当前连接的所有数据处理端各自的待处理任务数据量和可用内存空间，从所有数据处理端中识别处于空闲状态的所有数据处理端，再将所有电力数据包随机分配传输至处于空闲状态的数据处理端。

在上述技术方案中，获取该数据中台当前连接的所有数据处理端各自的待处理任务数据量和可用内存空间，当待处理任务数据量小于预设数量阈值或者可用内存空间大于预设内存空间值，则确定相应的数据处理端处于空闲状态，此时将所有电力数据包随机分配传输至处于空闲状态的数据处理端，从而保证每个电力数据包均能够获得及时高效的分析处理。

从上述实施例的内容可知，该基于数据中台的电力数据流向监控分析方法将电网内部所有电力监控端分为若干监控端集合，并对每个监控端集合配置存储端，对所有电力监控端生成的电力数据进行实时保存；还通过数据中台控制监控端集合向存储端传输电力数据的状态，保证数据中台下属所有电力监控端均能够将自身的电力数据完整及时地传输至存储端，避免电力数据遗漏保存和保证电力监控端与存储端的通信效率；再根据存储端的存储数据量，调整存储端与数据中台之间的电力数据流传输模式，提高存储端的数据存储效率；对数据中台接收到的电力数据流进行分析，生成若干电力数据包，以此分配传输至数据处理端，利用数据中台对电力监控端生成的电力数据进行分流传输控制，保证电力数据能够高效地传输到相应数据处理端进行及时处理，提高电力数据的传输和处理的效率及可靠性。

显然，本领域的技术人员可以对本发明进行各种改动和变型而不脱离本发明的精神和范围。这样，倘若本发明的这些修改和变型属于本发明权利要求及其等同技术的范围之内，则本发明也意图包含这些改动和变型在内。