Data services platform for managing data processing models and real-time data from well systems

1 . A method for implementing a data services platform for real-time data obtained from well systems, comprising:

receiving, by the data services platform, an input of a first data processing algorithm having a data processing function for processing real-time data from one or more well systems, the first data processing algorithm created using a template associated with the data services platform;

integrating, by the data services platform, the first data processing algorithm into a framework of the data services platform, the framework having a plurality of reusable data management algorithms that provide a plurality of data management functions for managing the real-time data from the one or more well systems;

receiving, by the data services platform, a configuration for the data processing function of the first data processing algorithm, the configuration including one or more parameters associated with the real-time data from at least a first well system of the one or more well systems;

configuring, by the data services platform, the plurality of reusable data management algorithms that perform the plurality of data management functions with the one or more parameters specified by the configuration associated with the first data processing algorithm; and

managing, by the data services platform, the real-time data from the first well system based on the one or more parameters.

2 . The method of claim 1 , wherein integrating the first data processing algorithm into the framework of the data services platform includes:

integrating the first data processing algorithm with the plurality of reusable data management algorithms that provide the plurality of data management functions, the plurality of reusable data management algorithms accessible by the first data processing algorithm during an execution of the first data processing algorithm and the processing of the real-time data from the first well system.

3 . The method of claim 2 , wherein the plurality of reusable data management algorithms include a plurality of prebuilt and reusable algorithms that are ancillary to the first data processing algorithm and perform the plurality of data management functions for the first data processing algorithm, the data management functions include at least one of:

input and output (I/O) data management functions,

algorithm authentication functions,

algorithm version management functions,

algorithm test and evaluation functions,

data visualization and analysis functions, and

historical data replay functions.

4 . The method of claim 1 , wherein one of the plurality of data management functions provided by the framework of the data services platform includes an input data management function for real-time data streams from a plurality of well systems, further comprising:

deploying and enabling the first data processing algorithm that utilizes the framework of the data services platform to perform the plurality of data management functions; and

monitoring the real-time data streams from the plurality of well systems to select the real-time data from the first well system having the one or more parameters for processing by the first data processing algorithm.

5 . The method of claim 4 , wherein the plurality of data management functions provided by the framework of the data services platform include an output data management function and a data visualization and analysis function for managing output data from the first data processing algorithm, further comprising:

detecting and storing the output data from the first data processing algorithm for storing historical data; and

processing the output data for visualization and analysis of the output data.

6 . The method of claim 5 , wherein processing the output data for visualization and analysis of the output data from the first data processing algorithm includes providing alerts or notifications regarding the first well system to cause modification of well system operations or maintenance of the first well system.

7 . The method of claim 1 , wherein the plurality of data management functions provided by the framework of the data services platform include an output data management function and a historical data replay function, further comprising:

detecting and storing the output data from the first data processing algorithm for storing historical data;

receiving a request to replay historical data from a first time period; and

replaying the historical data from the first time period in the data services platform as if the historical data is real-time data.

8 . The method of claim 1 , wherein the one or more parameters included in the configuration for the first data processing algorithm includes at least one of:

a well system identifier for the first well system;

a sliding time window size for the real-time data; and

one or more well system parameters from the first well system for processing using the first data processing algorithm, the one or more well system parameters being part of the real-time data from the first well system.

9 . The method of claim 1 , wherein the data services platform is implemented in a cloud server network that is remote from the first well system or in an edge network that is local to the first well system.

10 . A non-transitory computer-readable medium including computer-executable instructions comprising:

instructions for receiving, by a data services platform, an input of a first data processing algorithm having a data processing function for processing real-time data from one or more well systems, the first data processing algorithm created using a template associated with the data services platform;

instructions for integrating, by the data services platform, the first data processing algorithm into a framework of the data services platform, the framework having a plurality of reusable data management algorithms that provide a plurality of data management functions for managing the real-time data from the one or more well systems;

instructions for receiving, by the data services platform, a configuration for the data processing function of the first data processing algorithm, the configuration including one or more parameters associated with the real-time data from at least a first well system of the one or more well systems; and

instructions for configuring, by the data services platform, the plurality of reusable data management algorithms that perform the plurality of data management functions with the one or more parameters specified by the configuration associated with the first data processing algorithm; and

