CN113242146A - Distributed acquisition system for power grid data - Google Patents
Distributed acquisition system for power grid dataDownload PDFInfo
- Publication number
- CN113242146A CN113242146ACN202110495379.8ACN202110495379ACN113242146ACN 113242146 ACN113242146 ACN 113242146ACN 202110495379 ACN202110495379 ACN 202110495379ACN 113242146 ACN113242146 ACN 113242146A
- Authority
- CN
- China
- Prior art keywords
- processing
- transverse
- module
- subsystem
- acquisition
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Images
Classifications
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/08—Configuration management of networks or network elements
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/20—Information retrieval; Database structures therefor; File system structures therefor of structured data, e.g. relational data
- G06F16/27—Replication, distribution or synchronisation of data between databases or within a distributed database system; Distributed database system architectures therefor
- H—ELECTRICITY
- H02—GENERATION; CONVERSION OR DISTRIBUTION OF ELECTRIC POWER
- H02J—CIRCUIT ARRANGEMENTS OR SYSTEMS FOR SUPPLYING OR DISTRIBUTING ELECTRIC POWER; SYSTEMS FOR STORING ELECTRIC ENERGY
- H02J13/00—Circuit arrangements for providing remote indication of network conditions, e.g. an instantaneous record of the open or closed condition of each circuitbreaker in the network; Circuit arrangements for providing remote control of switching means in a power distribution network, e.g. switching in and out of current consumers by using a pulse code signal carried by the network
- H02J13/00006—Circuit arrangements for providing remote indication of network conditions, e.g. an instantaneous record of the open or closed condition of each circuitbreaker in the network; Circuit arrangements for providing remote control of switching means in a power distribution network, e.g. switching in and out of current consumers by using a pulse code signal carried by the network characterised by information or instructions transport means between the monitoring, controlling or managing units and monitored, controlled or operated power network element or electrical equipment
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/08—Configuration management of networks or network elements
- H04L41/0893—Assignment of logical groups to network elements
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/12—Discovery or management of network topologies
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/14—Network analysis or design
- H04L41/145—Network analysis or design involving simulating, designing, planning or modelling of a network
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L43/00—Arrangements for monitoring or testing data switching networks
- H04L43/08—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
- H04L43/0805—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability
- H04L43/0817—Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters by checking availability by checking functioning
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L43/00—Arrangements for monitoring or testing data switching networks
- H04L43/16—Threshold monitoring
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L2212/00—Encapsulation of packets
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Databases & Information Systems (AREA)
- Theoretical Computer Science (AREA)
- Power Engineering (AREA)
- Computing Systems (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Environmental & Geological Engineering (AREA)
- Small-Scale Networks (AREA)
- Computer And Data Communications (AREA)
Abstract
Translated fromChinese
Description
Technical Field
The invention relates to the field of power grid data processing, in particular to a power grid data distributed acquisition system.
Background
The power network is divided into a production network and an information network, the scale of the power grid construction is gradually enlarged, the power production network is synchronously and rapidly enlarged along with the production service range and the service type, and the power network is mutually independent according to the current situation that the 'multi-network' network isolation exists between the region division and the service application.
The huge network structure needs to build a network management system to ensure the stability of network operation. In the conventional network operation monitoring method, an independent network management system is deployed in each independent network to monitor and manage all network devices in a network architecture.
The network management system is separately deployed between different networks, a single-network data centralized collection and processing mode is adopted, data of each sub-network device is independently stored in the network management system, and the network management system is only responsible for data analysis and application of the network devices in the network. Therefore, from the aspect of investment and construction, several sets of systems and servers need to be built if several networks exist, and resources cannot be fully shared; from the aspect of application construction, the system has poor expansibility, and fusion expansion of applications cannot be realized; from the aspect of data sharing, the model and the data are independently stored, so that the overall business cannot be macroscopically mastered and comprehensively analyzed; and the maintenance is difficult in the aspect of operation and maintenance, and a plurality of sets of systems need to be maintained simultaneously.
More importantly, due to different formats and different processing logics and requirements, computing resources and storage resources cannot be configured in a coordinated manner, so that when part of servers are busy, some servers are in an idle state, and the resources are seriously wasted.
Disclosure of Invention
In view of this, the present invention provides a distributed acquisition system for grid data.
In order to solve the technical problems, the technical scheme of the invention is as follows: a power grid data distributed acquisition system is applied to a distributed acquisition network, the distributed acquisition network is provided with a plurality of acquisition nodes and processing nodes corresponding to a power supply power grid, the acquisition nodes are provided with acquisition ends, and the processing nodes are provided with processing ends and comprise an acquisition end configuration subsystem, a server configuration subsystem, a transverse scheduling subsystem, an upward switching subsystem and a downward packaging subsystem;
the acquisition terminal configuration subsystem comprises an access management module and a protocol calling module; the acquisition terminal configuration subsystem is configured with an acquisition type database and a protocol association database, the acquisition type database stores identification conditions and acquisition type information corresponding to the identification conditions, the protocol association database is configured with a plurality of acquisition type information and acquisition communication protocols corresponding to the acquisition type information, the access management module is used for verifying the identification characteristic information generated by the acquisition terminal, when the identification characteristic information meets the corresponding identification conditions, the corresponding acquisition type information is acquired and the corresponding acquisition terminal is accessed to the distributed acquisition network, and the protocol retrieval module retrieves the corresponding acquisition communication protocol from the protocol association database according to the acquired acquisition type information;
the server configuration subsystem comprises a topology management module, a protocol configuration module and a processing strategy configuration module, wherein the topology management module is configured with a distributed network model of a distributed acquisition network, the distributed network model reflects a topology association relation between an acquisition end and a processing end, and the topology management module configures a communication level for the processing end according to the distributed network model; the protocol configuration module configures a corresponding acquisition communication protocol for the processing end according to the topological correlation between the acquisition end and the processing end; the processing strategy configuration module configures a corresponding processing strategy for the processing terminal according to the processing requirement of the processing terminal;
the system comprises a transverse scheduling subsystem, a transverse relation database, a plurality of transverse association groups and a distributed acquisition network, wherein the transverse scheduling subsystem is configured with a transverse scheduling triggering condition, when the working state of a processing end meets the transverse scheduling triggering condition, the transverse scheduling subsystem of the processing end works, the transverse scheduling subsystem is configured with a transverse relation database, the transverse relation database is configured with a plurality of transverse association groups, numbers of the processing ends belonging to the same communication level are configured in the transverse association groups, and each processing end in the distributed acquisition network at least belongs to one transverse association group; the transverse scheduling subsystem comprises a transverse positioning module, a preloading module and a transverse execution module, wherein the transverse positioning module is configured with an idle judgment strategy, screens a processing end in an idle state in a transverse association group as a transverse processing target through the idle judgment strategy, sends a transverse scheduling command to the transverse processing target, and loads a corresponding processing strategy from a processing end of a last communication level of the transverse processing target through the preloading module when the transverse processing target receives the transverse scheduling command; the transverse execution module is configured with transverse scheduling and screening conditions, and sends the data tasks meeting the transverse scheduling and screening conditions to corresponding transverse processing targets;
the upward switching subsystem is configured with an upward switching triggering condition, when the working state of a processing end meets the upward switching triggering condition, the upward switching subsystem of the processing end works, the upward switching subsystem comprises a multiplexing determination module and a switching execution module, the processing strategy comprises a plurality of processing steps, the multiplexing determination module is configured with multiplexing characteristics and multiplexing screening conditions, the multiplexing determination module is used for marking the processing steps which meet the multiplexing characteristics and screening the marked processing steps through the multiplexing screening conditions to obtain target steps, and the switching execution module switches the target steps from the processing strategy to the processing strategy corresponding to the processing end of the previous communication level for execution;
the downward packaging subsystem is configured with a downward packaging triggering condition, when the working state of a processing end meets the downward triggering condition, the downward packaging subsystem of the processing end works, the downward packaging subsystem comprises a task packaging module, a task transferring module and a channel expansion module, the task packaging module is configured with a task judging condition, the task packaging module packages a data task meeting the task judging condition and a corresponding processing strategy into a transferred data packet, the task transferring module sends the transferred data packet to the processing end of the next communication level of the processing end, and the processing end receiving the transferred data packet processes the data task according to the corresponding processing strategy to generate a data result; and the channel expansion module configures a forwarding strategy, wherein the forwarding strategy comprises a verification condition, and when the received data result meets the verification condition, the data result is forwarded through the forwarding strategy.
Further, the transverse scheduling triggering condition includes a first local-level triggering threshold and a first lower-level triggering threshold, the transverse scheduling subsystem acquires the load condition of the processing end and generates a first local-level load value, and simultaneously acquires the load condition of the processing end of a next communication level of the processing end and generates a first lower-level load value; when the first local-level load value is higher than the first local-level trigger threshold and the first lower-level load value is higher than the first lower-level trigger threshold, the processing terminal is considered to meet the transverse scheduling trigger condition;
the transverse scheduling subsystem acquires the load condition of the processing end and generates a second local-level load value, and simultaneously acquires the load condition of the processing end of the lower and upper communication levels of the processing end and generates a second upper-level load value; when the second local-level load value is higher than a second local-level trigger threshold and the second upper-level load value is lower than a second upper-level trigger threshold, the processing terminal is considered to meet an up-switch trigger condition;
the downward encapsulation triggering condition comprises a third local triggering threshold and a third subordinate triggering threshold, the downward encapsulation subsystem acquires the load condition of the processing terminal and generates a third local load value, and simultaneously acquires the load condition of the processing terminal of the next communication level of the processing terminal and generates a third local triggering threshold; and when the third local load value is higher than the third local trigger threshold and the third subordinate load value is lower than the third subordinate trigger threshold, the processing terminal is considered to meet the downward packaging trigger condition.
Further, the server configuration subsystem further includes a transmission loss database, where the transmission loss database stores transmission loss characteristics of a topological association relationship between the processing terminals, and the transmission loss characteristics reflect transmission loss of communication performed by the processing terminals through the topological relationship.
Further, the transverse scheduling subsystem is configured with a transverse division strategy and a division database, the division database is provided with a complementary relation storing power utilization types, the complementary relation of the power utilization types comprises two power supply types and corresponding complementary values, the transverse division strategy obtains processing ends with the same last communication level, complementary loss values between the processing ends are calculated according to the complementary values and transmission loss characteristics through a loss calculation algorithm, and the processing ends with the complementary loss values smaller than a complementary reference value are divided into the same transverse association group.
Further, the acquisition end configuration subsystem includes a priority value configuration module, and the priority value configuration module is configured to configure a transmission priority value for a corresponding data task when the acquisition end generates the data task.
Further, the horizontal scheduling screening condition is configured with a horizontal priority reference value, when the transmission priority value of the corresponding data task is smaller than the horizontal priority reference value, the data task is judged to accord with the horizontal scheduling screening condition, and the horizontal priority reference value is generated according to the busy state of the corresponding processing end.
Further, the multiplexing screening condition is configured with a multiplexing saturation reference value, the multiplexing saturation reference value is generated according to a busy state of a corresponding processing end, each processing step is configured with a multiplexing load value, and the multiplexing screening condition determines that the processing step in which the sum of the multiplexing load values is smaller than the multiplexing saturation reference value is a target step.
Further, the multiplexing characteristic is that a result corresponding to the processing step needs to be sent to a processing end of the previous communication level.
Further, the task judgment condition includes a storage characteristic and a transmission characteristic, the storage characteristic is that the data result needs to be stored, and the transmission characteristic is that the data result needs to be transmitted to another processing end; and when the storage characteristics or the transmission characteristics of the storage task exist, the storage task is considered to be in accordance with the task judgment condition.
Further, the task encapsulation module configures an identification mark for the downward data packet, the channel expansion module configures a preset channel time period, and when the processing end receives a data result with the identification mark in the channel time period, the processing end judges that the data result meets the verification condition.
The technical effects of the invention are mainly reflected in the following aspects: the data formats are unified in a distributed data management mode, processing strategies and acquisition protocols are subjected to standardized processing, so that mutual resource borrowing and transferring between servers and between storages can be achieved, the balance of calculation load and storage load can be achieved by the aid of calculation resources of the servers, and reasonable resource allocation of the whole system is achieved particularly in a transverse calculation power borrowing and vertical calculation power borrowing mode.
Drawings
FIG. 1: the invention relates to an architecture schematic diagram of a power grid data distributed acquisition system;
FIG. 2: the invention discloses a topological schematic diagram of a collection end configuration subsystem;
FIG. 3: the invention is a topological schematic diagram of a server configuration subsystem;
FIG. 4: the invention discloses a topological schematic diagram of a transverse scheduling subsystem;
FIG. 5: the invention relates to a topological schematic diagram of an up-switch subsystem;
FIG. 6: the invention encapsulates a subsystem topological schematic diagram downwards.
Reference numerals: 100. the acquisition end is provided with a subsystem; 101. collecting a type database; 102. a protocol association database; 110. accessing a management module; 120. a protocol calling module; 130. a priority value configuration module; 200. a server configuration subsystem; 201. a transmission loss database; 210. a topology management module; 220. a protocol configuration module; 230. a processing policy configuration module; 300. a transverse scheduling subsystem; 301. a transverse relational database; 310. a transverse positioning module; 320. a pre-load module; 330. a transverse execution module; 400. an up-switch subsystem; 410. a multiplexing determination module; 420. a switching execution module; 500. packaging the subsystem downwards; 510. a task encapsulation module; 520. a task transfer module; 530. and a channel expansion module.
Detailed Description
The following detailed description of the embodiments of the present invention is provided in order to make the technical solution of the present invention easier to understand and understand.
A power grid data distributed acquisition system is applied to a distributed acquisition network, the distributed acquisition network is configured with a plurality of acquisition nodes and processing nodes corresponding to a power supply power grid, the acquisition nodes are configured with acquisition ends, and the processing nodes are configured with processing ends, and the system comprises an acquisitionend configuration subsystem 100, aserver configuration subsystem 200, atransverse scheduling subsystem 300, anupward switching subsystem 400 and adownward packaging subsystem 500; firstly, a distributed acquisition network is arranged corresponding to a power supply grid, because the power supply grid has a plurality of acquisition points and needs a terminal to analyze and process so as to facilitate timely scheduling, maintenance and adjustment, the distributed acquisition network is a prototype generated by an intelligent power grid, but at present, due to an independent network, formats and information recording types of data are different, and a server and storage resources cannot be borrowed and transferred mutually.
The acquisitionterminal configuration subsystem 100 includes anaccess management module 110 and aprotocol calling module 120; the acquisitionterminal configuration subsystem 100 is configured with anacquisition type database 101 and aprotocol association database 102, theacquisition type database 101 stores identification conditions and acquisition type information corresponding to the identification conditions, theprotocol association database 102 is configured with a plurality of acquisition type information and acquisition communication protocols corresponding to the acquisition type information, theaccess management module 110 is configured to verify the identification characteristic information generated by the acquisition terminal, when the identification characteristic information meets the corresponding identification conditions, the corresponding acquisition type information is acquired and the corresponding acquisition terminal is accessed to the distributed acquisition network, and theprotocol retrieval module 120 retrieves the corresponding acquisition communication protocol from theprotocol association database 102 according to the acquired acquisition type information; for example, the processing end is replaced, the physical address is adjusted, the new acquisition end is incorporated, and other items have independent data retention and management, and correspondingly set access management is performed, so that the acquisition type of each acquisition end is guaranteed to be recorded through a system, the data format is unified, the data is convenient to process, the protocol is uniformly configured through a background, identification is performed through identification characteristic information, the identification characteristic information can be the product number of a product, whether the corresponding product is recorded or not is determined through the number, the acquisition system is accessed after recording, the data format is unified, the acquisition system automatically calls the corresponding protocol, and the protocol does not need to be reconfigured by each processing end corresponding to the acquisition end, so that the efficiency and the reliability are improved. In one embodiment, the acquisition-side configuration subsystem 100 includes a priorityvalue configuration module 130, and the priorityvalue configuration module 130 is configured to configure a transmission priority value for a corresponding data task when the acquisition side generates the data task. Through the priorityvalue configuration module 130, the corresponding transmission priority value is generated according to the data task, so that a basis can be provided for scheduling of the data task, and the processing end can determine the corresponding priority order when data is contended.
The server configuration subsystem 200 includes a topology management module 210, a protocol configuration module 220, and a processing policy configuration module 230, where the topology management module 210 configures a distributed network model of a distributed acquisition network, the distributed network model reflects a topological association relationship between an acquisition end and a processing end, and the topology management module 210 configures a communication hierarchy for the processing end according to the distributed network model; the protocol configuration module 220 configures a corresponding acquisition communication protocol for the processing end according to the topological correlation between the acquisition end and the processing end; the processing policy configuration module 230 configures a corresponding processing policy for the processing end according to the processing requirement of the processing end; the server configuration subsystem 200 is designed to configure a server, so the server configuration subsystem 200 is designed to form a corresponding distributed network model through the topology management module 210, and thus the positions of the acquisition end and the processing end can be marked, more importantly, the relationship between the processing ends can be obtained, the acquisition end configuration subsystem 100 can be independently set to adjust the network structure, the relative relationship can be determined through the network model configured by the topology management module 210, and more importantly, the corresponding communication hierarchy is determined, i.e. a basis is provided for subsequent data processing and calling, the communication hierarchy is a first communication hierarchy directly connected with the acquisition end and a second communication hierarchy connected with the first communication hierarchy, and so on, if one processing end is connected with the acquisition end of the first communication hierarchy and the processing end of the second communication hierarchy, he is the first communication level with respect to the acquisition side and the third communication level with respect to the processing side. The processing strategy is generated according to the requirements of the processing end, two principles are generally followed, if the communication level of the data is required by both the communication level at the previous level and the communication level at the current level, the processing strategy is at least set at the current level, the processing strategy is a corresponding step reflecting how the processing end processes the data task to obtain a data result, and the power grid data management system has different requirements on the processing strategy and the data result, so that the processing strategy is not limited. In an embodiment, theserver configuration subsystem 200 further includes atransmission loss database 201, where thetransmission loss database 201 stores transmission loss characteristics of a topological correlation between processing ends, and the transmission loss characteristics reflect transmission loss of the processing ends in communication through the topological relation. Thetransmission loss database 201 is used for judging the transmission loss result, and the transmission loss characteristics are related to the information such as the communication type, the data transmission mode, the protocol, the physical distance of communication, the intermediate equipment and the like, and the transmission loss characteristics are known information and are reflected in the data content in the transmission loss characteristic mode, so that the corresponding transmission loss can be judged by the transmission loss characteristics, and the result can be conveniently quantized.
The transverse scheduling subsystem 300 is configured with a transverse scheduling triggering condition, when the working state of a processing end meets the transverse scheduling triggering condition, the transverse scheduling subsystem 300 of the processing end works, the transverse scheduling subsystem 300 is configured with a transverse relation database 301, the transverse relation database 301 is configured with a plurality of transverse association groups, the transverse association groups are configured with numbers of the processing ends belonging to the same communication level, and each processing end in the distributed acquisition network at least belongs to one transverse association group; the transverse scheduling subsystem 300 includes a transverse positioning module 310, a preloading module 320, and a transverse executing module 330, where the transverse positioning module 310 is configured with an idle judgment policy, and filters a processing end in an idle state in a transverse association group as a transverse processing object through the idle judgment policy and sends a transverse scheduling command to the transverse processing object, and when the transverse processing object receives the transverse scheduling command, loads a corresponding processing policy from a processing end of a previous communication level of the transverse processing object through the preloading module 320; the transverse execution module 330 is configured with transverse scheduling screening conditions, and the transverse execution module 330 sends data tasks meeting the transverse scheduling screening conditions to corresponding transverse processing targets; the transverse scheduling subsystem 300 is configured at a corresponding processing end, judges whether the condition of the corresponding processing end meets a transverse scheduling triggering condition in real time, when the busyness degree of the processing end reaches the transverse scheduling triggering condition, processes the data by setting a corresponding transverse association group, firstly judges which transverse association group the data belongs to in advance, then judges the load of the transverse association group, and can judge the actual load condition of a target server in the transverse association group through an idle judgment strategy, if the corresponding server is in an idle state, a transverse scheduling command is sent to a transverse processing target, and it needs to be explained that the configuration logic of the processing strategy in the invention, the previous communication level server configures all the processing strategies of each corresponding next communication level, so that the scheduling of the processing strategy can be realized, for example, the processing terminal B2 includes processing policies of the processing terminals a1 and a2, when the a1 sends a horizontal scheduling command to the a2, the B2 may load the processing policies in the a2, and then the horizontal execution module 330 of the a1 sends a data task to the a2, so that the a2 has both the processing policies and the data task and can perform data processing. The transverse scheduling triggering condition includes a first local-level triggering threshold and a first lower-level triggering threshold, thetransverse scheduling subsystem 300 obtains the load condition of the processing end and generates a first local-level load value, and obtains the load condition of the processing end of the next communication level of the processing end and generates a first lower-level load value; when the first local-level load value is higher than the first local-level trigger threshold and the first lower-level load value is higher than the first lower-level trigger threshold, the processing terminal is considered to meet the transverse scheduling trigger condition; because the transverse scheduling needs to satisfy two conditions, the first is that the load of the current stage is higher, and the second is that the load of the next stage is higher, because from the perspective of resource priority configuration, the resource and the storage resource of the transverse scheduling server are more consumed, only when the current stage and the next stage can not process, the transverse scheduling strategy is triggered, specifically, by setting two thresholds, because the load value of the processing end can be generated in real time, the detailed description is omitted. In one embodiment, thehorizontal scheduling subsystem 300 is configured with a horizontal partitioning policy and a partitioning database, the partitioning database is provided with a complementary relationship storing power consumption types, the complementary relationship of the power consumption types includes two power supply types and corresponding complementary values, the horizontal partitioning policy obtains processing ends with the same previous communication hierarchy, calculates complementary loss values between the processing ends according to the complementary values and transmission loss characteristics through a loss calculation algorithm, and partitions the processing ends with complementary loss values smaller than a complementary reference value into the same horizontal association group. Through the horizontal partition strategy and the partition database of thehorizontal scheduling subsystem 300, firstly, since the partition logic is based on the power utilization type, for example, the horizontal scheduling needs to consider idle state and transmission loss, and also has a power supply area type, and the collection peak value of the data to be collected and the load habit of the system are determined by the power supply area type, the processing end corresponding to the power supply areas in charge of different types correspondingly sets complementary values according to the complementary relationship, for example, a factory and a residential area, the complementary values are relatively high when the time nodes of the data collection peak value are different, the complementary values are relatively low if the data collection peak value is a commercial house and a residential area, whether the data are lower than the reference is judged through the calculation of the complementary loss value, and if the data are lower than the reference, the data burden of the horizontal scheduling is relatively low, and then the partition of the horizontal association group is performed. In one embodiment, the horizontal scheduling screening condition is configured with a horizontal priority reference value, when the transmission priority value of the corresponding data task is smaller than the horizontal priority reference value, the data task is determined to meet the horizontal scheduling screening condition, and the horizontal priority reference value is generated according to the busy state of the corresponding processing end. And judging whether the data task is in a load scheduling condition or not through the configuration of the transverse priority value, and processing the data with lower priority value in a transverse scheduling mode.
The up-switch subsystem 400 is configured with an up-switch triggering condition, when the working state of a processing end meets the up-switch triggering condition, the up-switch subsystem 400 of the processing end works, the up-switch subsystem 400 includes a multiplexing determination module 410 and a switch execution module 420, the processing strategy includes a plurality of processing steps, the multiplexing determination module 410 is configured with multiplexing features and multiplexing screening conditions, the multiplexing determination module 410 is configured to mark the processing steps meeting the multiplexing features and screen the marked processing steps through the multiplexing screening conditions to obtain target steps, and the switch execution module 420 switches the target steps from the processing strategy to the processing strategy corresponding to the processing end of the previous communication level for execution; the up-switch subsystem 400 is configured to, when an up-switch requirement occurs at a processing end, for example, the processing end is busy, where, as mentioned above, an upper processing end has a processing policy of a lower processing end, and if the data task satisfies a multiplexing characteristic, that is, the upper processing end also needs to use a data result, the multiplexing characteristic may be processed by the data existing at the upper processing end, so as to relieve the communication pressure at the lower processing end, specifically, it is determined whether the data task has the multiplexing characteristic, then a corresponding processing step is determined by a multiplexing screening condition, which step can be switched, and then a part of the processing steps is switched to the processing end of an upper communication layer for processing, because the upper processing end has all processing policies, but there may be a dependency relationship between the processing policy and the processing step, the processing step and the processing step, therefore, data that can be processed by the previous communication level needs to be screened out, and the reliability of the data is guaranteed. The upward switching trigger condition includes a second local-level trigger threshold and a second upper-level trigger threshold, thetransverse scheduling subsystem 300 obtains the load condition of the processing end and generates a second local-level load value, and obtains the load condition of the processing end of the lower and upper communication levels of the processing end and generates a second upper-level load value; when the second local-level load value is higher than a second local-level trigger threshold and the second upper-level load value is lower than a second upper-level trigger threshold, the processing terminal is considered to meet an up-switch trigger condition; the up-switch triggering condition needs to consider the load of the upper level and the local load, and the corresponding up-switch strategy can be triggered only when the load of the upper level is lower and the local load is higher. In one embodiment, the multiplexing screening condition is configured with a multiplexing saturation reference value, the multiplexing saturation reference value is generated according to a busy state of a corresponding processing end, each processing step is configured with a multiplexing load value, and the multiplexing screening condition determines that a processing step in which the sum of the multiplexing load values is smaller than the multiplexing saturation reference value is a target step. By means of the setting, the load of single switching is judged, a multiplexing saturation reference value is set, then corresponding load values are configured corresponding to each processing step, the sum of the multiplexing load values reaches a standard, namely the corresponding processing end reaches a configurable standard, the multiplexing load value is generated according to data such as processing data volume, processing time and transmission time of the processing step, and the multiplexing saturation reference value changes along with the busy state of the processing end of the previous communication layer. And the multiplexing characteristic is that the result corresponding to the processing step needs to be sent to the processing end of the last communication level. That is, the step of switching is the data required by the processing end of the previous communication layer, so that the transmission times of the data during switching can be reduced.
Thedownward encapsulation subsystem 500 is configured with a downward encapsulation triggering condition, when the working state of a processing end meets the downward triggering condition, thedownward encapsulation subsystem 500 of the processing end works, thedownward encapsulation subsystem 500 comprises atask encapsulation module 510, atask transfer module 520 and achannel expansion module 530, thetask encapsulation module 510 is configured with a task judgment condition, thetask encapsulation module 510 encapsulates a data task meeting the task judgment condition and a corresponding processing strategy into a transfer data packet, thetask transfer module 520 transmits the transfer data packet to the processing end of the next communication level of the processing end, and the processing end receiving the transfer data packet processes the data task according to the corresponding processing strategy to generate a data result; thechannel expansion module 530 configures a forwarding policy, where the forwarding policy includes a verification condition, and when the received data result meets the verification condition, the data result is forwarded through the forwarding policy. Thedownward encapsulation subsystem 500 is configured to trigger corresponding work through a downward encapsulation trigger condition when a processing end of an upper communication level is busy, and specifically encapsulate a task, where an encapsulation content includes a processing policy and a corresponding data task to form a processing data packet, the processing end of a next communication level performs processing, and then configures a channel, after the processing end completes the processing of the task, corresponding result data can be determined and data forwarding is directly performed, without original communication protocol verification and parsing, because the data formats are the same, additional data burden may be caused by parsing again, for example, when the processing end of C1 performs a case of dropping the data packet to B1, and the data result is to be sent to D1, at this time, data forwarding may be directly performed through thechannel expansion module 530, and reliability of the data is improved. The downward encapsulation triggering condition includes a third local triggering threshold and a third subordinate triggering threshold, thedownward encapsulation subsystem 500 obtains the load condition of the processing end and generates a third local load value, and obtains the load condition of the processing end of the next communication level of the processing end and generates a third local triggering threshold; and when the third local load value is higher than the third local trigger threshold and the third subordinate load value is lower than the third subordinate trigger threshold, the processing terminal is considered to meet the downward packaging trigger condition. And the downward encapsulation triggering condition is that the data task can be processed in a downward encapsulation mode when the load at the current stage is judged to be higher and the load at the lower stage is judged to be lower. The task judgment condition comprises a storage characteristic and a transmission characteristic, the storage characteristic is that the data result needs to be stored, and the transmission characteristic is that the data result needs to be transmitted to another processing end; and when the storage characteristics or the transmission characteristics of the storage task exist, the storage task is considered to be in accordance with the task judgment condition. The storage characteristic and the transmission characteristic of the condition are judged through the task, namely the data needs to be stored or needs to be transmitted to other processing ends, the storage characteristic and the transmission characteristic are associated with the data in advance in the collected information, the requirement of the data on the processing ends is not high, the key point is that the processing efficiency can be greatly improved by being parallel to the forwarding strategy, and if the data only needs to be processed locally, the data is preferably processed at the local processing end, and the data is not packaged and released. In one embodiment, thetask encapsulation module 510 configures an identification tag for the dropped data packet, and thechannel expansion module 530 configures a predetermined channel time period, and when the processing end receives a data result with the identification tag in the channel time period, it is determined that the data result meets the verification condition. Through the configuration of the identification mark, extra complex verification and processing logic is not needed, judgment is directly carried out, and the processing efficiency is improved.
The above are only typical examples of the present invention, and besides, the present invention may have other embodiments, and all the technical solutions formed by equivalent substitutions or equivalent changes are within the scope of the present invention as claimed.
Claims (10)
1. The utility model provides a power grid data distributing type collection system, is applied to the distributing type and gathers the network, the distributing type gathers the network and corresponds power supply electric wire netting and dispose a plurality of collection nodes and processing node, gather the node configuration and gather the end, processing node configuration disposes processing end, its characterized in that: the system comprises an acquisition end configuration subsystem, a server configuration subsystem, a transverse scheduling subsystem, an upward switching subsystem and a downward packaging subsystem;
the acquisition terminal configuration subsystem comprises an access management module and a protocol calling module; the acquisition terminal configuration subsystem is configured with an acquisition type database and a protocol association database, the acquisition type database stores identification conditions and acquisition type information corresponding to the identification conditions, the protocol association database is configured with a plurality of acquisition type information and acquisition communication protocols corresponding to the acquisition type information, the access management module is used for verifying the identification characteristic information generated by the acquisition terminal, when the identification characteristic information meets the corresponding identification conditions, the corresponding acquisition type information is acquired and the corresponding acquisition terminal is accessed to the distributed acquisition network, and the protocol retrieval module retrieves the corresponding acquisition communication protocol from the protocol association database according to the acquired acquisition type information;
the server configuration subsystem comprises a topology management module, a protocol configuration module and a processing strategy configuration module, wherein the topology management module is configured with a distributed network model of a distributed acquisition network, the distributed network model reflects a topology association relation between an acquisition end and a processing end, and the topology management module configures a communication level for the processing end according to the distributed network model; the protocol configuration module configures a corresponding acquisition communication protocol for the processing end according to the topological correlation between the acquisition end and the processing end; the processing strategy configuration module configures a corresponding processing strategy for the processing terminal according to the processing requirement of the processing terminal;
the system comprises a transverse scheduling subsystem, a transverse relation database, a plurality of transverse association groups and a distributed acquisition network, wherein the transverse scheduling subsystem is configured with a transverse scheduling triggering condition, when the working state of a processing end meets the transverse scheduling triggering condition, the transverse scheduling subsystem of the processing end works, the transverse scheduling subsystem is configured with a transverse relation database, the transverse relation database is configured with a plurality of transverse association groups, numbers of the processing ends belonging to the same communication level are configured in the transverse association groups, and each processing end in the distributed acquisition network at least belongs to one transverse association group; the transverse scheduling subsystem comprises a transverse positioning module, a preloading module and a transverse execution module, wherein the transverse positioning module is configured with an idle judgment strategy, screens a processing end in an idle state in a transverse association group as a transverse processing target through the idle judgment strategy, sends a transverse scheduling command to the transverse processing target, and loads a corresponding processing strategy from a processing end of a last communication level of the transverse processing target through the preloading module when the transverse processing target receives the transverse scheduling command; the transverse execution module is configured with transverse scheduling and screening conditions, and sends the data tasks meeting the transverse scheduling and screening conditions to corresponding transverse processing targets;
the upward switching subsystem is configured with an upward switching triggering condition, when the working state of a processing end meets the upward switching triggering condition, the upward switching subsystem of the processing end works, the upward switching subsystem comprises a multiplexing determination module and a switching execution module, the processing strategy comprises a plurality of processing steps, the multiplexing determination module is configured with multiplexing characteristics and multiplexing screening conditions, the multiplexing determination module is used for marking the processing steps which meet the multiplexing characteristics and screening the marked processing steps through the multiplexing screening conditions to obtain target steps, and the switching execution module switches the target steps from the processing strategy to the processing strategy corresponding to the processing end of the previous communication level for execution;
the downward packaging subsystem is configured with a downward packaging triggering condition, when the working state of a processing end meets the downward triggering condition, the downward packaging subsystem of the processing end works, the downward packaging subsystem comprises a task packaging module, a task transferring module and a channel expansion module, the task packaging module is configured with a task judging condition, the task packaging module packages a data task meeting the task judging condition and a corresponding processing strategy into a transferred data packet, the task transferring module sends the transferred data packet to the processing end of the next communication level of the processing end, and the processing end receiving the transferred data packet processes the data task according to the corresponding processing strategy to generate a data result; and the channel expansion module configures a forwarding strategy, wherein the forwarding strategy comprises a verification condition, and when the received data result meets the verification condition, the data result is forwarded through the forwarding strategy.
2. A distributed acquisition system for grid data as claimed in claim 1, wherein: the transverse scheduling triggering condition comprises a first local-level triggering threshold and a first lower-level triggering threshold, the transverse scheduling subsystem acquires the load condition of the processing terminal and generates a first local-level load value, and simultaneously acquires the load condition of the processing terminal of the next communication level of the processing terminal and generates a first lower-level load value; when the first local-level load value is higher than the first local-level trigger threshold and the first lower-level load value is higher than the first lower-level trigger threshold, the processing terminal is considered to meet the transverse scheduling trigger condition;
the transverse scheduling subsystem acquires the load condition of the processing end and generates a second local-level load value, and simultaneously acquires the load condition of the processing end of the lower and upper communication levels of the processing end and generates a second upper-level load value; when the second local-level load value is higher than a second local-level trigger threshold and the second upper-level load value is lower than a second upper-level trigger threshold, the processing terminal is considered to meet an up-switch trigger condition;
the downward encapsulation triggering condition comprises a third local triggering threshold and a third subordinate triggering threshold, the downward encapsulation subsystem acquires the load condition of the processing terminal and generates a third local load value, and simultaneously acquires the load condition of the processing terminal of the next communication level of the processing terminal and generates a third local triggering threshold; and when the third local load value is higher than the third local trigger threshold and the third subordinate load value is lower than the third subordinate trigger threshold, the processing terminal is considered to meet the downward packaging trigger condition.
3. A distributed acquisition system for grid data as claimed in claim 1, wherein: the server configuration subsystem further comprises a transmission loss database, wherein the transmission loss database stores transmission loss characteristics of topological association relations among the processing terminals, and the transmission loss characteristics reflect transmission loss of communication performed by the processing terminals through the topological relations.
4. A distributed grid data acquisition system as claimed in claim 3, wherein: the transverse scheduling subsystem is configured with a transverse division strategy and a division database, the division database is provided with a complementary relation storing power utilization types, the complementary relation of the power utilization types comprises two power supply types and corresponding complementary values, the transverse division strategy obtains processing ends with the same last communication level, complementary loss values between the processing ends are calculated according to the complementary values and transmission loss characteristics through a loss calculation algorithm, and the processing ends with the complementary loss values smaller than a complementary reference value are divided into the same transverse association group.
5. A distributed acquisition system for grid data as claimed in claim 1, wherein: the acquisition end configuration subsystem comprises a priority value configuration module, and the priority value configuration module is used for configuring a transmission priority value for a corresponding data task when the acquisition end generates the data task.
6. A distributed acquisition system of grid data as claimed in claim 5, wherein: and the transverse scheduling screening conditions are configured with transverse priority reference values, when the transmission priority value of the corresponding data task is smaller than the transverse priority reference value, the data task is judged to accord with the transverse scheduling screening conditions, and the transverse priority reference value is generated according to the busy state of the corresponding processing end.
7. A distributed acquisition system for grid data as claimed in claim 1, wherein: the multiplexing screening condition is configured with a multiplexing saturation reference value, the multiplexing saturation reference value is generated according to the busy state of the corresponding processing end, each processing step is configured with a multiplexing load value, and the multiplexing screening condition determines that the processing step in which the sum of the multiplexing load values is smaller than the multiplexing saturation reference value is a target step.
8. A distributed acquisition system for grid data as claimed in claim 1, wherein: the multiplexing characteristic is that the result corresponding to the processing step needs to be sent to the processing end of the last communication level.
9. A distributed acquisition system for grid data as claimed in claim 1, wherein: the task judgment condition comprises a storage characteristic and a transmission characteristic, the storage characteristic is that the data result needs to be stored, and the transmission characteristic is that the data result needs to be transmitted to another processing end; and when the storage characteristics or the transmission characteristics of the storage task exist, the storage task is considered to be in accordance with the task judgment condition.
10. A distributed acquisition system for grid data as claimed in claim 1, wherein: the task encapsulation module configures an identification mark for the downward data packet, the channel expansion module is configured with a preset channel time interval, and when the processing end receives a data result with the identification mark in the channel time interval, the processing end judges that the data result meets the verification condition.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110495379.8ACN113242146B (en) | 2021-05-07 | 2021-05-07 | A Distributed Acquisition System for Power Grid Data |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110495379.8ACN113242146B (en) | 2021-05-07 | 2021-05-07 | A Distributed Acquisition System for Power Grid Data |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN113242146Atrue CN113242146A (en) | 2021-08-10 |
| CN113242146B CN113242146B (en) | 2023-05-09 |
Family
ID=77132511
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110495379.8AActiveCN113242146B (en) | 2021-05-07 | 2021-05-07 | A Distributed Acquisition System for Power Grid Data |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN113242146B (en) |
Cited By (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113675853A (en)* | 2021-08-24 | 2021-11-19 | 国网福建省电力有限公司营销服务中心 | A power consumption information collection system for energy internet |
| CN117856453A (en)* | 2024-03-05 | 2024-04-09 | 四川川能智网实业有限公司 | Smart power grids control and management system |
Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101540505A (en)* | 2009-01-09 | 2009-09-23 | 南京南瑞继保电气有限公司 | Building method of multistage multi-region interconnected network data model |
| CN202166879U (en)* | 2011-03-18 | 2012-03-14 | 沈阳易讯科技股份有限公司 | Power intelligent dispatch management system |
| US8250131B1 (en)* | 2004-12-08 | 2012-08-21 | Cadence Design Systems, Inc. | Method and apparatus for managing a distributed computing environment |
| US20140277599A1 (en)* | 2013-03-13 | 2014-09-18 | Oracle International Corporation | Innovative Approach to Distributed Energy Resource Scheduling |
| WO2017222763A2 (en)* | 2016-05-31 | 2017-12-28 | Vapor IO Inc. | Autonomous distributed workload and infrastructure scheduling |
| WO2018129829A1 (en)* | 2017-01-12 | 2018-07-19 | 沃太能源南通有限公司 | New type micro-network system and system-based networking and scheduling method |
| US20180247001A1 (en)* | 2015-09-06 | 2018-08-30 | China Electric Power Research Institute Company Limited | Digital simulation system of power distribution network |
- 2021
- 2021-05-07CNCN202110495379.8Apatent/CN113242146B/enactiveActive
Patent Citations (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US8250131B1 (en)* | 2004-12-08 | 2012-08-21 | Cadence Design Systems, Inc. | Method and apparatus for managing a distributed computing environment |
| CN101540505A (en)* | 2009-01-09 | 2009-09-23 | 南京南瑞继保电气有限公司 | Building method of multistage multi-region interconnected network data model |
| CN202166879U (en)* | 2011-03-18 | 2012-03-14 | 沈阳易讯科技股份有限公司 | Power intelligent dispatch management system |
| US20140277599A1 (en)* | 2013-03-13 | 2014-09-18 | Oracle International Corporation | Innovative Approach to Distributed Energy Resource Scheduling |
| US20180247001A1 (en)* | 2015-09-06 | 2018-08-30 | China Electric Power Research Institute Company Limited | Digital simulation system of power distribution network |
| WO2017222763A2 (en)* | 2016-05-31 | 2017-12-28 | Vapor IO Inc. | Autonomous distributed workload and infrastructure scheduling |
| WO2018129829A1 (en)* | 2017-01-12 | 2018-07-19 | 沃太能源南通有限公司 | New type micro-network system and system-based networking and scheduling method |
Non-Patent Citations (1)
| Title |
|---|
| 王桂凤;耿向华;: "云技术在电网资源调度系统中的应用研究", 电源技术* |
Cited By (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113675853A (en)* | 2021-08-24 | 2021-11-19 | 国网福建省电力有限公司营销服务中心 | A power consumption information collection system for energy internet |
| CN113675853B (en)* | 2021-08-24 | 2023-06-20 | 国网福建省电力有限公司营销服务中心 | A power consumption information collection system for energy internet |
| CN117856453A (en)* | 2024-03-05 | 2024-04-09 | 四川川能智网实业有限公司 | Smart power grids control and management system |
| CN117856453B (en)* | 2024-03-05 | 2024-05-31 | 四川川能智网实业有限公司 | Smart power grids control and management system |
Also Published As
| Publication number | Publication date |
|---|---|
| CN113242146B (en) | 2023-05-09 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110572481B (en) | Intelligent electromechanical equipment data interaction method based on LoRa communication | |
| CN106100999B (en) | Image network flow control methods in a kind of virtualized network environment | |
| CN104579839B (en) | A kind of substation communication network state on_line monitoring system and method | |
| CN112165479A (en) | Cloud edge cooperative management and control system of power distribution network | |
| CN106162639B (en) | Floodlight-based SDN wireless network management platform and authentication method | |
| CN105205231A (en) | DCOM (distributed component object model)-based digital simulation system for distribution network | |
| CN101521604A (en) | Strategy-based distributed performance monitoring method | |
| CN113242146A (en) | Distributed acquisition system for power grid data | |
| CN103795575B (en) | A kind of system monitoring method towards multiple data centers | |
| CN114915995B (en) | Network slice monitoring method, system and storage medium based on in-band network telemetry | |
| CN106027421B (en) | The distribution method of dynamic bandwidth communicated towards IEC 61850 based on SDN | |
| CN113036930A (en) | Power grid data communication management system | |
| WO2018233030A1 (en) | Transmission duration-based internet of things data reporting control method and forwarding node | |
| CN117675580A (en) | Energy consumption control method and device for network equipment | |
| CN117395178B (en) | A quality monitoring method based on network partitioning | |
| CN101379763A (en) | System, method, and computer-readable medium for resource migration in a distributed telecommunication system | |
| CN102404760B (en) | Method and device for real-time measurement of system performance | |
| CN102082701B (en) | Method for storing network element positional information and apparatus for same | |
| CN103346905B (en) | A kind of method and system of signalling analysis | |
| CN112000659B (en) | A basic application system suitable for intelligent terminal equipment in distribution area | |
| CN107180393A (en) | A kind of centralized platform server monitored for transformer substation system | |
| CN105069024A (en) | Parallel data acquisition-oriented write access method for distributed file system | |
| CN119583990A (en) | OLT energy-saving method and device, non-volatile storage medium, and electronic device | |
| Tong et al. | B-SDN: A novel blockchain-based software defined network architecture | |
| Zhang et al. | Survey of network management protocols in wireless sensor network |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |