CN-122019663-A - Energy storage power station electric core data shunt acquisition processing method and system

CN122019663ACN 122019663 ACN122019663 ACN 122019663ACN-122019663-A

Abstract

The invention provides a method and a system for acquiring and processing power core data of an energy storage power station in a split manner, and belongs to the technical field of operation and scheduling automation of power systems. The method comprises the steps of automatically distinguishing real-time monitoring data from statistical analysis type data according to a specific marking rule, carrying out splitting treatment on different types of data through a preposed acquisition splitting technology, sending the real-time monitoring data to SCADA (supervisory control and data acquisition) processing, storing the real-time monitoring data in a real-time library for real-time monitoring control, directly storing the statistical analysis type data by adopting a time sequence library, and ensuring uniform and fragmented storage of the data by constructing a distributed time sequence library based on virtual nodes. Different applications call different data sets for display or analysis through interface configuration, so that the energy storage energy management system can access massive battery data, the data processing pressure of a platform is reduced, and the stability of the system is ensured.

Inventors

GU LIBIN
LIU JIABAO
ZENG CHAO
GE JIANKANG
LIU YUE
ZHANG WEICHENG

Assignees

北京四方继保工程技术有限公司
北京四方继保自动化股份有限公司

Dates

Publication Date: 20260512
Application Date: 20251231

Claims (10)

1. The utility model provides an energy storage power station electric core data reposition of redundant personnel collection processing method which characterized in that: automatically dividing the electric core data into real-time monitoring data and statistical analysis data according to a set data classification rule; Based on the original communication point tables of various energy storage devices, generating a configurable point table template through hierarchical configuration and protocol mapping analysis; forming an equipment group based on the equipment container relation, and applying a prepositive point table and a SCADA point table generated by the point table template; judging and splitting the received real-time data stream according to the data point table mark; And directly storing the statistical analysis data by adopting a time sequence library, carrying out hash calculation on the split data according to the configured split model, determining the split to which the split data belongs, distributing the data of different splits to corresponding virtual nodes for concurrent writing, and constructing a distributed time sequence library based on the virtual nodes.
2. The method for acquiring and processing the data of the power core of the energy storage power station in a split manner according to claim 1, which is characterized by comprising the following steps of: Generating the configurable point table template includes: the method comprises the steps of importing original communication point table templates of various energy storage devices, sequentially selecting configuration items associated with layers in a configuration tool according to the point table templates, wherein the configuration items associated with the layers comprise a transformer substation, a container type, a container, a channel and a terminal type; based on the selected container type and the container, loading the communication attribute and the point table frame of the corresponding energy storage equipment; Matching the selected channels with corresponding communication protocols, carrying out mapping analysis on the point table frames of the corresponding energy storage equipment according to the communication protocols, and extracting unified field information required by the system; and generating a configurable point table template according to the unified field information required by the system.
3. The method for acquiring and processing the data of the power core of the energy storage power station in a split manner according to claim 1, which is characterized by comprising the following steps of: the generated prepositive point table and SCADA point table comprise: Forming an energy storage device group based on the device container relationship; and (3) applying the configurable point table templates to the energy storage equipment group in batches, creating corresponding data points in an energy storage monitoring system, marking real-time monitoring data and statistical analysis data in an ammeter according to a data classification rule, and generating a prepositive point table and a SCADA point table with marks.
4. The method for acquiring and processing the data of the power core of the energy storage power station in a split manner according to claim 1, which is characterized by comprising the following steps of: Judging and splitting the received real-time data stream comprises the following steps: inputting real-time data streams from PCS, BMS and other devices, receiving the real-time data streams by a front node of a communication layer, inquiring a front point table with marks associated with the front point in a system real-time library by the communication layer, and inquiring SCADA point marks corresponding to each front node; Judging a shunting mode according to the SCADA point marks corresponding to each preposed node, and determining a shunting data queue and a preposed change message; And shunting the shunting data queue and the front-end change message to corresponding positions.
5. The method for acquiring and processing the data of the power core of the energy storage power station according to claim 4 is characterized in that: The determining of the split data queue and the pre-change message comprises the following steps: The prepositive protocol of the energy storage monitoring system receives real-time monitoring data, judges whether corresponding data is statistical analysis data according to whether SCADA points marked by prepositive points in a real-time library can be found, writes the statistical analysis data into a time library submission queue if the statistical analysis data is the statistical analysis data, and packages the data into a prepositive change message if the marking indicates the real-time monitoring data.
6. The method for acquiring and processing the data of the power core of the energy storage power station according to claim 4 is characterized in that: The shunting of the shunting data queue and the front-end changing message to the corresponding position comprises the following steps: After sending the pre-change message to a processing node corresponding to the SCADA point for SCADA processing, issuing an SCADA processing result to a high-speed message bus to form final real-time library data; and the background service directly submits the split data queue to a distributed time sequence base for storage to form a split data stream.
7. The method for acquiring and processing the data of the power core of the energy storage power station in a split manner according to claim 1, which is characterized by comprising the following steps of: Constructing a distributed timing library based on virtual nodes includes: configuring virtual nodes, wherein each virtual node configures service and allocates port numbers, fragmentation models and storage paths; The statistical analysis type data are directly stored by adopting a time sequence library, when the split data stream is stored, the time sequence library client performs hash calculation on the split data according to the configured split model, determines the split to which the split data belong, and distributes the data of different splits to corresponding virtual nodes for concurrent writing; and each virtual node stores the distributed fragment data into a disk array to form a distributed time sequence base based on the virtual nodes.
8. The method for acquiring and processing the data of the power core of the energy storage power station according to claim 7 is characterized in that: distributing the data of different fragments to corresponding virtual nodes for concurrent writing comprises: Setting a hash function, setting the number of fragments and the number of virtual nodes. Storing the split data flow by adopting a time sequence library, and calculating fragments to which the data belongs after all measuring points pass through a set hash function and modular operation when the split data is stored to obtain fragment data, and calling different virtual nodes to match the fragment data; And concurrently submitting the fragmented data to the matched virtual nodes.
9. The method for acquiring and processing the data of the power core of the energy storage power station in a split manner according to claim 8, which is characterized in that: And deploying a plurality of virtual nodes on the physical nodes, when a new physical node exists, modifying the configuration of the virtual nodes and the storage paths, and migrating the virtual nodes to the new physical node.
10. An energy storage power station electric core data shunt acquisition processing system, according to any one of claims 1-9, characterized in that: the data distinguishing module is used for automatically distinguishing the electric core data into real-time monitoring data and statistical analysis data according to a set data classification rule; The point table template is used for generating a configurable point table template through hierarchical configuration and protocol mapping analysis based on the original communication point tables of various energy storage devices; the point table generating module is used for forming an equipment group based on the equipment container relation, and applying the prepositive point table and the SCADA point table generated by the point table template; the distribution module is used for judging and distributing the received real-time data stream according to the point table marks; And the output module is used for directly storing the statistical analysis data by adopting the time sequence library, carrying out hash calculation on the split data according to the configured split model, determining the split to which the split data belongs, distributing the data of different splits to the corresponding virtual nodes for concurrent writing, and constructing the distributed time sequence library based on the virtual nodes.