instructions for managing, by the data services platform, the real-time data from the first well system based on the one or more parameters.

11 . The non-transitory computer-readable medium of claim 10 , wherein the plurality of data management functions provided by the framework of the data services platform include an output data management function and a historical data replay function, and the instructions further include:

instructions for detecting and storing the output data from the first data processing algorithm for storing historical data;

instructions for receiving a request to replay historical data from a first time period; and

instructions for replaying the historical data from the first time period in the data services platform as if the historical data is real-time data.

12 . The non-transitory computer-readable medium of claim 10 , wherein the instructions for integrating the first data processing algorithm into the framework of the data services platform further include:

instructions for integrating the first data processing algorithm with the plurality of reusable data management algorithms that provide the plurality of data management functions, the plurality of reusable data management algorithms accessible by the first data processing algorithm during an execution of the first data processing algorithm and the processing of the real-time data from the first well system.

13 . The non-transitory computer-readable medium of claim 12 , wherein the plurality of reusable data management algorithms include a plurality of prebuilt and reusable algorithms that are ancillary to the first data processing algorithm and perform the plurality of data management functions for the first data processing algorithm, the data management functions include at least one of:

input and output (I/O) data management functions,

algorithm authentication functions,

algorithm version management functions,

algorithm test and evaluation functions,

data visualization and analysis functions, and

historical data replay functions.

14 . The non-transitory computer-readable medium of claim 10 , wherein one of the plurality of data management functions provided by the framework of the data services platform includes an input data management function for real-time data streams from a plurality of well systems, and the instructions further include:

instructions for deploying and enabling the first data processing algorithm that utilizes the framework of the data services platform to perform the plurality of data management functions; and

instructions for monitoring the real-time data streams from the plurality of well systems to select the real-time data from the first well system having the one or more parameters for processing by the first data processing algorithm.

15 . The non-transitory computer-readable medium of claim 14 , wherein the plurality of data management functions provided by the framework of the data services platform include an output data management function and a data visualization and analysis function for managing output data from the first data processing algorithm, and the instructions further include:

instructions for detecting and storing the output data from the first data processing algorithm for storing historical data; and

instructions for processing the output data for visualization and analysis of the output data.

16 . A system for implementing a data services platform for real-time data obtained from well systems, comprising:

one or more processors; and

a computer-readable medium having instructions stored therein, the instructions executable by the one or more processors to cause the data services platform of the system to:

receive an input of a first data processing algorithm having a data processing function for processing real-time data from one or more well systems, the first data processing algorithm created using a template associated with the data services platform;

integrate the first data processing algorithm into a framework of the data services platform, the framework having a plurality of reusable data management algorithms that provide a plurality of data management functions for managing the real-time data from the one or more well systems;

receive a configuration for the data processing function of the first data processing algorithm, the configuration including one or more parameters associated with the real-time data from at least a first well system of the one or more well systems; and

configure the plurality of reusable data management algorithms that perform the plurality of data management functions with the one or more parameters specified by the configuration associated with the first data processing algorithm; and

manage the real-time data from the first well system based on the one or more parameters.

17 . The system of claim 16 , wherein the instructions are executable by the one or more processors to cause the system to:

integrate the first data processing algorithm with the plurality of reusable data management algorithms that provide the plurality of data management functions, the plurality of reusable data management algorithms accessible by the first data processing algorithm during an execution of the first data processing algorithm and the processing of the real-time data from the first well system.

18 . The system of claim 16 , wherein one of the plurality of data management functions provided by the framework of the data services platform includes an input data management function for real-time data streams from a plurality of well systems, and the instructions are executable by the one or more processors to cause the system to:

deploy and enable the first data processing algorithm that utilizes the framework of the data services platform to perform the plurality of data management functions; and

monitor the real-time data streams from the plurality of well systems to select the real-time data from the first well system having the one or more parameters for processing by the first data processing algorithm.

19 . The system of claim 18 , wherein the plurality of data management functions provided by the framework of the data services platform include an output data management function and a data visualization and analysis function for managing output data from the first data processing algorithm, and the instructions are executable by the one or more processors to cause the system to:

detect and store the output data from the first data processing algorithm for storing historical data; and

process the output data for visualization and analysis of the output data.