Real-time data management for a power grid

Patent metadata

Field	Value
Publication number	US-10191529-B2
Application number	US-201615355808-A
Country	US
Kind code	B2
Filing date	Nov 18, 2016
Priority date	Nov 2, 2012
Publication date	Jan 29, 2019
Grant date	Jan 29, 2019

Abstract

A real-time data management system for accessing data in a power grid that controls a transmission delay of real-time data delivered via a real-time bus, and delivers real-time data in a power grid. A unified data model covering various organizations and various data resource may be included. Multi-bus collaboration and bus performance optimization approaches may be used to improve efficiency and performance of the buses. An event integration and complex event process component may be included to provide status of the power grid. A high volume of real-time data and events may be managed to provide data transmission with a low latency, provide flexible extension of the number of data clusters and the number of databases to ensure high volume data storage, and achieve a high speed and transparent data access. Additionally, rapid design and development of analytical applications, and the near real-time enterprise decision-making may be enabled.

First claim

What is claimed is:

1. A method for data transfer in a power grid, the method comprising:
monitoring, by a processor, a data transfer rate at which power grid data is communicated to data consumer instances via a communication bus, the communication bus configured to exchange the power grid data between data producers and the data consumer instances, the power grid data comprising data related to the power grid received from a plurality of different equipment operable as the data producers within the power grid;
identifying, by the processor, sub-processes of a data consumer instance that process power grid data only in parallel and sub-processes of the data consumer instance that process power grid data only in serial, wherein the sub-processes of the data consumer instance that process the power grid data only in parallel comprise parallelizable threads and the sub-process of the data consumer instance that process the power grid data only in serial comprise non-parallelizable threads;
determining, by the processor, an estimated parallel processing time of the sub-processes of the data consumer instance that process power grid data only in parallel and an estimated serial processing time of the sub-processes of the data consumer instance that process power grid data only in serial; and
controlling, by the processor, the data transfer rate based the estimated parallel processing time and the estimated serial processing time.

2. The method claim 1 , wherein the step of controlling the data transfer rate further comprises adjusting a number of the sub-processes of the data consumer instance that process the power grid data only in parallel.

3. The method of claim 1 , wherein the step of controlling the data transfer rate further comprises adjusting a number of the sub-processes of the data consumer instance that process the power grid data only in serial.

4. The method claim 1 , wherein the step of controlling the data transfer rate further comprises maintaining a number of the sub-processes of the data consumer instance that process the power grid data only in serial and adjusting a number of the sub-processes of the data consumer instance that process the power grid data only in parallel.

5. The method of claim 1 , wherein the estimated parallel processing time is an average processing time of the sub-processes of the data consumer instance that process the power grid data only in parallel and the estimated serial processing time is an average processing time of the sub-processes of the data consumer instance that process the power grid data only in serial.

6. The method of claim 1 , wherein the step of controlling the data transfer rate further comprises:
determining, by the processor, a maximum number of data consumer instances based on the estimated serial processing time and the estimated parallel processing time, the maximum number of data consumer instances indicative of an optimal message consumption speed; and
adjusting, by the processor, the number of data consumer instances based on the maximum number of data consumer instances.

7. A system comprising a processor and a non-transitory storage medium accessible to the processor, the non-transitory storage medium comprising instructions executable by the processor, the instructions comprising:
instructions executable to monitor a data transfer rate at which power grid data is communicated to data consumer instances via a communication bus, the communication bus configured to exchange the power grid data between data producers and the data consumer instances, the power grid data comprising real-time data related to a power grid received in real time from equipment of the power grid;
instructions executable to identify parallelizable sub-processes of the data consumer instances that process the power grid data in parallel;
instructions executable to identify non-parallelizable sub-processes of the data consumer instances that process the power grid data in serial;
instructions executable to determine an estimated processing time of the parallelizable sub-processes and an estimated processing time of the non-parallelizable sub-processes;
instructions executable to control the data transfer rate based on the estimated processing time of the parallelizable sub-processes and the estimated processing time of the non-parallelizable sub-processes; and
instructions executable to maintain an optimal data transfer rate at which the power grid data is transferred to the data consumer instances by controlling a number of parallelizable sub-processes and a number of non-parallelizable sub-processes.

8. The system of claim 7 , wherein the instructions to control the data transfer rate further comprises instructions executable to increase a number of the parallelizable sub-processes.

9. The system of claim 7 , wherein the estimated processing time of the parallelizable sub-processes is an average processing time of the parallelizable sub-processes and the estimated processing time of the non-parallelizable sub-processes is an average processing time of the non-parallelizable sub-processes.

10. The system of claim 7 , wherein parallelizable sub-processes include threads that execute in parallel and the non-parallelizable sub-processes include threads that execute in serial.

11. The system according to claim 7 , wherein the instructions executable to control the data transfer rate further comprise instructions executable to cause the system to adjust a size of messages transmitted over the communication bus.

12. The system according to claim 7 , wherein the non-transitory storage medium further comprises instructions executable by the processor to assign, based on the data transfer rate, another communication bus to deliver a portion of the power grid data.

13. A system for delivering real-time data in a power grid, comprising:
a processor and a non-transitory storage medium accessible by the processor, the non-transitory storage medium including instructions executable by the processor to cause the system to:
monitor a data transfer rate at which power grid data is communicated to data consumer instances via a communication bus, the communication bus configured to exchange power grid data between data producers and the data consumer instances, the power grid data comprising real-time data related to the power grid received in real time from equipment of the power grid;
identify parallelizable sub-processes of the data consumer instances and non-parallelizable sub-processes of the data consumer instances, wherein the parallelizable sub-processes process the power grid data in parallel and non-parallelizable sub-processes process the power grid data in serial;
estimate an estimated processing time of the parallelizable sub-processes instances and an estimated processing time of the non-parallelizable sub-processes;
control the data transfer rate based on the estimated processing time of the parallelizable sub-processes and the estimated processing time of the non-parallelizable sub-processes;
determine the data transfer rate is not an optimal data transfer rate; and
adjust, in response to the data transfer rate not being the optimal data transfer rate, at least one of a number of parallelizable sub-processes or a number of non-parallelizable sub-processes.

14. A system for delivering real-time data in a power grid, comprising:
a processor and a non-transitory storage medium accessible by the processor, the non-transitory storage medium including instructions executable by the processor to cause the system to:
monitor a data transfer rate at which power grid data is communicated to data c

Assignees

• Accenture Global Services Ltd

Inventors

• Zhou Qin
• Yang Zhihui
• Cheng Xiaopei
• Gao Yan
• Ma Guo

Classifications

• H04L49/901

  using storage descriptor, e.g. read or write pointers · CPC title

• G06F1/266

  Arrangements to supply power to external peripherals either directly from the computer or under computer control, e.g. supply of power through the communication port, computer controlled power-strips · CPC title

• G06F1/3206 Primary

  Monitoring of events, devices or parameters that trigger a change in power modality · CPC title

• G06F12/023

  Free address space management · CPC title

• G06F17/30312

  Physics · mapped topic