CN-121984841-A - Distributed fault recording data acquisition and synchronization method, system, equipment and storage medium

CN121984841ACN 121984841 ACN121984841 ACN 121984841ACN-121984841-A

Abstract

The invention relates to the technical field of fault recording data acquisition, in particular to a distributed fault recording data acquisition and synchronization method, a system, equipment and a storage medium. The method comprises the steps of establishing network communication connection between a distributed wave recording device and a central server, configuring communication parameters, responding to a wave recording event trigger source to start a data acquisition request, performing communication health assessment on a target wave recording device, judging a communication state through double verification of network connectivity and port availability, sending a calling instruction to the target device to acquire a wave recording file list and receive data when transmission conditions are met, transmitting the data to a central database and executing a synchronous strategy of time sequence sequencing and integrity verification, and executing dynamic switching between main nodes and standby nodes based on the running state of service nodes in a redundant deployment environment. The unified collection, orderly synchronization and reliable storage of the data of the plurality of wave recording devices are realized, and the requirements of the fault analysis of the power system on the data integrity and timeliness are met.

Inventors

QIAN ZHENGHUA
Yang Yigeng
DING RONG
LIN YIXUAN
SU CHAO
LIN ZHIQING
LIANG ZHUHENG

Assignees

华电新能源集团股份有限公司福建分公司

Dates

Publication Date: 20260505
Application Date: 20251223

Claims (10)

1. The distributed fault recording data acquisition and synchronization method is characterized by comprising the steps of establishing network communication connection between a distributed recording device and a central server, configuring communication parameters of each recording device, responding to a recording event trigger source, and starting a data acquisition request for a target recording device by the recording event trigger source; Performing communication health degree evaluation on the target wave recording device, and judging whether the communication state of the target wave recording device meets the data transmission condition or not through a double-verification mode; When the communication state meets the data transmission condition, sending a wave recording file calling instruction to a target wave recording device, acquiring a wave recording file list, receiving a wave recording data file returned by the wave recording device, transmitting the received wave recording data file to a central database for storage, and executing a data synchronization strategy; and under the condition that the redundant deployment node exists in the central server, based on the running state of the service node, performing dynamic switching between the main service node and the standby service node to obtain synchronous service of data acquisition.
2. The method for collecting and synchronizing distributed fault recording data as in claim 1, wherein said recording event trigger source comprises an automatic trigger mode based on a preset rule and a manual trigger mode based on a user command; The wave recording event triggering source starts a data acquisition request for the target wave recording device, and the method comprises the steps of monitoring a fault event signal reported by the wave recording device in an automatic triggering mode, automatically generating the data acquisition request when a fault event is detected, and determining the wave recording device with the fault as the target wave recording device; under the manual triggering mode, a calling instruction which is sent by a user selecting a specific wave recording device through a monitoring interface is received, and the wave recording device selected by the user is determined to be a target wave recording device; based on the emergency degree of the data acquisition requests, acquisition priorities are distributed for different triggering modes, and the acquisition requests automatically triggered by fault events are preferentially processed.
3. The method for collecting and synchronizing distributed fault recording data as in claim 2, wherein the step of performing communication health assessment on the target recording device comprises the steps of sending a network connectivity detection message to the target recording device, receiving a detection response and recording response time, and judging that the network connectivity is abnormal when the response is not received within a preset time; Under the condition that the network connectivity is normal, a connection request is initiated to a data transmission port of the target wave recording device, whether the port is in an open state or not is verified, and a data channel can be established; and comprehensively judging the communication health level according to the network connectivity verification result and the port availability verification result, judging that the communication state meets the data transmission condition when both the network connectivity verification result and the port availability verification result pass, and recording abnormal information and triggering an alarm when any one of the network connectivity verification results and the port availability verification results fail.
4. The method for collecting and synchronizing distributed fault recording data as in claim 3, wherein the step of obtaining a recording file list and receiving a recording data file returned by the recording device comprises receiving a plurality of formats of recording data files returned by the recording device, wherein the plurality of formats comprise a parameter configuration file, a recording configuration file, a data file and a waveform file; Analyzing the recording data files with different formats respectively, extracting key information in each file and establishing association relation among the files; And storing the parsed recording data file into a designated directory of a file server, and storing the recording data file in a classified manner according to the recording device and the data type, so that the subsequent data inquiry and downloading are facilitated.
5. The method for collecting and synchronizing data for distributed fault recording as in claim 4, wherein said executing data synchronization strategy comprises receiving recording data files from different recording devices, parsing timestamp information and device identification information of each data file; Time sequence ordering is carried out on the data files from the plurality of wave recording devices according to the time stamp information, so that the data is ensured to be stored in the central database according to the actual occurrence time sequence; detecting the integrity of the data file, verifying whether the file format and the file size meet preset specifications, marking incomplete or abnormal files and triggering re-calling; in the process of storing a database, maintaining the corresponding relation between the wave recording device and the data file, recording the source device, the acquisition time and the synchronous state of the data, and realizing the traceability of the data.
6. The method for collecting and synchronizing distributed fault recording data as in claim 5, wherein said performing dynamic switching between the primary service node and the backup service node comprises monitoring an operational status of the primary service node in real time, including a communication program operational status, a database service status, and a file service status; When the abnormality of the main service node is detected, starting the standby service node to take over the data acquisition and synchronization tasks, and switching the communication connection of the wave recording device to the standby service node; In the switching process, synchronizing configuration information between a main service node and a standby service node and incomplete data transmission tasks, and ensuring smooth transition of service switching; after the main service node is recovered to be normal, a service switching operation is executed, the data acquisition and synchronization task is handed back to the main service node, and the data of the standby service node is updated to the latest state.
7. The method of claim 6, further comprising monitoring communication status between each recording device and the central server during data acquisition, and recording interruption time and interruption reason when communication interruption is detected; for data transmission failure caused by communication interruption, automatically triggering a data recall flow after communication is recovered, and acquiring wave recording data generated during interruption; displaying the communication state and the data acquisition progress of each wave recording device in real time on a monitoring interface, and sending alarm information to operation and maintenance personnel when abnormal conditions occur; and (3) periodically executing data integrity check, comparing a locally stored record file list of the wave recording device with a stored record of a central database, and identifying and supplementing missing wave recording data.
8. The distributed fault recording data acquisition and synchronization system is based on the distributed fault recording data acquisition and synchronization method according to any one of claims 1-7, and is characterized by further comprising a communication management module, a central server and a network communication module, wherein the communication management module is used for establishing network communication connection between a distributed recording device and the central server and configuring communication parameters of each recording device; the triggering response module is used for responding to a triggering source of the wave recording event and starting a data acquisition request of the target wave recording device; The health evaluation module is used for performing communication health evaluation on the target wave recording device and judging whether the communication state of the target wave recording device meets the data transmission condition; the data calling module is used for sending a wave recording file calling instruction to the target wave recording device, acquiring a wave recording file list and receiving a wave recording data file returned by the wave recording device; the data synchronization module is used for transmitting the received recording data file to the central database for storage and executing a data synchronization strategy; and the node switching module is used for executing dynamic switching between the main service node and the standby service node based on the service node running state to obtain the synchronous service of data acquisition.
9. A computer device comprises a memory and a processor, wherein the memory stores a computer program, and the computer device is characterized in that the processor realizes the steps of the distributed fault recording data acquisition and synchronization method as set forth in any one of claims 1 to 7 when executing the computer program.
10. A computer readable storage medium having a computer program stored thereon, wherein the computer program when executed by a processor performs the steps of the distributed fault recording data acquisition and synchronization method of any one of claims 1 to 7.

