Operating wellbore equipment using data from mediator computing devices

Abstract

A system includes a first wellbore operation controller for controlling a wellbore operation and generating a first broadcast indicating a first data topic desired for controlling the wellbore operation. The system also includes a second wellbore operation controller for generating a data stream associated with a wellbore and for generating a second broadcast indicating a second data topic that promotes the data stream. The system includes a mediator computing device that receives the first broadcast and the second broadcast and determines that the first wellbore operation controller is subscribed to the data stream by comparing the first data topic to the second data topic. In response to determining that the first wellbore operation controller is subscribed to the data stream, the mediator computing device creates a data link between the first wellbore operation controller and the second wellbore operation controller.

What is claimed is: 
     
       1. A system comprising:
 a first wellbore operation controller for controlling a wellbore operation performed with respect to a first wellbore and for generating a first broadcast indicating a first data topic desired for controlling the wellbore operation; 
 a second wellbore operation controller for generating a data stream of data associated with a second wellbore and for generating a second broadcast indicating a second data topic that promotes the data of the data stream; and 
 a mediator computing device positionable to:
 receive the first broadcast from the first wellbore operation controller and the second broadcast from the second wellbore operation controller; 
 determine that the first wellbore operation controller is subscribed to the data stream of the second wellbore operation controller by comparing the first data topic to the second data topic; and 
 in response to determining that the first wellbore operation controller is subscribed to the data stream of the second wellbore operation controller, create a data link between the first wellbore operation controller and the second wellbore operation controller to provide the data associated with the second wellbore to the first wellbore operation controller, wherein the data associated with the second wellbore comprises micro-seismic acoustic data and is transformed into a programming language-neutral format prior to providing the data associated with the second wellbore to the first wellbore operation controller, wherein the first wellbore operation controller adjusts an equipment control process of the wellbore operation using the data associated with the second wellbore received from the second wellbore operation controller, and wherein the equipment control process comprises forming the first wellbore, stimulating the first wellbore, or producing fluid from the first wellbore and the wellbore operation comprises a hydraulic fracturing operation. 
 
 
     
     
       2. The system of  claim 1 , wherein the mediator computing device is further positionable to:
 create an additional data link between the second wellbore operation controller and a third wellbore operation controller, wherein the data associated with the second wellbore comprises transformed data, and wherein the second wellbore operation controller transforms source data originating from the third wellbore operation controller to generate the transformed data. 
 
     
     
       3. The system of  claim 1 , wherein the mediator computing device is further positionable to connect with additional wellbore operation controllers in a pluggable manner without recompiling a base stack of a stack data structure of the mediator computing device. 
     
     
       4. The system of  claim 1 , wherein the mediator computing device is further positionable to connect with remote mediator computing devices by creating remote data links between the mediator computing device and the remote mediator computing devices to provide additional data streams from the remote mediator computing device to the first wellbore operation controller or the second wellbore operation controller. 
     
     
       5. A method comprising:
 transmitting, by a wellbore operation controller and to a mediator computing device, a first broadcast indicating a first data topic desired for controlling a wellbore operation performed with respect to a well; 
 receiving a message from the mediator computing device originating from a data producer, wherein the data producer generates a data stream associated with a second data topic, and wherein the mediator computing device (i) determines that the wellbore operation controller is subscribed to the data stream of the data producer by comparing the first data topic to the second data topic, (ii) generates a data link between the wellbore operation controller and the data producer in response to determining that the wellbore operation controller is subscribed to the data stream of the data producer, and (iii) provides the message to the wellbore operation controller using the data link; 
 determining that the message is filtered or accepted; 
 in response to determining that the message is filtered, discarding the message; 
 in response to determining that the message is accepted:
 extracting data from the message; 
 processing and consuming the data; and 
 adjusting an equipment control process using the data, wherein the data comprises micro-seismic acoustic data, the wellbore operation comprises a hydraulic fracturing operation, and wherein the equipment control process comprises forming the well, stimulating the well, or producing fluid from the well. 
 
 
     
     
       6. The method of  claim 5 , wherein the data of the message is transformed into a programming language-neutral format prior to receiving the message from the mediator computing device. 
     
     
       7. The method of  claim 5 , further comprising:
 receiving an additional message from the mediator computing device originating from an additional data producer; 
 determining if the additional message is filtered or accepted; 
 if the additional message is accepted, extracting additional data from the additional message; 
 processing and consuming the additional data; and 
 adjusting the equipment control process using the data and the additional data. 
 
     
     
       8. The method of  claim 5 , further comprising:
 communicatively connecting with the mediator computing device in a pluggable manner without recompiling a base stack of a stack data structure of the mediator computing device. 
 
     
     
       9. A non-transitory computer-readable medium that includes instructions that are executable by a processing device to perform operations controlling equipment associated with a wellbore, the operations comprising:
 transmitting, via a wellbore operation controller and to a mediator computing device, a first broadcast indicating a first data topic desired for controlling a wellbore operation performed with respect to a well; 
 receiving a message from the mediator computing device originating from a data producer, wherein the data producer generates a data stream associated with a second data topic, and wherein the mediator computing device (i) determines that the wellbore operation controller is subscribed to the data stream of the data producer by comparing the first data topic to the second data topic, (ii) generates a data link between the wellbore operation controller and the data producer in response to determining that the wellbore operation controller is subscribed to the data stream of the data producer, and (iii) provides the message to the wellbore operation controller using the data link; 
 determining that the message is filtered or accepted; 
 in response to determining that the message is accepted, extracting data from the message; 
 processing and consuming the data; and 
 adjusting an equipment control process using the data, wherein the data comprises micro-seismic acoustic data, the wellbore operation comprises a hydraulic fracturing operation, and wherein the equipment control process comprises forming the well, stimulating the well, or producing fluid from the well. 
 
     
     
       10. The non-transitory computer-readable medium of  claim 9 , wherein the data producer comprises a remote mediator computing device linked with the mediator computing device. 
     
     
       11. The non-transitory computer-readable medium of  claim 9 , the operations further comprising:
 filtering the message when a third data topic from a message header of the message does not match the first data topic of the first broadcast. 
 
     
     
       12. The non-transitory computer-readable medium of  claim 9 , the operations further comprising:
 communicatively connecting with the mediator computing device in a pluggable manner without recompiling a base stack of a stack data structure of the mediator computing device. 
 
     
     
       13. The non-transitory computer-readable medium of  claim 9 , the operations further comprising:
 receiving an additional message from the mediator computing device originating from an additional data producer; 
 determining if the additional message is filtered or accepted; 
 if the additional message is accepted, extracting additional data from the additional message; 
 processing and consuming the additional data; and 
 adjusting the equipment control process using the data and the additional data.