Distributed data analysis
First Claim
Patent Images
1. A computing system comprising:
- a data broker having a processor and configured to distribute received data to information consumers subscribed with the data broker for the received data, the information consumers comprising a first information consumer, a second information consumer, and an execution consumer, the first information consumer comprising a problem analysis consumer, and the second information consumer comprising an automation consumer, wherein the data broker has an interface to;
receive first data from a subsystem,send the first data to the first information consumer subscribed with the data broker for the first data,receive an analysis result that is based on an analysis of the first data by the first information consumer, the analysis result identifying a repair action to repair a problem with the subsystem,send the analysis result to the second information consumer subscribed with the data broker for data including the analysis result,receive, from the second information consumer, an executable instruction to execute the repair, andsend the executable instruction to the execution consumer causing execution of the repair by the execution consumer,wherein the data broker comprises a notification module configured to notify the first information consumer to not send the analysis result to the data broker if the second information consumer is not subscribed to the data including the analysis result.
2 Assignments
0 Petitions
Accused Products
Abstract
Distributed data analysis systems and methods are provided. A data broker distributes received data to consumers, such as information and repository consumers, which can be subscribed to the data. A subsystem with a processor for data processing can provide data to the data broker. A first information consumer may include a receiving module for receiving the data from the data broker, an analysis module for analyzing the received data to obtain a result, and a publication module for sending the result to the data broker when a second information consumer is subscribed to the result.
28 Citations
18 Claims
-
1. A computing system comprising:
-
a data broker having a processor and configured to distribute received data to information consumers subscribed with the data broker for the received data, the information consumers comprising a first information consumer, a second information consumer, and an execution consumer, the first information consumer comprising a problem analysis consumer, and the second information consumer comprising an automation consumer, wherein the data broker has an interface to; receive first data from a subsystem, send the first data to the first information consumer subscribed with the data broker for the first data, receive an analysis result that is based on an analysis of the first data by the first information consumer, the analysis result identifying a repair action to repair a problem with the subsystem, send the analysis result to the second information consumer subscribed with the data broker for data including the analysis result, receive, from the second information consumer, an executable instruction to execute the repair, and send the executable instruction to the execution consumer causing execution of the repair by the execution consumer, wherein the data broker comprises a notification module configured to notify the first information consumer to not send the analysis result to the data broker if the second information consumer is not subscribed to the data including the analysis result. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12)
-
-
13. A method comprising:
-
receiving, by a data broker having a processor, data from a subsystem; distributing, by the data broker, the data to a first information consumer that has registered with the data broker for the data, the first information consumer comprising a problem analysis consumer; receiving, by the data broker, an analysis result produced by the first information consumer based on analyzing the data, the analysis result identifying a repair action to repair a problem with the subsystem; sending, by the data broker, the analysis result to a second information consumer if the second information consumer is registered with the data broker for data including the analysis result, the second information consumer comprising an automation consumer; receiving, by the data broker from the second information consumer, an executable instruction to execute the repair; sending, by the data broker, the executable instruction to a third information consumer that causes execution of the repair by the third information consumer, the third information consumer registered with the data broker for data including the executable instruction; determining, by the data broker, whether any information consumer is registered with the data broker for data including a result of the execution of the repair; and in response to determining that there is no information consumer registered with the data broker for data including the result of the execution of the repair, notifying, by the data broker, the third information consumer to not send the result of the execution of the repair to the data broker. - View Dependent Claims (14, 15)
-
-
16. A method comprising:
-
receiving, by a data broker including a processor, data from a subsystem; distributing, by the data broker, the data to a first information consumer that has a first subscription with the data broker for the data, the first information consumer comprising a problem analysis consumer; receiving, by the data broker, an analysis result produced by the first information consumer based on analyzing the data, the analysis result identifying a repair action to repair a problem with the subsystem; sending, by the data broker, the analysis result to a second information consumer that has a second subscription with the data broker for data including the analysis result, the second information consumer comprising an automation consumer; receiving, by the data broker from the second information consumer, an executable instruction to execute the repair; sending, by the data broker, the executable instruction to an execution consumer that has a third subscription with the data broker; executing, by the execution consumer, the executable instruction to execute the repair of the problem; determining, by the data broker, whether any information consumer has a subscription with the data broker for data including a result of the execution of the repair; and in response to determining that there is no information consumer having a subscription with the data broker for data including the result of the execution of the repair, notifying, by the data broker, the execution consumer to not send the result of the execution of the repair to the data broker. - View Dependent Claims (17, 18)
-
Specification