Description

Energy storage power station electric core data shunt acquisition processing method and system Technical Field The invention belongs to the technical field of operation and scheduling automation of a power system, and particularly relates to a data distribution acquisition processing method of a large-scale energy storage power station. Background In an electrochemical energy storage system, each single cell has data such as voltage, temperature, SOC and the like, and one battery cluster approximately comprises 200-400 single cells, and the whole data scale of the 200MWh energy storage power station exceeds 100 ten thousand points. The main purpose of the battery cell data is to perform optimal analysis of the battery by analyzing the historical data without participating in the conventional SCADA functions of processing out-of-limit, alarming and the like. In addition, the rate of change of these stations is extremely high during the charge and discharge of the battery, and the process pressure on the system is extremely high. Prior art document 1 (CN 120186215A) discloses an energy storage system data acquisition method and an energy storage system. The decoupling device has the advantages that the decoupling device relates to the technical field of data information of the energy storage system, realizes decoupling between an acquisition task and acquisition equipment, and does not solve the problems of big data acquisition, storage and the like of the energy storage real-time monitoring system; compared with the prior art document 1, the invention is remarkably different in that the invention is provided aiming at the scope of a real-time monitoring system, belongs to the technical field of operation and scheduling automation of an electric power system, and mainly solves the performance problem of real-time data acquisition and processing in the proposed data distribution view point. Prior art document 2 (CN 118673085A) discloses a task execution method, device, energy storage device analysis system, medium and product. Compared with the prior art document 2, the invention is provided for the category of a real-time monitoring system, belongs to the technical field of operation and dispatching automation of an electric power system, mainly solves the performance problem of real-time data acquisition and processing in the proposed data distribution view, and based on the remarkable difference, the invention has the technical effects that the data are stored in the real-time library or the time sequence library respectively based on timeliness of the data, the real-time data processing pressure is reduced, and the data access amount of the energy storage monitoring system is improved under the condition of not changing hardware configuration. Disclosure of Invention In order to solve the defects in the prior art, the invention provides a large-scale energy storage power station electric core data shunt acquisition processing method, which automatically distinguishes real-time monitoring data and statistical analysis type data according to specific marking rules, carries out shunt processing on different types of data through a preposed acquisition and shunt technology, sends SCADA (supervisory control and data acquisition) processing on the real-time monitoring data, stores the real-time monitoring data in a real-time library for real-time monitoring control, directly stores the statistical analysis type data by adopting a time sequence library, and ensures uniform and fragmented storage of the data by constructing a distributed time sequence library based on virtual nodes. Different applications call different data sets for display or analysis through interface configuration, so that the energy storage energy management system can access massive battery data, the data processing pressure of a platform is reduced, and the stability of the system is ensured. The invention adopts the following technical scheme. The first aspect of the invention provides a method for acquiring and processing power core data of an energy storage power station in a split manner, which comprises the following steps: automatically dividing the electric core data into real-time monitoring data and statistical analysis data according to a set data classification rule; Based on the original communication point tables of various energy storage devices, generating a configurable point table template through hierarchical configuration and protocol mapping analysis; forming an equipment group based on the equipment container relation, and applying a prepositive point table and a SCADA point table generated by the point table template; judging and splitting the received real-time data stream according to the data point table mark; And directly storing the statistical analysis data by adopting a time sequence library, carrying out hash calculation on the split data according to the configured split model, determining the split to which t