Description

Distributed fault recording data acquisition and synchronization method, system, equipment and storage medium Technical Field The invention relates to the technical field of fault recording data acquisition, in particular to a distributed fault recording data acquisition and synchronization method, a system, equipment and a storage medium. Background The fault wave recording device is important equipment for recording the instantaneous electric quantity change of faults in the power system, plays an important role in fault analysis, relay protection evaluation and power grid safe operation, adopts a single-machine independent operation mode in the traditional fault wave recording device, stores fault data locally, and enables operation and maintenance personnel to acquire wave recording files in a mode of manual reading on site or remote login by site, but the mode has the problems of low data acquisition efficiency, excessively scattered historical data management and the like. With the increasing number of substations, tens of or hundreds of wave recording devices may be distributed in a single power plant or power supply area, if a large-area fault occurs in a power grid, the wave recording data of a plurality of substations need to be simultaneously called for comprehensive analysis, the traditional station-by-station calling mode consumes long time and has large workload, the requirement of rapid fault positioning cannot be met, meanwhile, the data format, the storage position and the access mode of each wave recording device are different, certain difficulties are caused to unified management and long-term storage of data, and the existing fault wave recording networking devices still have the following problems in terms of data acquisition, synchronization of multi-device data, running continuity and the like although the remote calling of the data can be realized. Firstly, the lack of communication state verification before data calling, when the network is abnormal or the ports of the wave recording devices are not available, the data transmission is easy to fail, and the problems of finding and positioning are difficult to realize in time, secondly, the data from different wave recording devices have disordered recording sequences in a database in the time dimension, the accuracy of fault time sequence analysis is affected, and once the server fails, the whole data acquisition service is interrupted, so that the requirement of a power system on high availability cannot be met. In addition, in actual operation and maintenance, network communication between the wave recording device and the central server may be interrupted due to equipment restarting, network maintenance, switch faults and the like, the existing system lacks automatic recall of the wave recording data generated during the communication interruption, operation and maintenance personnel are required to manually check and supplement, complexity of operation and maintenance work is increased, and meanwhile, as the quantity of the wave recording data continuously grows, data integrity verification and identification of missing data also become important problems of operation and maintenance. Disclosure of Invention The present invention has been made in view of the problems occurring in the prior art. Therefore, the invention aims to solve the problems of communication reliability verification, distributed data synchronous management, service continuity guarantee and the like of the existing fault recording data acquisition system. In order to solve the technical problems, the invention provides the following technical scheme: in a first aspect, an embodiment of the present invention provides a distributed fault recording data acquisition and synchronization method, which includes establishing a network communication connection between a distributed recording device and a central server, configuring communication parameters of each recording device, responding to a recording event trigger source, and starting a data acquisition request for a target recording device by the recording event trigger source; Performing communication health degree evaluation on the target wave recording device, and judging whether the communication state of the target wave recording device meets the data transmission condition or not through a double-verification mode; When the communication state meets the data transmission condition, sending a wave recording file calling instruction to a target wave recording device, acquiring a wave recording file list, receiving a wave recording data file returned by the wave recording device, transmitting the received wave recording data file to a central database for storage, and executing a data synchronization strategy; and under the condition that the redundant deployment node exists in the central server, based on the running state of the service node, performing dynamic switching between the main service node and t