JP6664297B2 - External database accommodation device, method and program - Google Patents

Description

  The present invention relates to an external database accommodation device, a method, and a program.

  There is a system that acquires data in an external database (hereinafter, also referred to as an external DB) used by another system at any time in response to a request and responds to the request (for example, see Non-Patent Document 1). For example, a request for certain data from a terminal is made to another system, and this system refers to an external DB and acquires the requested data from the external DB.

Yotaro Nakayama, “Realization of Virtual Data Integration Platform Using PostgreSQL”, UNISYS TECHNOLOGY REVIEW, No.111, pp.25-37, 2012.3

  The external DB does not always include data attribute information such as data generation time and data update time. Therefore, when acquiring attribute information of data, there is a problem that it is not possible to obtain all necessary information simply by acquiring data from an external DB.

  That is, when the attribute information of the data such as the data generation time and the data update time is not included in the external DB, the attribute information cannot be included in the request response.

  SUMMARY OF THE INVENTION The present invention has been made in view of the above circumstances, and an object thereof is to provide an external database accommodating apparatus capable of including attribute information of a request even when the attribute information of the external database is not included. , A method and a program.

  In order to achieve the above object, an aspect of the present invention includes the following components. That is, the external database accommodating apparatus obtains a response to a request from an external database that receives a plurality of requests that can uniquely identify the type of data to be acquired from one or more systems. And a storage processing unit and an integration processing unit. The attribute information database stores attribute information which is information related to data of a response to a request. The extraction and storage processing unit extracts first attribute information based on data of a response from the external database to the first request, and stores the first attribute information in the attribute information database. The integration processing unit responds to the first request with data obtained by integrating the response to the first request and the first attribute information.

  According to the present invention, it is possible to provide an external database accommodating apparatus, a method, and a program that can include attribute information of a data even when the attribute information of the data is not included in the external database.

FIG. 1 is a block diagram including an external database accommodation device according to an embodiment. FIG. 4 is a sequence diagram showing a method of referring to data in an internal DB. The sequence diagram including the method of referring to the data in the external DB of the external database accommodating device according to the embodiment. FIG. 5 is a sequence diagram including a method in a case where there is no request for a certain period or more of the external database accommodating apparatus according to the embodiment.

Hereinafter, an external database accommodating apparatus, method, and program according to an embodiment of the present invention will be described with reference to the drawings. In the following embodiments, the same operation is performed for the parts with the same numbers, and the overlapping description will be omitted.
The external database accommodation device according to the embodiment will be described with reference to FIG.
The external database accommodating device of the present embodiment includes a data integration processing unit 101, an attribute information extraction and storage processing unit 102, an attribute information storage database 103, and a data presence monitoring processing unit 104. Hereinafter, the database is abbreviated as DB. In addition, as devices related to the external database accommodating device of the present embodiment, there are the systems 1 to N that access the request reception database, the external DB system common API 111, and the external DB 112. The systems 1 to N include request accepting units 121-1 to 121-N, request target DB determining units 122-1 to 122-N, and internal DBs 123-1 to 123-N, respectively.

  In the present embodiment, the request and the data are based on at least one of the following two conditions. (Condition 1) The request can uniquely identify the type of data to be acquired, and includes, for example, "the latest data (last accumulated data) in the specific type data group". (Condition 2) The data acquired by the request from the external DB 112 is provided with an ID for uniquely identifying the acquisition target data, and the data acquired by the request includes at least one of the IDs.

  The external DB 112 stores data responding to the request.

  The attribute information storage DB 103 stores attribute information that is not included in the data in the external DB 112 and is information related to data. The attribute information includes, for example, data generation time or data update time. Further, the attribute information need not be the information on the time as long as it is information related to data.

The attribute information extraction and storage processing unit 102 extracts attribute information (for example, data generation time or data update time) from the data acquired from the external DB 112. The attribute information extraction and storage processing unit 102 accumulates the extracted attribute information in the attribute information storage DB 103, and accumulates in the data presence monitoring processing unit 104 that the attribute has been extracted. Here, the data generation time refers to a time at which the attribute information extraction and storage processing unit 102 can confirm that the data of the response to the request exists for the first time, as “data generation time”. The data update time is defined as the time at which the attribute information extraction and storage processing unit 102 can confirm for the first time that the data of the response to the request has been updated, as “data update time”.
Further, the attribute information extraction and storage processing unit 102 extracts necessary attribute information such as generation or update time from the data in the external DB 112 and separately accumulates the attribute information in the attribute information storage DB 103.

  The data presence monitoring processing unit 104 sends a request to the external DB system common API 111 in the external DB 112 if there is no request for a certain period of time α or more from the time of receiving the last request for each request unit. Make an inquiry (request) corresponding to. Here, the request unit is a specific request, and includes, for example, temperature information, humidity information, and sunshine information. The request unit may be further limited and defined as information in which a response to the request changes over time. This will be described briefly in detail using an example of a request. The data presence monitoring processing unit 104 determines whether or not there has been a request for the temperature information for a certain period α or more from the time when the last request for the temperature information was received with respect to the external DB system common API 111. If there is no request, the external DB 112 is inquired of a request for the temperature information.

