CN110968640B - Oil well data processing method and device and oil well control system - Google Patents
Oil well data processing method and device and oil well control system Download PDFInfo
- Publication number
- CN110968640B CN110968640B CN201811136731.3A CN201811136731A CN110968640B CN 110968640 B CN110968640 B CN 110968640B CN 201811136731 A CN201811136731 A CN 201811136731A CN 110968640 B CN110968640 B CN 110968640B
- Authority
- CN
- China
- Prior art keywords
- data
- oil well
- source database
- well
- data set
- 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.)
- Active
Links
Images
Landscapes
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
The invention discloses an oil well data processing method and device and an oil well control system, wherein the oil well data processing method comprises the steps of acquiring a time delay data set of an oil well from an oil well source database, and determining an influence time period consisting of earliest creation time and latest creation time of oil well data in the time delay data set; storing the oil well data in the delay data set to a target source database, and updating an oil well data list corresponding to the target source database; extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; and executing processing operation on the complete data set, obtaining a processing result, and updating a historical processing result by using the processing result. The method and the device can restore the delay data set to the target source database, determine the complete data set corresponding to the influence time period, and re-process the complete data set by the server so as to obtain an accurate processing result.
Description
Technical Field
The invention relates to the technical field of energy processing, in particular to an oil well data processing method and device and an oil well control system.
Background
The oil well control system comprises a plurality of sensors which are arranged in the oil well and are used for collecting oil well original data, a multi-stage serial monitoring system which is arranged outside the oil well and is used for obtaining the original data and processing the original data to obtain the oil well data, an oil well source database which is arranged on each monitoring system and is used for storing the oil well data, and a server which is connected with the oil well source database in each stage of monitoring system and is used for pulling and processing the oil well data from each source database.
The well data includes a creation time, which is the collection time of the raw data, as the well data is obtained from the raw data processing, in order to characterize the well characteristics at the collection time, rather than the generation time of the well data in a different source database.
Ideally, each well source database will sequentially generate well data according to the order of the creation time, so that the server sequentially pulls and processes the well data according to the order of the creation time.
However, in actual situations, due to the large number of multi-stage serial monitoring systems, serial processing (and other network faults, bandwidth sizes and other reasons) is performed between each stage of monitoring systems, so that the oil well data in each oil well source database is not generated according to the sequence of the creation time, but is in a relatively chaotic state.
For example, the first batch of raw data is acquired from 2:00, three sets of well data are acquired at 2:30,3:00,4:00, respectively, and the second batch of raw data is acquired from 2:15, three sets of well data are acquired at 2:45,3:15,4:15, respectively.
The current situation of the oil well control system is as follows: the oil well data generated in the oil well source database firstly reaches the server, and the oil well data generated in the oil well database later reaches the server, so that in actual conditions, the server sequentially acquires and processes the oil well data according to the sequence of the generation time and acquires the processing result, and does not sequentially acquire and process the oil well data according to the sequence of the creation time and acquire the processing result.
Due to the current situation of oil well data delay, the server can miss some oil well data which should be processed in the period in the process of processing the oil well data according to the period, and the accuracy of processing results obtained by the server is lower under the condition that part of the oil well data is missing.
Disclosure of Invention
The present invention has been made in view of the above problems, and it is an object of the present invention to provide a well data processing method and apparatus, well control system, which overcomes or at least partially solves the above problems.
In order to achieve the above object, the present application provides the following technical features: a method of well data processing comprising:
acquiring a time delay data set of an oil well from an oil well source database, and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the time delay data set;
storing the oil well data in the delay data set to a target source database, and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time;
extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data;
and executing processing operation on the complete data set, obtaining a processing result, and updating a historical processing result by using the processing result.
Optionally, the acquiring the time delay data set of an oil well from the oil well source database includes:
determining a current delay time period;
Acquiring a plurality of oil well data with intersection between the creation time and the current delay time period from an oil well source database;
and excluding the well data stored in the target source database from the plurality of well data, and determining the remaining well data as the time delay data set.
Optionally, the well data includes a well number, creation time, and data content;
then excluding well data from the plurality of well data that has been stored in the target source database, including:
if the well number and the creation time of one of the plurality of well data are the same as the well number and the creation time of one of the well data in the target source database, determining that the target source database has stored the well data;
the well data is excluded from the plurality of well data.
Optionally, in the case of acquiring a time-lapse data set of an oil well from the oil well source database, the method further includes:
acquiring an incremental dataset of the well from a well source database;
storing the incremental data set to the target source database, and updating an oil well data list corresponding to the target source database, so that the oil well data list arranges oil well data in the target source database according to the sequence of creation time;
Then after the historical processing result is updated by the processing result, the method further comprises:
and performing a processing operation on the incremental dataset to obtain and store a processing result so that the processing result is used as a historical processing result in the next cycle to be updated by the processing result obtained after the processing operation is performed on the complete dataset.
Optionally, the acquiring the incremental dataset of the oil well from the oil well source database includes:
determining a current incremental time period;
acquiring a plurality of well data with intersections of the creation time and the current increment time period from a well source database;
the plurality of well data is determined as the incremental dataset.
Optionally, the determining the current incremental time period includes:
determining the ending time point of the last increment time period of the current increment time period as the starting time point of the current increment time period;
increasing a first preset value on the basis of the starting time point of the current increment time period, and determining the starting time point of the current increment time period as the ending time point of the current increment time period;
wherein the first preset value represents an execution period of the server.
Optionally, the determining the current delay period includes:
Determining the starting time point of the current increment time period as the ending time point of the current delay time period;
subtracting a second preset value from the ending time point of the current delay time period to determine the starting time point of the current delay time period;
the second preset value is a preset backtracking time length of the delay data.
An oil well data processing apparatus comprising:
determining an influence time period unit, which is used for acquiring a time delay data set of an oil well from an oil well source database and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the time delay data set;
the time delay data set storage unit is used for storing the oil well data in the time delay data set to a target source database and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time;
a complete data set unit for extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data;
And the processing unit is used for executing processing operation on the complete data set, obtaining a processing result and updating the historical processing result by using the processing result.
A well data processing system comprising:
the sensors are arranged in the oil well and used for collecting the original data of the oil well;
the system comprises a multi-stage serial monitoring system which is arranged outside an oil well and used for acquiring original data and processing the original data to acquire the oil well data, and each monitoring system is provided with an oil well source database for storing the oil well data;
the server is connected with the oil well source database in each level of monitoring system;
a target source database connected with the server and a target result database;
the server is used for acquiring a delay data set of an oil well from an oil well source database and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the delay data set; storing the oil well data in the delay data set to a target source database, and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time; extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data; and executing processing operation on the complete data set, obtaining a processing result, and updating a historical processing result in a target result database by using the processing result.
An apparatus comprising a processor, a memory, and a program stored on the memory and executable on the processor, the processor implementing the steps of when executing the program:
acquiring a time delay data set of an oil well from an oil well source database, and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the time delay data set;
storing the oil well data in the delay data set to a target source database, and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time;
extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data;
and executing processing operation on the complete data set, obtaining a processing result, and updating a historical processing result by using the processing result.
By means of the technical scheme, the oil well data processing method determines the delay data set based on the delay time period, thinks of receiving the influence time period influenced by the delay data set, and then stores the delay data set into the target source database so as to restore the delay data set to the target source database, and determines the complete data set corresponding to the influence time period.
After having the complete data set, the server will reprocess the complete data set to obtain an accurate processing result, and update the historical processing result with the accurate processing result, so that the processing result tends to be more accurate.
The foregoing description is only an overview of the present invention, and is intended to be implemented in accordance with the teachings of the present invention in order that the same may be more clearly understood and to make the same and other objects, features and advantages of the present invention more readily apparent.
Drawings
Various other advantages and benefits will become apparent to those of ordinary skill in the art upon reading the following detailed description of the preferred embodiments. The drawings are only for purposes of illustrating the preferred embodiments and are not to be construed as limiting the invention. Also, like reference numerals are used to designate like parts throughout the figures. In the drawings:
FIG. 1 shows a schematic diagram of a well control system;
FIG. 2 shows a flow chart of a well data processing method;
fig. 3 shows a schematic diagram of the structure of the well data processing apparatus.
Detailed Description
Exemplary embodiments of the present disclosure will be described in more detail below with reference to the accompanying drawings. While exemplary embodiments of the present disclosure are shown in the drawings, it should be understood that the present disclosure may be embodied in various forms and should not be limited to the embodiments set forth herein. Rather, these embodiments are provided so that this disclosure will be thorough and complete, and will fully convey the scope of the disclosure to those skilled in the art.
The present application provides an oil well control system, see fig. 1, comprising:
a plurality of sensors 100 disposed within the well for acquiring raw data from the well.
A multi-stage serial monitoring system 200 disposed outside the well for acquiring raw data and processing the raw data to obtain well data, each monitoring system being provided with a well source database for storing well data.
And the server 300 is connected with the oil well source databases in each level of monitoring system and is used for pulling and processing oil well data from each source database and obtaining processing results.
A target source database 400 connected to the server 300 for storing well data obtained from the respective source databases.
A target result database 500 connected to the server 300 for storing the processing results obtained after processing the well data.
The user terminal 600 is configured to send a query request to the server, so as to receive a query result corresponding to the query request, which is fed back by the server.
Since the treatment process of the present application is consistent for each well, the present application will be described in detail in terms of wells. The following describes the various parts of the well control system:
a number of sensors 100 are installed in the well, which may include temperature sensors, depth sensors, metering sensors, etc. as needed in some wells. The number and types of the sensors may be determined according to actual situations, and are not limited herein.
Taking a multi-stage serial monitoring system as an example of a three-stage serial monitoring system, the three monitoring systems are respectively a monitoring system 1, a monitoring system 2 and a monitoring system 3, and the three monitoring systems are connected in series. The monitoring system 1 is provided with an oil well source database 1, the monitoring system 2 is provided with an oil well source database 2, and the monitoring system 3 is provided with an oil well source database 3.
The monitoring system 1 acquires raw data from a plurality of sensors, a plurality of oil well data 1 are acquired after a first processing operation is performed on the raw data, and a source database 1 of the monitoring system 1 is used for storing the plurality of oil well data 1.
The monitoring system 2 obtains a part of the raw data and/or a part of the well data 1 from the source database 1, and obtains a plurality of well data 2 after performing a second processing operation on the part of the raw data and/or the part of the well data 1, and the source database 2 of the monitoring system 1 is used for storing the plurality of well data 2.
The monitoring system 3 obtains a part of the raw data and/or a part of the well data 2 from the source database 2, and obtains a plurality of well data 3 after performing a third processing operation on the part of the raw data and/or the part of the well data 2, and the source database 3 of the monitoring system 3 is used for storing the plurality of well data 3.
Continuing the above example, where the well control system includes three monitoring systems, the server 300 is connected to the well source databases of the 3 monitoring systems to pull and process well data from the well source databases.
In order to distinguish between different well data, each well data includes a well number (hereinafter abbreviated as a well number), creation time, and data content; to characterize the well characteristics when the raw data was collected, the creation time of the well data is the collection time of the raw data, rather than the generation time of the well data in a different source database.
It should be noted that, since several sensors periodically acquire raw data and send the raw data to the monitoring system 1, the multi-stage serial monitoring system also periodically performs a processing procedure, and stores the oil well data to respective oil well source databases. Thus, well data created differently is stored in each well source database.
In this application, the server periodically executes the following process, where the execution period may be set to a first preset value, and the first preset value may be adjusted based on the actual situation, which is not limited. The following describes the execution process of the server in detail, taking one cycle as an example.
The application provides an oil well data processing method which is applied to a server shown in fig. 1. Referring to fig. 2, the well data processing method comprises the steps of:
step S201: the server determines a current delta time period and a current delay time period.
Because the data between the server and the well source database is not synchronized, the server will typically process well data in the well source database for a period of time that is later than the current time (a period of time may be one hour or two, and is not limiting of the present application). Assuming that the current time of the server is 16:00, the server will typically process well data in the wellhead database around 15:00.
The server determining the current delta time period comprises: determining the ending time point of the last increment time period as the starting time point of the current increment time period; and adding a first preset value on the basis of the starting time point of the current increment time period, and determining the starting time point of the current increment time period as the ending time point of the current increment time period. Wherein the first preset value represents an execution period of the server.
Assuming that the last increment period end time point is a and the first preset value is set to a, the current increment period is [ a, a+a ]. Wherein the first preset value a represents the execution period of the server and at the same time represents the update frequency of the source database, for example 20 minutes.
The server determining the current delay period includes: determining the starting time point of the current increment time period as the ending time point of the current delay time period; subtracting a second preset value from the ending time point of the current delay time period to determine the starting time point of the current delay time period; the second preset value is a preset backtracking time length of the delay data.
Continuing the above assumption, at the start time point of the current increment period, a, the second preset value is set to b, and the current delay period is [ a-b, a ]. The second preset value is set for monitoring the delay data and setting the backtracking time length of the delay data. For example 5 hours, the size with respect to the length of the backtracking time can be adjusted. Step S202: the server obtains an incremental dataset for a well from the well source database and obtains a supplemental dataset for the well from the well source database.
For incremental data sets:
s11: after determining the incremental time period, the server may obtain a plurality of well data from a well source database having an intersection of creation time and the current incremental time period.
S12: the server determines the plurality of well data as the incremental dataset.
For the supplemental data set:
s21: after determining the current delay time period, the server acquires a plurality of oil well data with intersection between the creation time and the current delay time period from an oil well source database.
Step S22: the server determines the plurality of well data as the supplemental data set. The supplemental data set contains delay data, also has non-delay data, and subsequently requires extraction of the delay data set from the supplemental data set.
The steps S201 to S202 are processes in which the server pulls the well data from the well source database, and thus the server can process the data by the first process. The second process may be employed for processing subsequent to the server processing of the well.
Step S203: and the server stores the incremental data set into a target source database and updates an oil well data list corresponding to the target source database.
The purpose of updating the oil well data list corresponding to the target source database is as follows: and arranging the oil well data in the target source database according to the sequence of the creation time by the oil well data list. Of course, this step may also temporarily not need to update the well data list, but update the well data list together at step S206, thereby saving the operation time.
Step S204: and excluding the oil well data stored in the target source database from a plurality of oil well data in the supplementary data set, and determining the remaining oil well data as the time delay data set.
Because the time delay period is relatively long, the plurality of well data is not depleted of non-delayed well data, which has been stored in the target source database in the previous or previous cycle.
To avoid duplication of storage, well data that has been stored in the target source database may be excluded from the plurality of well data, and then the remaining well data is determined as the time-lapse data set.
Step S205: the server determines an influence period consisting of an earliest creation time and a latest creation time of the well data in the time-lapse dataset.
The processing result of the corresponding time period of the missing well data is affected after the missing well data, and for this purpose, the server may determine the affected time period and reprocess the well data corresponding to the time period so as to obtain an accurate processing result.
The time delay data set includes a plurality of time delayed well data, the well data including a creation time. After the server ranks the creation time of the oil well data in the delay data set, the latest creation time and the earliest creation time can be obtained.
The earliest creation time and the latest creation time may constitute an influence period. For example, the earliest creation time is 12:00, and the latest creation time is 14: in the case of 00, the influence period is [12:00 to 14:00].
Step S206: and storing the oil well data in the delay data set to the target source database, and updating an oil well data list corresponding to the target source database.
The purpose of updating the oil well data list corresponding to the target source database is as follows: and arranging the oil well data in the target source database according to the sequence of the creation time by the oil well data list.
In order to facilitate subsequent processing, after the delay data set is stored in the target source database, the oil well data list is updated so that the oil well data list is ordered according to the order of the creation time, and the subsequent realization server can acquire the oil well data according to the order of the creation time.
Step S207: the server extracts a plurality of oil well data with intersections of the creation time and the influence time period from the target source database, wherein the plurality of oil well data form a complete data set; wherein the complete data set includes delayed well data and undelayed well data.
It will be appreciated that after storing the delayed data set in the target source database, the data in the target source database contains both missing well data (delayed data) and non-delayed well data, so the data in the target source database affecting the time period should be complete during the present period (the next period may have the delayed data coming, so it is not truly complete here, but rather complete relative to the present period).
The server may determine an earliest creation time of the influence time period from the well data list, and from a latest creation time of the definite sound time period in the well data list, then extract all well data between the earliest creation time and the latest creation time of the well data list.
Step S208: and the server executes processing operation on the complete data set and obtains a processing result.
The server processes the complete data sets one by one according to the order of the creation time of the oil well data in the complete data sets from small to large, and processing results are obtained after all the oil well data in the complete data sets are processed.
The processing result may have multiple types of parameters, and the server may process according to preset rules corresponding to the different types of parameters. For ease of understanding, the preset rules are illustrated below:
preset rule 1: the oil well is continuously not stopped, and the preset parameter 1 is corresponding to: continuous non-stop working time.
And acquiring the oil well data in the complete data set one by one, updating the continuous non-stop working time if one oil well data is in a normal state, and updating the non-stop working time if one oil well data is in an abnormal state.
Preset rule 2: more than three alarm states appear continuously, corresponding to preset parameter 2: and generating alarm information.
And if the complete data set has alarm states of three continuous oil well data, generating alarm information.
Step S209: the server updates the historical processing results in the target result database with the processing results.
It will be appreciated that the current delay period [ a-b, a ] is a period that has been processed by the incremental period [ a-a, a ] of the previous period, so the processing result corresponding to the period [ a-a, a ] has been calculated by the server in the previous period, and is referred to as a history processing result for convenience of distinction.
It will be appreciated that processing results obtained by the server processing the complete data set are more accurate than historical processing results obtained by the time period [ a-a, a ] in which the time-lapse data set was missing. Thus, the server updates the historical processing results with the processing results.
Step S210: the server performs processing operations on the incremental dataset and obtains processing results, and updates historical processing results in the target result database with the processing results.
The time period of the delay data set is [ A-b, A ], the time period bit of the increment data set is [ A, A+a ], and the time period of the delay data set is positioned before the time period of the increment data set, so that the server processes the delay data set first and then processes the increment data set so as to process the subsequent increment data set on the premise of ensuring accurate previous processing results.
It will be appreciated that the processing results in the target results database include the well number, time and data content.
Step S211: the server receives the query request input by the user terminal and searches the query result corresponding to the query request in the target result database.
The query request includes a well number; the well number and time period are already mature techniques with respect to the query request and will not be described in detail herein.
Step S212: the server feeds back the query result to the user terminal so that the user terminal can display the query result.
As is clear from the above technical features, the present application cannot change the generation time of the well data in each source database, nor can it change the process of pulling the well data from the well source database by the server according to the generation time, which is a part of the well monitoring system that cannot be changed temporarily.
For this purpose, the present application determines a delay data set based on the delay time period, and thinks of an influence time period for which the influence of the delay data set is received, and then stores the delay data set to the target source database so as to restore the delay data set to the target source database, and determines a complete data set corresponding to the influence time period.
After having the complete data set, the server will reprocess the complete data set to obtain an accurate processing result, and update the historical processing result with the accurate processing result, so that the processing result tends to be more accurate.
Referring to fig. 3, the present application provides an oil well data processing apparatus, comprising:
a determining-influence time period unit 31 for acquiring a time-lapse data set of an oil well from an oil well source database, and determining an influence time period composed of an earliest creation time and a latest creation time of oil well data in the time-lapse data set;
a delay data set storing unit 32, configured to store the oil well data in the delay data set to a target source database, and update an oil well data list corresponding to the target source database, so that the oil well data list arranges the oil well data in the target source database according to the sequence of creation time;
a complete data set unit 33 for extracting, from the target source database, a plurality of well data having intersections of creation times and the influence time periods, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data;
a processing unit 34 for performing processing operations on the complete data set and obtaining processing results, and updating historical processing results with the processing results.
Wherein determining the time delay data set for an oil well from the oil well source database in the influence period unit 31 comprises: determining a current delay time period; acquiring a plurality of oil well data with intersection between the creation time and the current delay time period from an oil well source database; and excluding the well data stored in the target source database from the plurality of well data, and determining the remaining well data as the time delay data set.
The oil well data comprises a well number, creation time and data content; then excluding well data from the plurality of well data that has been stored in the target source database, including:
if the well number and the creation time of one of the plurality of well data are the same as the well number and the creation time of one of the well data in the target source database, determining that the target source database has stored the well data; the well data is excluded from the plurality of well data.
The oil well data processing device further comprises:
an incremental dataset acquisition unit 35 for acquiring an incremental dataset of an oil well from the oil well source database in the case of acquiring a delayed dataset of the oil well from the oil well source database;
a delta data set storage unit 36, configured to store the delta data set in the target source database, and update an oil well data list corresponding to the target source database, so that the oil well data list arranges oil well data in the target source database according to the sequence of creation time;
then after the historical processing result is updated by the processing result, the method further comprises:
performing a processing operation on the incremental dataset to obtain and store a processing result so that the processing result is used as a historical processing result in a next cycle to be updated by a processing result obtained after performing the processing operation on the complete dataset
The processing unit 34 is further configured to perform a processing operation on the incremental dataset, obtain and store a processing result so that the processing result is used as a historical processing result in a next cycle to be updated by a processing result obtained after the processing operation is performed on the complete dataset.
Wherein the acquiring the incremental dataset of the well from the well source database comprises: determining a current incremental time period; acquiring a plurality of well data with intersections of the creation time and the current increment time period from a well source database; the plurality of well data is determined as the incremental dataset.
The determining the current incremental time period includes: determining the ending time point of the last increment time period of the current increment time period as the starting time point of the current increment time period; increasing a first preset value on the basis of the starting time point of the current increment time period, and determining the starting time point of the current increment time period as the ending time point of the current increment time period; wherein the first preset value represents an execution period of the server.
Wherein the determining the current delay time period includes: determining the starting time point of the current increment time period as the ending time point of the current delay time period; subtracting a second preset value from the ending time point of the current delay time period to determine the starting time point of the current delay time period; the second preset value is a preset backtracking time length of the delay data.
The oil well data processing device comprises a processor and a memory, wherein the above-mentioned unit 31 for determining the influence time period, the unit 32 for storing the time delay data set, the unit 33 for composing the complete data set, the processing unit 34, the unit 35 for obtaining the increment data set, the unit 36 for storing the increment data set and the like are all stored in the memory as program units, and the processor executes the above-mentioned program units stored in the memory to realize the corresponding functions.
The processor includes a kernel, and the kernel fetches the corresponding program unit from the memory. The kernel can be provided with one or more than one kernel, and the processing result tends to be more accurate by adjusting the kernel parameters.
The memory may include volatile memory, random Access Memory (RAM), and/or nonvolatile memory, such as Read Only Memory (ROM) or flash memory (flash RAM), among other forms in computer readable media, the memory including at least one memory chip.
The embodiment of the invention provides a storage medium, and a program is stored on the storage medium, and the program is executed by a processor to realize the oil well data processing method.
The embodiment of the invention provides a processor which is used for running a program, wherein the method for processing oil well data is executed when the program runs.
The embodiment of the invention provides equipment, which comprises a processor, a memory and a program stored in the memory and capable of running on the processor, wherein the processor realizes the following steps when executing the program:
acquiring a time delay data set of an oil well from an oil well source database, and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the time delay data set;
storing the oil well data in the delay data set to a target source database, and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time;
extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data;
and executing processing operation on the complete data set, obtaining a processing result, and updating a historical processing result by using the processing result.
Optionally, the acquiring the time delay data set of an oil well from the oil well source database includes:
Determining a current delay time period;
acquiring a plurality of oil well data with intersection between the creation time and the current delay time period from an oil well source database;
and excluding the well data stored in the target source database from the plurality of well data, and determining the remaining well data as the time delay data set.
Optionally, the well data includes a well number, creation time, and data content;
then excluding well data from the plurality of well data that has been stored in the target source database, including:
if the well number and the creation time of one of the plurality of well data are the same as the well number and the creation time of one of the well data in the target source database, determining that the target source database has stored the well data;
the well data is excluded from the plurality of well data.
Optionally, in the case of acquiring a time-lapse data set of an oil well from the oil well source database, the method further includes:
acquiring an incremental dataset of the well from a well source database;
storing the incremental data set to the target source database, and updating an oil well data list corresponding to the target source database, so that the oil well data list arranges oil well data in the target source database according to the sequence of creation time;
Then after the historical processing result is updated by the processing result, the method further comprises:
and performing a processing operation on the incremental dataset to obtain and store a processing result so that the processing result is used as a historical processing result in the next cycle to be updated by the processing result obtained after the processing operation is performed on the complete dataset.
Optionally, the acquiring the incremental dataset of the oil well from the oil well source database includes:
determining a current incremental time period;
acquiring a plurality of well data with intersections of the creation time and the current increment time period from a well source database;
the plurality of well data is determined as the incremental dataset.
Optionally, the determining the current incremental time period includes:
determining the ending time point of the last increment time period of the current increment time period as the starting time point of the current increment time period;
increasing a first preset value on the basis of the starting time point of the current increment time period, and determining the starting time point of the current increment time period as the ending time point of the current increment time period;
wherein the first preset value represents an execution period of the server.
Optionally, the determining the current delay period includes:
Determining the starting time point of the current increment time period as the ending time point of the current delay time period;
subtracting a second preset value from the ending time point of the current delay time period to determine the starting time point of the current delay time period;
the second preset value is a preset backtracking time length of the delay data. The device herein may be a server, PC, PAD, cell phone, etc.
The present application also provides a computer program product adapted to perform, when executed on a data processing device, a program initialized with the method steps of:
acquiring a time delay data set of an oil well from an oil well source database, and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the time delay data set;
storing the oil well data in the delay data set to a target source database, and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time;
extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data;
And executing processing operation on the complete data set, obtaining a processing result, and updating a historical processing result by using the processing result.
Optionally, the acquiring the time delay data set of an oil well from the oil well source database includes:
determining a current delay time period;
acquiring a plurality of oil well data with intersection between the creation time and the current delay time period from an oil well source database;
and excluding the well data stored in the target source database from the plurality of well data, and determining the remaining well data as the time delay data set.
Optionally, the well data includes a well number, creation time, and data content;
then excluding well data from the plurality of well data that has been stored in the target source database, including:
if the well number and the creation time of one of the plurality of well data are the same as the well number and the creation time of one of the well data in the target source database, determining that the target source database has stored the well data;
the well data is excluded from the plurality of well data.
Optionally, in the case of acquiring a time-lapse data set of an oil well from the oil well source database, the method further includes:
Acquiring an incremental dataset of the well from a well source database;
storing the incremental data set to the target source database, and updating an oil well data list corresponding to the target source database, so that the oil well data list arranges oil well data in the target source database according to the sequence of creation time;
then after the historical processing result is updated by the processing result, the method further comprises:
and performing a processing operation on the incremental dataset to obtain and store a processing result so that the processing result is used as a historical processing result in the next cycle to be updated by the processing result obtained after the processing operation is performed on the complete dataset.
Optionally, the acquiring the incremental dataset of the oil well from the oil well source database includes:
determining a current incremental time period;
acquiring a plurality of well data with intersections of the creation time and the current increment time period from a well source database;
the plurality of well data is determined as the incremental dataset.
Optionally, the determining the current incremental time period includes:
determining the ending time point of the last increment time period of the current increment time period as the starting time point of the current increment time period;
Increasing a first preset value on the basis of the starting time point of the current increment time period, and determining the starting time point of the current increment time period as the ending time point of the current increment time period;
wherein the first preset value represents an execution period of the server.
Optionally, the determining the current delay period includes:
determining the starting time point of the current increment time period as the ending time point of the current delay time period;
subtracting a second preset value from the ending time point of the current delay time period to determine the starting time point of the current delay time period;
the second preset value is a preset backtracking time length of the delay data.
It will be appreciated by those skilled in the art that embodiments of the present application may be provided as a method, system, or computer program product. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, and the like) having computer-usable program code embodied therein.
The present application is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems) and computer program products according to embodiments of the application. It will be understood that each flow and/or block of the flowchart illustrations and/or block diagrams, and combinations of flows and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including instruction means which implement the function specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be loaded onto a computer or other programmable data processing apparatus to cause a series of operational steps to be performed on the computer or other programmable apparatus to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide steps for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
In one typical configuration, a computing device includes one or more processors (CPUs), input/output interfaces, network interfaces, and memory.
The memory may include volatile memory in a computer-readable medium, random Access Memory (RAM) and/or nonvolatile memory, etc., such as Read Only Memory (ROM) or flash memory (flashRAM). Memory is an example of a computer-readable medium.
Computer readable media, including both non-transitory and non-transitory, removable and non-removable media, may implement information storage by any method or technology. The information may be computer readable instructions, data structures, modules of a program, or other data. Examples of storage media for a computer include, but are not limited to, phase change memory (PRAM), static Random Access Memory (SRAM), dynamic Random Access Memory (DRAM), other types of Random Access Memory (RAM), read Only Memory (ROM), electrically Erasable Programmable Read Only Memory (EEPROM), flash memory or other memory technology, compact disc read only memory (CD-ROM), digital Versatile Discs (DVD) or other optical storage, magnetic cassettes, magnetic tape magnetic disk storage or other magnetic storage devices, or any other non-transmission medium, which can be used to store information that can be accessed by a computing device. Computer-readable media, as defined herein, does not include transitory computer-readable media (transmission media), such as modulated data signals and carrier waves.
It should also be noted that the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrase "comprising one … …" does not exclude the presence of other like elements in a process, method, article or apparatus that comprises an element.
It will be appreciated by those skilled in the art that embodiments of the present application may be provided as a method, system, or computer program product. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, and the like) having computer-usable program code embodied therein.
The foregoing is merely exemplary of the present application and is not intended to limit the present application. Various modifications and changes may be made to the present application by those skilled in the art. Any modifications, equivalent substitutions, improvements, etc. which are within the spirit and principles of the present application are intended to be included within the scope of the claims of the present application.
Claims (9)
1. A method of well data processing comprising:
acquiring a time delay data set of an oil well from an oil well source database, and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the time delay data set;
storing the oil well data in the delay data set to a target source database, and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time;
extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data;
executing processing operation on the complete data set, obtaining a processing result, and updating a historical processing result by using the processing result;
wherein, in the case of acquiring a time delay data set of an oil well from an oil well source database, further comprising:
acquiring an incremental dataset of the well from a well source database;
storing the incremental data set to the target source database, and updating an oil well data list corresponding to the target source database, so that the oil well data list arranges oil well data in the target source database according to the sequence of creation time;
Then after the historical processing result is updated by the processing result, the method further comprises:
and performing a processing operation on the incremental dataset to obtain and store a processing result so that the processing result is used as a historical processing result in the next cycle to be updated by the processing result obtained after the processing operation is performed on the complete dataset.
2. The method of claim 1, wherein said retrieving a well delay data set from a well source database comprises:
determining a current delay time period;
acquiring a plurality of oil well data with intersection between the creation time and the current delay time period from an oil well source database;
and excluding the well data stored in the target source database from the plurality of well data, and determining the remaining well data as the time delay data set.
3. The method of claim 2, wherein the well data comprises a well number, a creation time, and data content;
then excluding well data from the plurality of well data that has been stored in the target source database, including:
if the well number and the creation time of one of the plurality of well data are the same as the well number and the creation time of one of the well data in the target source database, determining that the target source database has stored the well data;
The well data is excluded from the plurality of well data.
4. The method of claim 1, wherein the acquiring the incremental dataset of the well from the well source database comprises:
determining a current incremental time period;
acquiring a plurality of well data with intersections of the creation time and the current increment time period from a well source database;
the plurality of well data is determined as the incremental dataset.
5. The method of claim 4, wherein the determining the current incremental time period comprises:
determining the ending time point of the last increment time period of the current increment time period as the starting time point of the current increment time period;
increasing a first preset value on the basis of the starting time point of the current increment time period, and determining the starting time point of the current increment time period as the ending time point of the current increment time period;
wherein the first preset value represents an execution period of the server.
6. The method of claim 5, wherein determining the current delay period comprises:
determining the starting time point of the current increment time period as the ending time point of the current delay time period;
subtracting a second preset value from the ending time point of the current delay time period to determine the starting time point of the current delay time period;
The second preset value is a preset backtracking time length of the delay data.
7. An oil well data processing apparatus, comprising:
determining an influence time period unit, which is used for acquiring a time delay data set of an oil well from an oil well source database and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the time delay data set;
the time delay data set storage unit is used for storing the oil well data in the time delay data set to a target source database and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time;
a complete data set unit for extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data;
the processing unit is used for executing processing operation on the complete data set, obtaining a processing result and updating a historical processing result by utilizing the processing result;
The incremental data set acquisition unit is used for acquiring the incremental data set of the oil well from the oil well source database under the condition that the delay data set of the oil well is acquired from the oil well source database;
the incremental data set storage unit is used for storing the incremental data set to the target source database and updating an oil well data list corresponding to the target source database so that the oil well data list arranges oil well data in the target source database according to the sequence of creation time;
the processing unit is further configured to perform a processing operation on the incremental dataset to obtain and store a processing result so that the processing result is used as a historical processing result in a next cycle to be updated by a processing result obtained after the processing operation is performed on the complete dataset.
8. An oil well data processing system, comprising:
the sensors are arranged in the oil well and used for collecting the original data of the oil well;
the system comprises a multi-stage serial monitoring system which is arranged outside an oil well and used for acquiring original data and processing the original data to acquire the oil well data, and each monitoring system is provided with an oil well source database for storing the oil well data;
the server is connected with the oil well source database in each level of monitoring system;
A target source database connected with the server and a target result database;
the server is used for acquiring a delay data set of an oil well from an oil well source database and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the delay data set; storing the oil well data in the delay data set to a target source database, and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time; extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data; executing processing operation on the complete data set, obtaining a processing result, and updating a historical processing result in a target result database by using the processing result; wherein, in the case of acquiring a time delay data set of an oil well from an oil well source database, further comprising: acquiring an incremental dataset of the well from a well source database; storing the incremental data set to the target source database, and updating an oil well data list corresponding to the target source database, so that the oil well data list arranges oil well data in the target source database according to the sequence of creation time; then after the historical processing result is updated by the processing result, the method further comprises: and performing a processing operation on the incremental dataset to obtain and store a processing result so that the processing result is used as a historical processing result in the next cycle to be updated by the processing result obtained after the processing operation is performed on the complete dataset.
9. An apparatus comprising a processor, a memory, and a program stored on the memory and executable on the processor, the processor implementing the steps of when executing the program:
acquiring a time delay data set of an oil well from an oil well source database, and determining an influence time period consisting of the earliest creation time and the latest creation time of oil well data in the time delay data set;
storing the oil well data in the delay data set to a target source database, and updating an oil well data list corresponding to the target source database so that the oil well data list arranges the oil well data in the target source database according to the sequence of the creation time;
extracting a plurality of well data having intersections of creation time and the influence time period from the target source database, the plurality of well data constituting a complete data set; wherein the complete data set comprises delayed well data and undelayed well data;
executing processing operation on the complete data set, obtaining a processing result, and updating a historical processing result by using the processing result;
wherein, in the case of acquiring a time delay data set of an oil well from an oil well source database, further comprising:
Acquiring an incremental dataset of the well from a well source database;
storing the incremental data set to the target source database, and updating an oil well data list corresponding to the target source database, so that the oil well data list arranges oil well data in the target source database according to the sequence of creation time;
then after the historical processing result is updated by the processing result, the method further comprises:
and performing a processing operation on the incremental dataset to obtain and store a processing result so that the processing result is used as a historical processing result in the next cycle to be updated by the processing result obtained after the processing operation is performed on the complete dataset.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811136731.3A CN110968640B (en) | 2018-09-28 | 2018-09-28 | Oil well data processing method and device and oil well control system |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201811136731.3A CN110968640B (en) | 2018-09-28 | 2018-09-28 | Oil well data processing method and device and oil well control system |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN110968640A CN110968640A (en) | 2020-04-07 |
| CN110968640B true CN110968640B (en) | 2023-05-23 |
Family
ID=70026608
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201811136731.3A Active CN110968640B (en) | 2018-09-28 | 2018-09-28 | Oil well data processing method and device and oil well control system |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN110968640B (en) |
Families Citing this family (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN115049515B (en) * | 2022-04-28 | 2024-06-11 | 中国石油大学(华东) | Method and device for establishing oil well yield increase measure sample database and plate map |
Family Cites Families (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN106909598B (en) * | 2016-07-01 | 2020-10-13 | 阿里巴巴集团控股有限公司 | Processing method, device and system for guaranteeing consistency of calculation data |
| US10891263B2 (en) * | 2016-12-09 | 2021-01-12 | Salesforce.Com, Inc. | Systems and methods for providing database updates for data visualization |
| CN107092637B (en) * | 2017-02-16 | 2020-01-31 | 北京星选科技有限公司 | Data processing method and device |
| CN107402963B (en) * | 2017-06-20 | 2020-10-02 | 阿里巴巴集团控股有限公司 | Search data construction method, incremental data pushing device and equipment |
| CN108052567A (en) * | 2017-12-06 | 2018-05-18 | 吉旗（成都）科技有限公司 | A kind of method that increment caches displaying with pulling time series data and exhaustive |
-
2018
- 2018-09-28 CN CN201811136731.3A patent/CN110968640B/en active Active
Also Published As
| Publication number | Publication date |
|---|---|
| CN110968640A (en) | 2020-04-07 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111078488B (en) | Data acquisition method, device, storage medium and system | |
| CN108197181B (en) | Compression storage method of time sequence data, electronic equipment and storage medium | |
| CN112487083B (en) | Data verification method and device | |
| CN109376196B (en) | Method and device for batch synchronization of redo logs | |
| WO2012020456A1 (en) | Time-series data processing apparatus and method thereof | |
| US20110113009A1 (en) | Outlier data point detection | |
| CN110968640B (en) | Oil well data processing method and device and oil well control system | |
| CN106648839B (en) | Data processing method and device | |
| CN105162622B (en) | A kind of storage method and system | |
| CN110928636A (en) | Virtual machine live migration method, device and equipment | |
| CN107562703B (en) | Dictionary tree reconstruction method and system | |
| CN108874304B (en) | Rule configuration method and device of cache system | |
| CN104216977A (en) | Time series data search method and device | |
| JP2016126596A (en) | Difference learning management program, difference learning management device, and difference learning management method | |
| CN115599793B (en) | Method, device and storage medium for updating data | |
| WO2021014436A1 (en) | Data restoration using dynamic data structure altering | |
| CN111161064A (en) | Processing method and device for blockchain transaction records | |
| CN109561126B (en) | Data synchronization method and device, storage medium and processor | |
| CN111125087A (en) | Data storage method and device | |
| CN111046003B (en) | Soil erosion factor data updating method and device and electronic equipment | |
| CN110968993A (en) | Information processing method and device, storage medium and processor | |
| CN115344538A (en) | Log processing method, device and equipment and readable storage medium | |
| CN115328736A (en) | Probe deployment method, device, equipment and storage medium | |
| CN113627148A (en) | Automatic association method and device for knowledge in knowledge base | |
| CN110019436B (en) | Data import \ export method and device and data table processing method and device |
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 |