The certain period α may be a predetermined constant, or on the assumption that requests are sent to the system periodically, for example, using the following values obtained from the average μ and the standard deviation σ of the request interval, You may. That is, when there is no request equal to or greater than the threshold value, an inquiry is made to the external DB 112.
(Threshold) = μ + 3 × σ

  The data presence monitoring processing unit 104 periodically refers to the external DB 112 only when the external DB 112 has not been searched from each system for a certain period of time. As a result, concentration of processing on the external DB 112 can be avoided, and the load on the external DB 112 can be reduced.

  When receiving the request, the data integration processing unit 101 responds to the request with data obtained by integrating data in the external DB 112 corresponding to the request and attribute information in the attribute information storage DB 103 corresponding to the data.

  The external DB system common API (application program interface) 111 converts a request when there is a request from which attribute information can be extracted, and notifies the data existence monitoring processing unit 104 of the request. The external DB system common API 111 transmits the data acquired from the external DB 112 to the attribute information extraction and storage processing unit 102 in order to extract attribute information from a response to the request. The request conversion is to convert a request received by the external DB system common API 111 to conform to the specification of the external DB.

  Next, an operation of the external database accommodating apparatus of the present embodiment will be described with reference to FIGS. 2, 3, and 4, which are sequence diagrams. These sequence diagrams also explain the external database accommodation method and these external database accommodation programs.

First, a case of referring to data in the internal DB of each of the systems 1 to N will be described with reference to FIG. Hereinafter, one of the systems 1 to N will be described as a representative. When the system is given as the “representative”, the branch number (for example, “−1” in the case of “121-1”) is omitted, and the request receiving unit 121, the request target DB determining unit 122, and the internal DB 123 are described. .
The request receiving unit 121 of a certain system receives a request (step S201). The request target DB determination unit 122 receives this request (step S202), and determines in which database a response to the request (request response) is located (step S203). Here, the request target DB determination unit 122 determines that the response to the request is in the internal DB 123. The request target DB determination unit 122 transmits a request to the internal DB 123 (Step S204). The internal DB 123 acquires data corresponding to the request received from the request target DB determination unit 122 (Step S205), and transmits this data to the request target DB determination unit 122 (Step S206). Thereafter, the request receiving DB determining unit 122 transmits the received data to the request receiving unit 121 (step S207), and finally transmits the data to the terminal or the like to which the request receiving unit 121 has input the request (step S208).

Next, a case where the external database accommodation device of the present embodiment refers to data in the external DB 112 will be described with reference to FIG.
In this example, the request target DB determination unit 122 determines that the response to the request is in the external DB 112 (step S203). The request target DB determination unit 122 transmits a request to the external DB system common API 111 (step S301). The external DB system common API 111 converts the received request according to the specification of the external DB 112 to inquire (step S302), and then transmits the converted request to the external DB 112 (step S303). The external DB 112 acquires data corresponding to the request received from the external DB system common API 111 (step S304), and transmits this data to the external DB system common API 111 (step S305). The external DB system common API 111 receives data (request response) corresponding to the request from the external DB 112, and transmits data as a request response to the attribute information extraction and storage processing unit 102 (step S306). The external DB system common API 111 also transmits the request response data to the data integration processing unit 101, and stores the request response (step S307).

  The attribute information extraction and storage processing unit 102 extracts the attribute information based on the data that is the request response (step S308). The attribute information extraction and storage processing unit 102 transmits the extracted attribute information to the attribute information storage DB 103 (step S309), and transmits information indicating that the attribute information has been extracted to the data presence monitoring processing unit 104 (step S310). ). The attribute information storage DB 103 stores the extracted attribute information (Step S311). In step S307, a request signal for requesting the attribute information corresponding to the stored request response is transmitted to the attribute information storage DB 103 (step S312). The attribute information storage DB 103 acquires the attribute information corresponding to the request signal (Step S313), and transmits the attribute information to the data integration processing unit 101 (Step S314).

  The data integration processing unit 101 integrates the request response transmitted in step S307 and the attribute information transmitted in step S314 (step S315). The data integration processing unit 101 transmits the integrated data to the request target DB determination unit 122 (step S316), and the request target DB determination unit 122 passes through the request reception unit 121 (steps S316 and S317), and finally sends the request The receiving unit 121 transmits the data to the terminal or the like to which the request has been input (step S318).

  As described above, according to the external database accommodating apparatus of the present embodiment, even when attribute information (for example, data generation time or data update time information) that is not included in the data in the external DB 112 is acquired when the external DB 112 is referred to. can do.

Next, a case where the external database accommodating device of the present embodiment has not received a request for a certain period or more will be described with reference to FIG.
The data presence monitoring processing unit 104 determines whether or not a request has been received for a certain period of time α or more from the time of receiving the last request (step S401). For example, an arbitrary request that satisfies the above (condition 1) and / or (condition 2) is transmitted to the external DB 112 via the application system common API 111 (step S402). This request may be any request in which the response is stored in the external DB 112 in this example. If no response is stored in the external DB 112, this processing stops halfway and the request is not accepted.
The external DB system common API 111 converts the request and transmits the converted request to the external DB 112 (step S404). The external DB 112 acquires data corresponding to the request received from the external DB system common API 111 (step S405), and transmits this data to the external DB system common API 111 (step S406). The external DB system common API 111 receives data (request response) corresponding to the request from the external DB 112, and transmits data as a request response to the attribute information extraction and storage processing unit 102 (step S407).

  The attribute information extraction and storage processing unit 102 extracts attribute information based on the data that is the request response (step S408). The attribute information extraction and storage processing unit 102 transmits the extracted attribute information to the attribute information storage DB 103 (step S409), and transmits information indicating that the attribute information has been extracted to the data presence monitoring processing unit 104 (step S410). ). The attribute information storage DB 103 stores the extracted attribute information (Step S411).

  As described above, when a plurality of systems refer to one external DB, the data presence monitoring processing unit 104 performs periodic reference to the external DB 112 only when the external DB 112 is not searched from each system for a certain period of time. The content of the attribute information storage DB 103 can be enhanced. As a result, the degree of concentration of requests on the external DB 112 is reduced, and the load on the external DB 112 can be reduced.

  According to the above embodiment, attribute information (for example, data generation time or data update time information) that is not included in the data in the external database can be acquired when referring to the external database. In addition, the degree of concentration of requests to the external database can be reduced, and the load on the external database can be reduced.

  Note that the present invention is not limited to the above-described embodiment as it is, and can be embodied by modifying constituent elements in an implementation stage without departing from the scope of the invention. Various inventions can be formed by appropriately combining a plurality of constituent elements disclosed in the above embodiments. For example, some components may be deleted from all the components shown in the embodiment. Further, components of different embodiments may be appropriately combined.

1 to N: system, 101: data integration processing unit, 102: attribute information extraction and storage processing unit, 103: attribute information storage database, 104: data existence monitoring processing unit, 111: external DB system common API, 112: external DB, 121-1 to 121-N: request receiving unit; 122-1 to 122-N: request target DB determining unit; 123-1 to 123-N: internal DB.

Claims (7)

An external database accommodating apparatus that obtains a response to a request from an external database that receives a plurality of requests that can uniquely identify a type of data to be acquired from one or more systems,
An attribute information database storing attribute information that is information related to data of a response to the request;
Based on the response data from the external database to the first request, a first data generation time, which is a time at which it was possible to confirm that the response data to the first request was present for the first time, is stored in the attribute information database. An extraction and storage processing unit that obtains the information of the first data generation time in the attribute information database , based on the obtained information,
An external database accommodation device, comprising: an integration processing unit that responds to the first request with data obtained by integrating a response to the first request and the first data generation time . A monitoring unit that transmits a second request to the external database when there is no request after a certain period of time has elapsed since the last time the request was received;
The extraction and storage processing unit is configured to determine, based on data of a response from the external database to the second request, that data of a response to the second request is present for the first time, a second data generation time. The external database accommodating apparatus according to claim 1, wherein information on the second data generation time is obtained in the attribute information database based on information stored in the attribute information database.   The monitoring processing unit determines a threshold value larger than the average value based on an average value and a standard deviation of a time interval at which a request to the external database is made. 3. The external database accommodation device according to claim 2, wherein the external database accommodation device transmits two requests. An external database accommodation method for obtaining a response to a request from an external database that receives a plurality of requests that can uniquely identify the type of data to be acquired from one or more systems,
The first data generation time, which is the time at which it was possible to confirm for the first time that the data of the response to the first request was present based on the data of the response from the external database to the first request by the extraction and storage processing unit , Requested based on information stored in an attribute information database that stores attribute information that is information related to the data of the response to the request ,
By the extraction and storage processing unit, the attribute information database that stores attribute information, and stores information of the first data generation time,
The integration processing unit, wherein the response to the first request, it responds with data obtained by integrating the first data generation time to the first request, external database housed method comprising a. The monitoring processor, when there is no request finally passed over a fixed period from the time a request is received, further comprising transmitting a second request to the external database,
A second data generation time that is a time at which the extraction and storage processing unit can confirm that the response data to the second request exists for the first time based on the response data from the external database to the second request; Is determined based on information stored in the attribute information database ,
5. The external database accommodating method according to claim 4, wherein the extraction and storage processing unit stores information on the second data generation time in the attribute information database. The monitoring processing unit determines a threshold value larger than the average value based on the average value and the standard deviation of the time interval at which the request to the external database is made. 6. The external database accommodation method according to claim 5, wherein two requests are transmitted.   A program for causing a computer to execute each step of the method for accommodating an external database according to any one of claims 4 to 6.