JP4432733B2 - Cooperation processing apparatus and system - Google Patents

Description

  The present invention relates to a distributed data processing technique in which a plurality of data processing components are linked to perform a series of processing.

  As a distributed data processing method for executing a series of processes in cooperation with a plurality of data processing components, for example, there is a method disclosed in Patent Document 1. In this method, the procedure information and the intermediate result information of the joining process are circulated in the network as a transfer information unit, while each node that executes each partial process and holds the result acquires the transfer information unit from the network, and transfers the transfer information unit. Based on the procedure information of the information unit, the partial processing result held by the node and the acquired intermediate result information are used to perform a part of the combining process, and the intermediate result information is updated based on the result, and the network is added together with the procedure information. To send.

  Patent Document 2 discloses a system for obtaining a processing result obtained by performing complex processing by causing a processing server to process a raw material file on a web server and linking the processing of a plurality of processing servers. In this system, a web browser sends a request by a virtual URL (Uniform Resource Locator) in which a raw material file is modified with a procedure name, a parameter, a computer name, and the like. A composite process combining a plurality of partial processes is expressed by incorporating a virtual URL of another partial process as an argument with respect to the virtual URL of the partial process, and each processing server displays a virtual URL addressed to itself. Interpret and the request indicated by the argument (virtual URL) that cannot be processed by itself is transferred to a processing server that can process the request by HTTP (Hypertext Transfer Protocol), and the processing result is acquired. To use. Each processing server stores the processing result (snapshot) of the partial processing executed by itself in a table in association with the virtual URL that is the source of the processing. Then, the processing server checks whether there is a snapshot corresponding to the sent virtual URL addressed to itself in the table in its own device, and if so, checks its validity. The snapshot is returned as a processing result without executing the indicated process. Here, in the validity check, if the snapshot creation time is newer than the update date and time of the raw material file for the snapshot creation, it is determined to be valid. When the processing result of the partial processing of another processing server is used as an argument for creating the snapshot, the effectiveness of the snapshot of the partial processing of the argument is inquired to the other processing server. If even one of the snapshots of a partial processing argument is invalid, the partial processing snapshot is invalidated. If the snapshot is invalid, the partial process is re-executed. However, in this case, if there is an effective snapshot of the argument of the partial process, the process is not re-executed for the argument, and the snapshot is used.

Japanese Patent Laid-Open No. 10-027164 JP 2000-076118 A

  In the method of Patent Document 1, there is a problem that a data load as an intermediate processing result is included in a transfer processing unit to be circulated in the network, and the network load is large. Further, in this method, every time a transfer processing unit comes to a node, a copy of data in the transfer processing unit is generated for that node. Further, even if the processing is exactly the same as the processing performed in the past, if such processing is described in the program, it is repeatedly executed, so that the efficiency is low.

  In the method of Patent Document 2, since each processing server holds and reuses a snapshot of a partial process performed by itself, it is difficult to waste that the same process as the process performed in the past is repeated. However, in this method, when the processing is completed, the processing server transmits the actual data of the processing result to the processing server that uses the processing result. For this reason, even if the processing load of each processing server can be reduced by using the snapshot, the effect of reducing the load on the network is small.

  Further, in the method of Patent Document 2, the processing in a plurality of processing servers is linked by describing a virtual URL of another processing as an argument of the processing in a virtual URL indicating a certain processing in a nested manner. However, it is difficult to express the repetition of processing in such a nested description form.

  In addition, when executing linked processing of, for example, pipeline processing in which a plurality of processing servers are linked, the processing of the next processing server is started from the time when the entity data of the processing result of the processing server is passed to the next processing server However, there is a problem that the entire process takes time. This problem also occurs when a plurality of data processing components on one computer apparatus are linked. The pipeline processing function provided by an OS (operating system) such as UNIX (registered trademark) starts up each program constituting the pipeline first, and the standard output stream of the program is set to the next program. Since the cooperation process is realized by assigning the standard input stream, there is no problem as described above. However, if the processing results of each program are passed through the input / output stream in this way, the processing results for each program do not remain on the computer device, so the intermediate processing results, such as debugging, are examined. It was not enough if you wanted to.

  The present invention solves at least one of the above problems of the prior art.

In one aspect of the present invention, there is provided a cooperative processing apparatus that executes a requested process by causing a plurality of data processing units, each executing a predetermined unit process, to perform a cooperative operation. The cooperative processing apparatus, when receiving a registration request for processing result data from the data processing unit to the shared storage unit and a shared storage unit for storing the processing result data of the plurality of data processing units, Unique processing result identification information is assigned to the processing result data, the assigned processing result identification information is registered in the shared storage unit in association with the processing result data, and the processing result identification information is returned to the registration request. Processing result registering means for returning to the data processing unit as a value, and when receiving an acquisition request designating processing result identification information from the data processing unit, processing result data corresponding to the processing result identification information is sent to the shared storage unit Processing result providing means for acquiring from the data processing unit and returning it to the data processing unit, each data processing unit responding to an activation request including processing result identification information as a processing parameter. Is sent to the processing result providing means to receive the processing result data corresponding to the processing result identification information, and the unit processing is performed using the processing result data. and executes, have rows registration request to the processing result registration means for storing the processing result data obtained by the unit process, the cooperative processing apparatus, the execution request of inclusive procedure a plurality of unit processes And a processing control unit that sequentially activates the data processing unit corresponding to each unit process described in the processing procedure to execute each unit process, and each data processing unit includes: In response to the registration request, the processing result identification information received from the processing result registration unit is returned to the processing control unit, and the processing control unit returns from the data processing unit. The processing result identification information is passed as a processing parameter to another data processing unit that performs unit processing using the processing result data of the data processing unit. One or more corresponding to each usable range identification information and usable range identification information giving means for giving unique usable range identification information to the execution request and passing the given usable range identification information to the processing control unit And an available range information management means for holding the processing result identification information, wherein the processing control unit uses the available range identification information given from the available range identification information giving means in the processing procedure. The data processing unit registers the available range identification information passed from the processing control unit with the processing result registration unit. The processing result registration unit passes the usable range identification information passed from the data processing unit to the processing result data that is the target of the registration request. The data processing unit registers the usable range identification information passed from the processing control unit with the acquisition request to the processing result providing unit in association with the corresponding processing result identification information. The processing result providing means associates the processing result identification information related to the acquisition request from the data processing unit with the usable range identification information passed at the time of the acquisition request. It is checked whether or not it is held in the available range information management means, and if it is held, processing result data corresponding to the processing result identification information is acquired from the shared storage unit Return to the data processing unit Te.

In another aspect of the present invention, a cooperative processing system that executes a requested process by cooperatively operating a plurality of host devices connected via a network is provided. In this system, each host device includes at least one data processing unit that executes unit processing, a shared storage unit for storing processing result data of the data processing unit, and the shared storage from the data processing unit. When the processing result data registration request is received, the processing result data is given unique processing result identification information, and the given processing result identification information is associated with the processing result data in the shared storage. Processing result registration means for returning the processing result identification information to the data processing unit as a return value for the registration request, and when receiving an acquisition request designating processing result identification information from the data processing unit, Processing result providing means for acquiring processing result data corresponding to the processing result identification information from the shared storage unit and returning the processing result data to the data processing unit, and each data processing unit When activated by an activation request including processing result identification information as a processing parameter, an acquisition request including the processing result identification information is sent to the processing result providing means to receive processing result data corresponding to the processing result identification information, The process result data is used to execute its own unit process, and in order to store the process result data obtained by the unit process, a registration request is made to the process result registration unit, and the data processing unit If it is called from the host device, the processing result identification information received as a return value for the registration request is returned to the other host device that is the call source, and the processing result providing means is provided by the data processing unit. If there is no processing result data corresponding to the processing result identification information specified in the acquisition request in the shared storage unit of the local host device, An acquisition request with the processing result identification information is made to the shared storage unit of the host device indicated by the processing result identification information, and the processing result data returned from the shared storage unit in response to the acquisition request is the data processing unit And the processing result data is associated with the processing result identification information and registered in the shared storage unit of the own host device, and the plurality of host devices serve as a plurality of unit processes as one of the data processing units. Including a processing control unit that controls the execution of the processing procedure including: only the processing control unit out of a plurality of data processing units in the host device issues a startup request to the data processing unit in the other host device, The processing control unit of the host device can issue an activation request only to the processing control unit among the plurality of data processing units of other host devices. A portal host device that accepts a processing procedure execution request from a client device and other remote host devices, and the portal host device has a unique usable range for a processing procedure execution request from a client device. An available range identification information adding unit that assigns identification information and passes the assigned available range identification information to the processing control unit of the portal host device, and at least one processing result identification information corresponding to each available range identification information. A usable range information management means for holding, wherein the processing control unit of the portal host device activates the usable range identification information given from the usable range identification information giving means in the processing procedure. To the data processing unit in its own host device and execute the second processing procedure for another host device in the processing procedure Is included, the execution request for the second processing procedure is passed along with the available range identification information to the processing control unit of the other host device, and the remote host device receives each available range identification information. When receiving an execution request for a processing procedure from another host device, the available range identification information received together with the execution request is stored in the available range information management means for holding one or more processing result identification information corresponding to Means for registering in the usable range information management means in the host device, and the processing control unit of the remote host device receives the usable range identification received together with the execution request of the processing procedure from the other host device The information is passed to the data processing unit in the host device that is activated in the processing procedure, and the second processing for the other host device is performed in the processing procedure. When a sequential execution instruction is included, the execution request of the second processing procedure is passed along with the available range identification information to the processing control unit of the other host device, and the data processing unit of each host device Passes the usable range identification information passed from the processing control unit of the own host device to the processing result registration unit at the time of a registration request to the processing result registration unit of the own host device, and the processing of each host device The result registering means associates the usable range identification information passed at the time of the registration request from the data processing unit of the own host device with the processing result identification information corresponding to the processing result data that is the target of the registration request. The data processing unit of each host device registers the usable range identification information passed from the processing control unit of its own host device with its own host device. When the acquisition request to the processing result providing unit of the host device is passed to the processing result providing unit, the processing result providing unit of each host device identifies the processing result related to the acquisition request from the data processing unit of the own host device. When the information is in the shared storage unit of the own host device, the processing result identification information is stored in the available range information management unit of the own host device in association with the available range identification information passed with the acquisition request. The processing result data corresponding to the processing result identification information is acquired from the shared storage unit and returned to the data processing unit only when it is held, and the data processing unit of the own host device If the processing result identification information related to the acquisition request is not in the shared storage unit of the own host device, the shared storage unit of the host device indicated by the processing result identification information The processing result providing unit of each of the host devices can use the processing result identification information from the processing result providing unit of another host device. When receiving an acquisition request with range identification information, check whether the processing result identification information is held in the available range management means in the host device in association with the available range identification information, Only when it is held, the processing result data corresponding to the processing result identification information is acquired from the shared storage unit of the own host device and returned to the processing result providing means of the other device .

In yet another aspect, each host device constituting the cooperative processing system includes one or more data processing units each executing unit processing, a shared storage unit for storing processing result data of the data processing unit, When a registration request for processing result data from the data processing unit to the shared storage unit is received, unique processing result identification information is given to the processing result data, and the given processing result identification information is used as the processing result. Processing result registration means for registering the processing result identification information in association with the data and returning the processing result identification information to the data processing unit as a return value for the registration request; and specifying the processing result identification information from the data processing unit Processing result providing means for acquiring processing result data corresponding to the processing result identification information from the shared storage unit and returning it to the data processing unit when receiving an acquisition request; Each of the data processing units, when activated by an activation request including processing result identification information as a processing parameter, sends an acquisition request including the processing result identification information to the processing result providing means to the processing result identification information Receives corresponding processing result data, executes its own unit processing using the processing result data, and makes a registration request to the processing result registration means to store the processing result data obtained by the unit processing If the data processing unit is called from another host device, the processing result identification information received as a return value for the registration request and the corresponding processing result data registered in the shared storage unit are called up. Returning to the other host device that is the original, each data processing unit transmits another host for partial processing in the execution of its unit processing. If you call a data processing unit of the winding device, and registers the processing result identification information and the processing result data returned from the data processing unit of the other of the host device for that call to the shared storage unit, said plurality of host The apparatus includes a processing control unit that controls execution of a processing procedure including a plurality of unit processes as one of the data processing units, and only the processing control unit among the plurality of data processing units in the host device An activation request is issued to a data processing unit in another host device, and the processing control unit of the host device can issue an activation request only to the processing control unit among a plurality of data processing units of the other host device. The plurality of host devices are classified into a portal host device that receives a processing procedure execution request from a client device, and a remote host device other than the portal host device, and the portal host The device assigns unique usable range identification information to the processing procedure execution request from the client device, and assigns usable range identification information that passes the assigned usable range identification information to the processing control unit of the portal host device And usable range information management means for holding one or more processing result identification information corresponding to each usable range identification information, and the processing control unit of the portal host device includes the usable range identification information. The usable range identification information given from the granting unit is passed to the data processing unit in the own host device activated in the processing procedure, and the second information for the other host device in the processing procedure is given. If the execution instruction of the processing procedure is included, the execution request of the second processing procedure is passed along with the usable range identification information to the processing control unit of the other host device. When the remote host device receives a request for execution of a processing procedure from another host device and a usable range information management unit that holds one or more processing result identification information corresponding to each usable range identification information, the remote host device executes the processing Means for registering the usable range identification information received together with the request in the usable range information management means in the host device, and the processing control unit of the remote host device performs processing from the other host device. The usable range identification information received together with the execution request of the procedure is passed to the data processing unit in the own host device activated in the processing procedure, and the second information for the other host device is included in the processing procedure. When an instruction to execute this processing procedure is included, the execution request for the second processing procedure is shared with the usable range identification information to the processing control unit of the other host device. The data processing unit of each host device passes the usable range identification information passed from the processing control unit of the host device to the processing result registration at the time of a registration request to the processing result registration unit of the host device. The processing result registration unit of each host device passes the available range identification information passed at the time of the registration request from the data processing unit of the own host device to the processing result data that is the target of the registration request. Registered in the usable range information management means of the own host device in association with the processing result identification information corresponding to, and the data processing unit of each host device is used by the processing control unit of the own host device The possible range identification information is passed to the processing result providing means at the time of an acquisition request to the processing result providing means of the own host device, and the processing result providing means of each host device When the processing result identification information related to the acquisition request from the data processing unit of the host device is in the shared storage unit of the own host device, the processing result identification information corresponds to the usable range identification information passed along with the acquisition request. Then, it is checked whether or not it is held in the usable range information management means of its own host device, and if it is held, processing result data corresponding to the processing result identification information is acquired from the shared storage unit. If the processing result identification information related to the acquisition request from the data processing unit of the own host device is not in the shared storage unit of the own host device, the host device sharing indicated by the processing result identification information is returned to the data processing unit An acquisition request with the processing result identification information and the usable range identification information is sent to the storage unit, and the processing result providing means of each host device transmits another host device. When the acquisition request accompanied with the processing result identification information and the usable range identification information is received from the processing result providing means, the processing result identification information is sent to the usable range management means in the own host device. It is checked whether or not it is held in correspondence with the information. Only when it is held, processing result data corresponding to the processing result identification information is acquired from the shared storage unit of the own host device, and the other device's Return to the processing result providing means .

  The best mode for carrying out the present invention (hereinafter referred to as “embodiment”) will be described below with reference to the drawings.

[First Embodiment]
FIG. 1 is a diagram showing a system configuration of the first embodiment of the present invention. In this system, one host (computer device) 1 executes a service for a client 2 (computer device). The host 1 performs processing for the service by executing a script described in a script language such as Groovy. The request that the client 2 sends to the host 1 for requesting a service includes, for example, a script name (script name) and parameters as arguments of the script.

  The processing mechanism in the host 1 includes a processing control unit 10, a processing control procedure interpretation unit 20, data processing units 30-1 and 30-2, a raw material data storage unit 40, and a processing result storage unit 50.

  The data processing units 30-1 and 30-2 are units that execute individual unit data processing for realizing a service for the client 2. There is no particular limitation on the contents of unit data processing (hereinafter referred to as “unit processing”). For example, various things such as document summarization and merging of multiple documents can be considered.

  In the illustrated example, the data processing units 30-1 and 30-2 are implemented as classes such as Java (registered trademark). The class name is Component1 for the data processing unit 30-1 and Component2 for the data processing unit 30-2. The data processing unit 30-1 includes an execute method 32-1 that is a method of the Component1 class, and the data processing unit 30-2 includes an execute method 32-2 that is a method of the Component2 class. The execute methods 32-1 and 32-2 are methods for executing unit processes provided by the corresponding data processing units 30-1 and 30-2, respectively.

  Although FIG. 1 shows two data processing units 30-1 and 30-2, it is of course possible to provide the host 1 with more data processing units. The processing of the host 1 is realized by linking the unit processing of these data processing units 30-1, 30-2,. Hereinafter, the data processing units 30-1, 30-2,... Are collectively referred to as the data processing unit 30 for matters that are not unique to the data processing units 30-1 and 30-2 and are generally applicable to the data processing units. .

  The processing control unit 10 is a unit that controls the unit processing of the plurality of data processing units 30. The process control unit 10 activates the script specified in the request from the client 2 and activates the data processing unit 30 that executes each unit process described in the script to execute the process. When executing the script, the process control unit 10 controls the transfer of the processing results of the data processing units 30.

  The process control unit 10 can be implemented as a servlet program. In the illustrated example, the processing control unit 10 is implemented as a class such as Java (registered trademark), and its class name is Evaluator. The process executed by the process control unit 10 is implemented as an eval method 12. The client 2 can request processing from the host 1 by designating a script and parameters necessary for the execution and calling the eval method 12 of the Evaluator class of the host 1.

For example, when the host 1 is configured as a web application server, a request from the client 2 to the host 1 can be in the form of an HTTP URL as exemplified below.

http: //host.domain/Evaluator? method = eval & script = script1.groovy & arg1 = aaa & arg2 = bbb
… (1)

  In this URL (1), host is the host name of the host 1, and domain is the domain name of the domain in which the host 1 is located. Evaluator is the Evaluator class to call. In the URL query part (description below “?”), A method name eval to be called, a script name script1.groovy to be executed, and two arguments (parameters) aaa and bbb of the script are described. The number of arguments required by a script (or whether arguments are not required) varies from script to script. Arguments that match the script to be executed are set in the request.

  The script executed by the host 1 may include an expression for starting the processing (that is, unit processing) of each data processing unit 30 and an expression for causing another script to be executed. In addition, various known control structures such as for loops can be described in the script, and a series of processes can be represented by unit processing or the order of expressions indicating the script or the description of the control structure. Can do.

  When an HTTP request based on the above URL (1) is sent from the client 2 to the host 1, the host 1 receives the request and starts a servlet indicated by the name Evaluator. This servlet is the processing control unit 10.

  The process control procedure interpreting unit 20 is a unit that interprets the script description, interprets the script notified from the process control unit 10, and sequentially instructs the process indicated by the script to the process control unit 10.

  The raw material data storage unit 40 stores raw material data that is a raw material for unit processing in the data processing unit 30. Raw material data depends on the content of the unit process. For example, the raw material data for the document summarization process is document data. Although the raw material data storage unit 40 is shown as a unit in the host 1 in the figure, a system configuration using another server device on the LAN or the Internet as the raw material data storage unit 40 is possible instead.

  The processing result storage unit 50 is a unit that stores and manages the processing result of the unit processing executed by each data processing unit 30. In the present embodiment, the processing result of the unit processing executed by each data processing unit 30 is registered in the processing result storage unit 50. The processing result storage unit 50 adds “processing result ID” to the processing result to be registered. Is assigned and managed with unique identification information. Then, the data transfer between the data processing units 30 is realized by not passing the data entity directly but by passing the processing result ID. Receiving the processing result ID, the data processing unit 30 acquires a data entity corresponding to the processing result ID from the processing result storage unit 50 and uses it for its own processing.

  In the illustrated example, the processing result storage unit 50 is implemented as a class such as Java (registered trademark), and its class name is Pool. The process result data registration process for the process result storage unit 50 is implemented as a register method 51, and the process result data acquisition process from the process result storage unit 50 is implemented as an access method 52, respectively. The entity data of the processing result is registered and managed in the processing result management table 53. As shown in FIG. 2, the processing result management table 53 is a table in which the processing result entity data (“processing result entity”) is registered in association with the processing result ID assigned thereto.

  The processing contents of the methods executed by each processing unit in the host 1 are summarized below.

<Data processing unit 30 (Evaluator)>
Execute method 32: When this method is called, it performs predetermined data processing, calls the regiter method 51 of the processing result storage unit 50 (Pool), registers the processing result in the processing result storage unit 50, and the regiter method A processing result ID which is a return value of 51 is returned to the caller of the execute method 32. When the processing result ID is given to the argument of the execute method 32 to be called, the access method 52 of the processing result storage unit 50 is called to acquire the processing result entity corresponding to the processing result ID and use it for data processing.

<Processing result storage unit 50 (Pool)>
Register method 51: This method assigns a processing result ID to the processing result entity passed as an argument, registers it in the processing result management table 53, and returns the processing result ID to the caller. The unique processing result ID is generated, for example, by assigning a serial number.

Access method 52: This method reads the processing result entity corresponding to the processing result ID passed as an argument from the processing result management table 53, and returns it to the caller.

<Processing control unit 10 (Evaluator)>
Eval method 12: This method activates the script specified in the argument and returns the processing result to the caller. If the caller is the client 2, the processing result is returned as entity data. On the other hand, when called from a script, a processing result ID is returned. Details of the processing of the eval method 12 will be described later in detail with reference to a flowchart.

Next, the script used in this embodiment will be described. Of the expressions constituting the script, the expression for starting the data processing unit 30 is as follows.

id1 = Component1.execute (url1);… (2)

This example is an expression indicating that the raw material data indicated by the URL url1 is processed by the execute method of the Component1 class, and id1 indicates a processing result ID which is a return value of the method.

Of the expressions constituting the script, the expression indicating the execution of another script is as follows.

id2 = Evaluator.eval (scriptname, parameter);… (3)

As this example shows, script execution is achieved by calling the eval method of the Evaluator class. The first argument scriptname of the eval method is the script name of the script to be executed, and the second argument parameter is an array of parameters taken by the script. In this case, since the eval method is called from within the script, the return value id2 is the processing result ID of the final processing result of the script.

  The script is such that an expression for starting the data processing unit 30 and an expression for instructing execution of another script are described together with statements indicating various control structures such as repetition and selection.

  In the present embodiment, the script is stored in a storage device in the host 1. Then, the process control procedure interpreting unit 20 reads the script corresponding to the script name designated by the process control unit 10 from the storage device and interprets it.

  Next, request processing by the host 1 will be described with reference to the processing (eval method) procedure of the processing control unit 10 shown in FIG. 3 and FIG.

  The servlet that is the processing control unit 10 is activated in response to a request in the URL format from the client 2, and first extracts a script name and parameters (arguments) from the query part of the request (S10). For example, when the request is the above-described URL (1), “script1.groovy” is extracted as the script name, aaa is extracted as the first parameter, and bbb is extracted as the second parameter.

  Next, the process control unit 10 calls a script indicated by the script name (S12). That is, the extracted script name and parameters are passed and the process control procedure interpretation unit 20 is activated. The activated process control procedure interpreting unit 20 acquires a script corresponding to the script name from the storage device, interprets the script, and sequentially instructs the process control unit 10 to execute the process.

For example, suppose the called script "script1.groovy" is as follows:

id_const = Component1.execute (url1);… (11)
id_result;
for (i = 0; i <10; i ++) [
id_current = Component2.execute (id_const, id_result);… (12)
id_result = id_current;
]
return id_result;

In this script, equation (11) indicates an instruction to cause the data processing unit 30-1 to process the raw material data indicated by the URL url1. id_const is a variable that holds the ID of the processing result of this processing. The expression (12) indicates an instruction to cause the data processing unit 30-2 to execute the process result data indicated by the process result ID “id_const” and the process result data indicated by the process result ID “id_result”. . id_current is a variable that holds the ID of the processing result of this processing. The processing of equation (12) is repeated 10 times by a for loop, but the argument id_const used therein does not change during the iteration. That is, the processing result of the processing of the expression (11) is repeatedly used in the for loop as a constant that does not change. On the other hand, another argument id_result is updated to the latest id_current value at each iteration.

  When such a script is given, the process control procedure interpreting unit 20 first determines that the process indicated by the expression (11) should be executed as shown in FIG.

  The process controller 10 goes to the process control procedure interpreter 20 to receive a process instruction (S14), and determines whether or not the process instruction has been received (S16). In the case of the above script example, the processing instruction represented by the expression (11) can be acquired first, so the determination result is Yes and the process proceeds to S18. In S18, it is determined whether or not the processing instruction is a script execution instruction. The processing instruction includes an instruction to start the data processing unit 30 shown in the above formula (2) and a script execution instruction shown in the formula (3). That is why.

  In the case of the processing instruction represented by the expression (11), since it is an instruction to activate the data processing unit 30, the determination result in S18 is No, and the process proceeds to S20. In S20, the data processing unit 30 indicated by the instruction is activated. For example, in the case of the processing instruction of the expression (11), the processing control unit 10 activates the execute method 32-1 of the data processing unit 30-1 with the argument “url1” specified. The data processing unit 30-1 acquires the raw material data indicated by "url1" from the raw material data storage unit 40, and performs predetermined processing on the raw material data by the execute method 32-1. The execute method 32-1 calls the register method 51 of the processing result storage unit 50 and registers the processing result “A1” of the processing in the processing result management table 53. The register method 51 assigns the processing result ID “id1” to the processing result “A1”, registers it in the processing result management table 53, and returns the processing result ID “id1” to the data processing unit 30-1.

  Here, the registration of the processing result in the processing result management table 53 can be performed before all the processing result data of the execute method 32-1 is prepared.

  The data processing unit 30-1 receives the processing result ID “id1” as a return value from the register method 51 of the processing result storage unit 50, and returns “id1” to the processing control unit 10 as a return value of its own processing. When the processing control unit 10 acquires the processing result ID “id1” from the data processing unit 30-1 (S22), the processing control unit 10 returns to S14 and tries to acquire the next processing instruction from the processing control procedure interpretation unit 20.

  In the case of the above-described script example “script1.groovy”, the process of the expression (11) is followed by the first process of the expression (12) in the for loop. Therefore, the determination result in S16 is Yes, the determination result in S18 is No, and the execute method 32-2 of the data processing unit 30-2 is called in S20. The first argument id_const at the time of this call is the processing result ID “id1” of the processing result of the data processing unit 30-1. Since the second argument id_result is the first loop, it is the default value. The called execute method 32-2 calls the access method 52 of the processing result storage unit 50, and acquires the data of the processing result entity indicated by the first and second arguments (processing result ID) from the processing result management table 53. To do. FIG. 1 shows only the flow of acquiring the processing result entity “A1” corresponding to the processing result ID “id1” in order to avoid complexity. The execute method 32-2 performs predetermined data processing on the acquired two entity data, registers the processing result “A2” in the processing result management table 53 by the register method 51, and sets the processing result ID ”. id2 "is acquired and returned to the processing control unit 10. The process control unit 10 acquires the process result ID “id2” and returns to S14. Since the next process in the above script example is to set the received process result ID “id2” in the variable id_result, the process control unit 10 executes it and proceeds to S14 again.

  In this step S14, the processing control unit 10 receives the processing instruction of the expression (12) for the second time of the for loop in the above script example, so in S20 the first argument id_const is set to “id1” and the second argument With the id_result set to “id2”, the execute method 32-2 of the data processing unit 30-2 is called to obtain the ID of the processing result, and the process returns to S14. The above processing is repeated until the last loop of the for loop. In FIG. 1, the processing result ID of the processing result of the data processing unit 30-2 in the last loop is “idN”, and the value of the variable id_result is “idN” at this point. In S14 which is returned after the last loop is completed, there is no next processing instruction, so the processing of the processing control unit 10 proceeds to S24.

  In S24, the subsequent processing branches to S26 and S28 depending on whether the currently executed script is called from another script or not.

  That is, the script includes a script called from a servlet (processing control unit 10) activated by a request from the client 2 and a script called from the above expression (3) from the script. The latter is not included in the above script example, but if a processing instruction such as the above equation (3) is included in the script, the determination result in S18 is Yes in the processing instruction number. In this case, the process control unit 10 returns to S12, activates the eval method 12 of the Evaluator class, and calls the script indicated in the expression of the process instruction. Thus, the final processing result of the script called by a certain expression in the script is passed to the calling script as the return value of the expression. On the other hand, the processing result of the script called from the request of the client 2 is returned to the client 2.

  Here, the processing result returned to the script may be the processing result ID because it is used in the host 1. Receiving this, the process control unit 10 can acquire the process result entity corresponding to the process result ID from the process result storage unit 50 as necessary. On the other hand, it is necessary to return the processing result entity data to the client 2 as a result of the request. In accordance with such distinction, in the branch of S24, if the script a currently being executed is called from another script b, the process control unit 10 determines the process result ID of the final process result of the script a. Is returned to the script b (S26). In the script b that has received this processing result ID, the remaining processing is continued using the ID. On the other hand, if the script a currently being executed is called by a request from the client 2, the process control unit 10 performs a process corresponding to the process result ID set in the variable id_result at the end of the script a. The result entity is retrieved from the processing result storage unit 50 by the access method 52, set in an HTTP response, and returned to the caller client 2.

  As described above, in the present embodiment, the processing result of each data processing unit 30 (this is an intermediate processing result when viewed from the processing of the entire request) is unique in the processing result storage unit 50 which is a system shared storage area. Is managed by assigning a general processing result ID. In the script describing the process, the process result ID is used to indicate process arguments and return value data. In this way, waste of repeatedly executing the same process can be eliminated. For example, in the above script example, the processing result of the expression (11) before the loop is specified as an argument in the expression (12) in the for loop, but the value of the argument is the number of loop iterations. It doesn't change regardless. Therefore, if the processing result ID of the processing result of the expression (11) once processed is designated as the argument, the processing result of the expression (11) held in the processing result storage unit 50 can be used repeatedly, and therefore a for loop There is no waste of recalculating Eq. (11) each time.

  In this embodiment, since the processing results obtained by the data processing units 30 are stored in the processing result storage unit 50, the processing results at each stage during the overall processing for the request from the client 2 are displayed. Since it can be observed as necessary, it is easy to investigate when a problem occurs. For example, if a process result ID that is a process argument is included in the error code, the process result entity can be read from the process result storage unit 50 using the process result ID indicated in the error code at the time of the error occurrence. Can be investigated.

  In the present embodiment, it is preferable that the Pool object in the processing result storage unit 50 is a synchronous object that can write data to the object and read data from the object in parallel. By doing so, the data processing unit 30 calls the register method 51 of the processing result storage unit 50 to obtain a processing result storage area and obtains a processing result ID before the processing result of itself is produced. The processing result ID can be returned to the processing control unit 10. In response to this, the processing control unit 10 can activate the subsequent data processing unit 30 using the processing result of the data processing unit 30 by using the processing result ID. That is, the subsequent data processing unit 30 can be activated before all the processing of the previous data processing unit 30 is completed. From another viewpoint, the end of the process of the previous data processing unit 30 can be delayed until another data processing unit 30 that uses the result of the process needs the process result. For this reason, efficient linkage processing is possible.

[Second Embodiment]
Next, a second embodiment of the present invention will be described. FIG. 4 is a diagram illustrating a functional configuration of the host 1 according to the second embodiment. In this figure, the client 2 is not shown. The same components as those in FIG. 1 are denoted by the same reference numerals, and detailed description thereof is omitted.

  The host 1 of the second embodiment adds an available range control unit 60 and an effective period management unit 70 to the host 1 of the first embodiment of FIG. 1, and further adds a remove method 54 to the processing result storage unit 50. It is a thing. In addition, the processing contents of the processing control unit 10, each data processing unit 30, and the processing result storage unit 50 are slightly added. Hereinafter, these additional points will be described.

  First, the available range control unit 60 is a unit for management that prevents a request from accessing the processing result of another request in the processing result storage unit 50.

  That is, in the first embodiment, the processing result of each data processing unit 30 activated for request processing is registered in the processing result storage unit 50 and can be used from the processing control unit 10 or another data processing unit 30. However, since various requests arrive at the host 1 and requests from different users also arrive, it is not preferable from the viewpoints of information security and the like that processing results relating to different requests can be used.

  Therefore, the same identification information generated by the available range control unit 60 is assigned to a thread that is activated in association with one request, and the processing result registered in the processing result storage unit 50 is also the identification information and By managing in association with each other, control is performed so that the processing result cannot be used from other requests. Conversely, in a series of threads that are activated during the execution of a single request, it is necessary to share the processing results among the threads for the cooperation of the processes. Even if it can be shared, there is no security problem. Therefore, in this embodiment, unique identification information is given to the request, and the thread activated in the course of executing the request always takes over the identification information set in the activation source thread, and the process By managing the result with identification information, it is controlled so that threads in the same request can refer to the processing result, and threads belonging to different requests cannot refer to the processing result. Thus, the identification information for identifying the request is hereinafter referred to as “available range ID”.

  For this management, the available range control unit 60 includes an available range ID management table 66. In the available range ID management table 66, as shown in FIG. 5, for each available range ID, the processing result of the processing result of each data processing unit 30 in the process of the request to which the available range ID is assigned. An array of IDs is registered.

  The available range control unit 60 can be implemented as a class such as Java (registered trademark), for example. The class name here is VirtualThreadManager. VirtualThreadManager has the following methods:

Open method 61: When this method is called, it generates a unique usable range ID and creates an entry corresponding to the usable range ID in the usable range ID management table 66. The usable range ID may be generated, for example, by assigning a serial number. This method is called from the processing control unit 10 and sets the generated available range ID to the thread executing this method.

Close method 62: When this method is called, the available range ID set in the thread executing this method is acquired, and an entry corresponding to the available range ID is used as an available range ID management table. Delete from 66. At this time, the remove method of the processing result storage unit 50 is called with the processing result ID array of the entry to be deleted as an argument, and each processing result belonging to the usable range is deleted. This method is called from the processing control unit 10 when the processing of the request is completed. The intermediate processing result for the request from the client 2 is basically not required from requests other than that request (however, the request for debugging the script described later is not limited to this), and thus deleted at the end of the request processing. By doing so, the available memory area can be increased.

Add method 63: This method is called when an ID of a processing result newly registered in the processing result storage unit 50 is added to the available range ID management table 66. The process result ID is passed to this method as an argument from the caller. When this method is called, the available range ID set in the thread executing this method is acquired, and the processing result ID array of the entry corresponding to the available range ID in the available range ID management table 66 is acquired. In addition, the processing result ID received as an argument is added.

Validate method 64: This method is used to determine whether or not a thread can use (access) the processing result when the thread tries to access the processing result registered in the processing result storage unit 50. Is. To this method, the processing result ID of the processing result is passed as an argument from the caller. When this thread is called, it acquires the available range ID set in the thread executing this method, and the processing result ID of the entry corresponding to the available range ID in the available range ID management table 66 It is checked whether the processing result ID passed as an argument is included in the array. If it is included, the thread determines that the processing result is usable, and otherwise determines that the thread cannot be used. The determination result is returned to the caller.

Remove method 65: This method is used to delete the processing result ID of the processing result from the processing result ID array of the available range ID management table 66 in accordance with the deletion of the processing result from the processing result storage unit 50. It is done. A processing result ID is passed to this method as an argument from the caller. This method acquires the available range ID set in the thread executing this method, and from the processing result ID array of the entry corresponding to the available range ID in the available range ID management table 66, the argument The processing result ID is deleted.

  Next, the valid period management unit 70 will be described. The effective period management unit 70 is a unit that performs management for suppressing consumption of the storage area of the processing result storage unit 50. That is, in this embodiment, the start point and end point of the valid period are explicitly described in the script, and the processing results of each process described between the start point and the end point in the script are only between the start point and the end point. Valid. In other words, when the progress of the script processing exceeds the end point (that is, when the effective period ends), the processing result of the processing described from the corresponding start point to the end point is deleted from the processing result storage unit 50. By explicitly describing in the script the deletion of processing results that are not used later by the script creator, it is possible to prevent the storage area of the processing result storage unit 50 from being wasted due to processing result data that is not used. .

  In this embodiment, in order to delete the related processing result after the expiration of the validity period, the validity period ID is associated with the processing result registered in the processing result storage unit 50 in this embodiment. The validity period ID is identification information uniquely given to each validity period. When the script is executed and the starting point of the effective period is reached, a unique effective period ID is generated (for example, a serial number is assigned). If the validity period ID is set in the thread that is activated until the end point corresponding to the start point and the processing result is registered in the processing result storage unit 50, the thread that executes the registration process The validity period ID is acquired from the information, and the validity period ID is associated and registered. As a result, when the processing of the script proceeds and exceeds the end point of the effective period, the processing result within the effective period can be collectively deleted from the processing result storage unit 50 by searching the processing result associated with the effective period ID. .

  For this management, the valid period management unit 70 includes a valid period ID management table 75. As shown in FIG. 6, an entry is created for each valid period ID in the valid period ID management table 75, and each data process activated by the process description within the range to which the valid period ID is assigned is entered. An array of IDs of processing results of the unit 30 is registered.

  The valid period management unit 70 can be implemented as a class such as Java (registered trademark), for example. The class name is ScopeManager here. ScopeManager has the following methods.

Open method 71: This method is called at the beginning of the validity period. In other words, when a valid period is set in a script, an expression that calls this method is written at a position corresponding to the start point of the period. This method is called from the processing control unit 10. When called, this method generates a unique effective period ID, registers it in the effective period ID management table 75, and sets the generated effective period ID for the thread executing this method.

Close method 72: This method is called from the processing control unit 10 at the end of the effective period in order to collectively delete processing results of threads belonging to the effective period. When this method is called, it obtains the validity period ID set in the thread executing the method (this is set when the open method is called from the caller), and the validity period ID management table The entry corresponding to the ID is deleted from 75. At this time, the remove method 54 of the processing result storage unit 50 is called with the processing result ID array of the entry to be deleted as an argument, and each processing result belonging to the usable range is deleted. The remove method 54 called at this time deletes the entry of the processing result ID received as an argument from the processing result management table 53, calls the remove method 65 of the available range control unit 60, and sets the processing result ID. A request is made to delete from the available range ID management table 66.

Add method 73: This method is called when an ID of a processing result newly registered in the processing result storage unit 50 is added to the valid period ID management table 75. The process result ID is passed to this method as an argument from the caller. When this method is called, it acquires the effective period ID set in the thread executing this method, and for the processing result ID array of the entry corresponding to the effective period ID in the effective period ID management table 75, The processing result ID received as an argument is added.

Export method 74: This method is used when there is a process result within the valid period set in the script that is to be used in a process outside the valid period. That is, by describing an expression that calls this method in the script, the processing result corresponding to the processing result ID specified in the argument of the method is not deleted even after the validity period including the expression ends. Can be. This method is called with the target process result ID and another valid period ID as an argument, acquires the valid period ID set for the thread executing this method, and the process result ID received as the argument Are moved from the processing result ID array of the entry corresponding to the effective period ID in the effective period ID management table 75 to the processing result ID array of the entry corresponding to another effective period ID received as an argument. Thereby, even when the close method of the validity period management unit 70 is called to delete the validity period ID, the processing result corresponding to the processing result ID moved to the entry of another validity period ID is the processing result. It is not deleted from the storage unit 50.

  Next, changes in the processing result storage unit 50 according to the present embodiment as viewed from the first embodiment will be described.

  First, in the present embodiment, a remove method 54 is added. The remove method 54 is used to delete the processing result entry from the processing result management table 53. For example, this method is called from the available range control unit 60 at the end of processing for a request from the client 2, or is called from the valid period management unit 70 at the end of the valid period. This method takes an array of processing result IDs as an argument.

  The register method 51 and the access method 52 perform the following processing in addition to the processing described in the first embodiment.

  First, when the register method 51 is called, it acquires an available range ID and a valid period ID set for the thread executing the method 51. Then, the add method 63 of the usable range control unit 60 and the add method 73 of the validity period management unit 70 are called, and the processing result ID of the processing result registered in the processing result management table 53 by the register method 51 is passed as an argument. . In response to this, the add method 63 assigns the argument processing result ID to the processing result ID array of the entry corresponding to the usable range ID set in the thread that executes this method in the usable range ID management table 66. to add. In the case of the add method 73, it is added to the valid period ID management table 75.

  Further, the access method 52 investigates whether or not the caller can use the actual process result before returning the process result entity corresponding to the process result ID passed as an argument from the caller. This investigation is performed by calling the validate method 64 of the usable range control unit 60. That is, the access method 52 calls the validate method 64 with the processing result ID received from the caller as an argument. As described above, the validate method 64 acquires the usable range ID set in the thread that executes the method, determines whether the processing result ID passed as an argument can be accessed, and returns the result to the access method 52. . When the access method 52 receives the determination result that the access is possible, the entity data corresponding to the processing result ID is read from the processing result management table 53 and returned to the caller. When a determination result indicating that access is not possible is received, a value indicating that access is not possible is returned to the caller.

  As described above, the effective period management unit 70 has a portion similar to the usable range control unit 60, but the fundamental difference is that the effective period management unit 70 responds to the processing instruction described in the script. In contrast, the usable range control unit 60 is not described in a script, but is always called from the processing control unit 10 at the start and end of request processing.

  Next, the flow of request processing in this embodiment will be described with reference to FIG. In FIG. 7, steps that perform the same processing as the steps in the procedure of the first embodiment shown in FIG. 3 are denoted by the same reference numerals and detailed description thereof is omitted.

  The procedure of FIG. 7 is obtained by adding step S5 before step S10 of the procedure of FIG. 3 and adding step S30 after step S28.

  In this procedure, when the processing control unit 10 of the host 1 receives a request from the client 2, it first calls the open method 61 (VirtualThreadManager.open) of the usable range control unit 60 and receives the usable range ID (S5). ). Subsequent processing after step S10 is basically the same as the procedure of FIG. 3 except for the processing of the last step S30. However, in detail, the process control unit 10 performs the process of setting the assigned usable range ID for the process thread that it calls, which is not in the first embodiment.

  That is, in step S5, the process control unit 10 that has received the available range ID sets the available range ID for the variable of its own thread, and thereafter uses the same for the thread that it calls. Set possible range ID. For example, in the process of executing the script of the request, the data processing unit 30 to be called in step S20 or a script to be called from the script in step S12 after the determination in step S18 is Yes (further derived scripts such as a script to be called from the called script) When a new thread is activated for the execution of (including), an available range ID is set for the thread.

  If a new thread is activated even in the process of the data processing unit 30 called in step S20, the available range ID set in the variable of the own thread is set as the variable of the newly activated thread. Set.

  In this way, by setting the usable range ID to the thread variable in a chain, the same usable range ID is associated with the threads of all the processing units derived from one request. As a result, the usable range to which the process (thread) of each processing unit belongs (that is, from which request is derived) can be understood by looking at the variable of the thread.

  On the other hand, in this embodiment, when registering the processing result of the data processing unit 30 in the processing result storage unit 50, the processing result ID assigned to the processing result can be used set in the data processing unit 30. Since it is registered in the usable range ID management table 66 by the add method 63 in association with the range ID, it can be known to which usable range the processing result belongs by using this table 66.

  Therefore, when the access to the processing result is requested by the access method 52 from the data processing unit 30 or the processing control unit 10, the processing result storage unit 50 uses the validate method 64 to make an inquiry to the available range control unit 60. By doing this, it is possible to know whether the thread of the data processing unit 30 or the processing control unit 10 can access the processing result. If access is possible, the processing result storage unit 50 returns the substance of the processing result to the caller, and otherwise returns information notifying that access is impossible.

  When the processing of the script specified in the request from the client 2 is completed and the processing result is returned to the client 2 (S28), the processing control unit 10 calls the close method 62 of the available range control unit 60 in S30, The available range ID of the request and the processing result information associated therewith are deleted from the available range control unit 60 and the processing result storage unit 50. Since the processing result registered in the request execution process is basically not used by other requests after the processing of the request is completed, there is no problem even if the data is deleted in S30.

  In this procedure, the process control unit 10 uses the open period 71 and the close method 72 described in the script to delete the processing result that is no longer necessary using the effective period management unit 70 immediately. It is executed by calling with.

For example, given the following script:

id4 = Component4.execute (param4);… (21)
ida = function_a (urla, urlb);… (22)
return Component5.merge (id4, ida);… (23)

function_a (URL url1, URL url2) [
sid = (VirtualThread.currentThread ()). getScopeID ();… (24)
ScopeManager.open ();… (25)

id1 = Component1.execute (url1);
id2 = Component2.execute (url2);

id3 = Component3.merge (id1, id2);





ScopeManager.export (id3, sid);… (26)
ScopeManager.close ();… (27)
return id3;
]

  In this script, ScopeManager indicates an effective period management unit 70, and ComponentN (N is an integer of 1 to 5) indicates five different data processing units 30, respectively.

  In addition, in the script executed by Expressions (21) to (23), “function_a ()” and subsequent characters represent function definitions.

  First, the processing of Component4 shown in Expression (21) is executed, and this processing result id4 and the processing result ida when arguments “urla” and “urlb” are specified in function_a are Are merged and the merged result is returned to the caller of the script.

  Function_a shows a procedure for leaving only the processing result corresponding to id3 among the processing results generated in the function and deleting the other processing results.

  In function_a, first, the effective period ID set in the current thread is acquired by executing the expression (24), and stored in the variable sid. The validity period ID stored in sid is the same as the validity period ID of the function_a caller. Next, the validity period ID is given by executing the expression (25) (open method). In the next two expressions, Component 1 and Component 2 perform predetermined processing based on the raw material data indicated by url 1 and url 2, respectively. The results of these two processes are merged by Component 3 according to the following formula. The result ID of the result of the merge process is set in the variable id3. Since this processing result (id3) is also used in, for example, the expression (23) outside the function definition, the id3 is called by calling the export method 74 in the expression (26) before closing the valid period according to the expression (27). Is excluded from the data deletion target at the end of the validity period. Then, by executing the expression (27) (close method), the effective period starting from the expression (25) is closed, and the processing result obtained within the period is deleted from the processing result storage unit 50. In this script example, id3 is excluded from the deletion target, so that each processing result entity corresponding to the processing result IDs id1 and id2 is deleted from the processing result storage unit 50.

  The second embodiment has been described above. According to this embodiment, the processing result in the middle stage of the request is not referred to from another request by the function of the available range control unit 60, so that unauthorized use of the processing result can be prevented. In addition, when the effective period specified in the script has passed by the effective period management unit 70, the processing result generated within that period can be deleted, so that the waste of the storage area of the host 1 can be reduced. . As a result, it is possible to avoid a shortage of memory area in the middle of processing, resulting in an increase in calculation cost and a situation where processing is impossible.

  As is clear from the above description, the functions of the usable range control unit 60 and the validity period management unit 70 are independent. Therefore, in the above-described example, the host 1 including both the usable range control unit 60 and the valid period management unit 70 is shown. Of these, only the usable range control unit 60 and only the valid period management unit 70 are included. Even in the configuration, individual effects of each unit can be obtained.

  In the above example, the processing result of the data processing unit 30 can be accessed only from threads having the same usable range ID, and has been deleted when it is out of the valid period. Thus, if the processing result is deleted or the processing result cannot be accessed from another request, debugging becomes difficult. A modification of the second embodiment that facilitates script debugging will be described below.

  In this modification, a method (setDebug) for instructing the debug mode is prepared in the usable range control unit 60 and the expiration date management unit 70.

When the usable range control unit 60 is implemented as a VirtualThreadManager class and the valid period management unit 70 is implemented as a ScopeManager class, the debug mode can be instructed by describing the following in the script to be debugged.

VirtualThreadManager.setDebug (true);… (31)
ScopeManager.setDebug (true);… (32)

  Regarding the processing of the description shown after such description, the debug mode is handled for each of the available range control unit 60 and the expiration date management unit 70.

  For example, the available range ID management table 66 is provided with a flag indicating whether or not each available range ID is a debug target. This flag is set to a value indicating "not a debug target" by default. When the setDebug method of the available range control unit 60 is called, the available range ID management table 66 indicates whether or not the available range ID set for the thread executing the method is a debug target. Set the flag to a value indicating "debugging target". When the close method 62 of the usable range control unit 60 is called, it determines whether or not the usable range ID set in the thread executing the method is a debug target with reference to the flag, and debugs. If it is the target, the deletion processing of the registration information in the usable range ID management table 66 and the processing for deleting the processing result ID information registered in the entry of the usable range ID from the processing result storage unit 50 are not executed. If it is not a debug target, the information is deleted as described above. Further, when the validate method 64 of the usable range control unit 60 is called, it determines whether or not the usable range ID set in the thread executing the method is a debug target with reference to the flag, and debugs. If it is a target, it indicates that the processing result ID that is an argument of the call to the validate method 64 is usable without checking whether the processing range ID is registered in the usable range ID entry in the usable range ID management table 66. The return value is returned to the processing result storage unit 50.

  Similarly, the valid period management table 75 is provided with a flag indicating whether each valid period ID is a debug target, and this is set by the setDebug method of the valid period management unit 70. When the close method 72 of the valid period control unit 70 is called, it determines whether or not the usable range ID passed from the caller is a debug target by referring to the flag. Processing such as deletion of registration information in the period ID management table 75 and deletion of information on the processing result ID registered in the entry of the effective period ID from the processing result storage unit 50 is not executed.

  The end of the debug mode range can also be indicated by the description of the setDebug method with the argument set to false.

  In this way, while the debug mode is specified, in the process of the close method of the usable range control unit 60 and the expiration date management unit 70, the remove instruction to the processing result storage unit 50 is not performed. Further, in the process of the validate method of the usable range control unit 60, it is possible to prevent the use determination.

  As described above, even after a series of processing ends and the processing result is returned to the client 2, the processing result storage unit 50 retains the processing result within the range of the debug mode, and the remaining processing result is accessed. The usable range control unit 60 is not limited. Therefore, efficient debugging can be performed by examining the processing results remaining in the processing result storage unit 50.

  In the present embodiment, since the processing results are managed in association with the available range IDs by the available range control unit 60, if the available range ID is specified during script debugging, the processing results are used. A processing result group corresponding to the possible range ID can be extracted and analyzed.

[Third Embodiment]
The first and second embodiments have a configuration in which a plurality of data processing units 30 execute unit processing in cooperation with one host 1. On the other hand, the third embodiment has a system configuration in which a plurality of hosts 1P and 1R cooperate in processing via a network 3 such as the Internet, as shown in FIG.

  The internal configuration of the hosts 1P and 1R is the same as that of the second embodiment shown in FIG. However, a function for processing cooperation via the network 3 is added to each unit in the hosts 1P and 1R.

  Hosts 1P and 1R that perform processing cooperation can be classified into a portal host 1P that receives a request from the client 2 and a remote host 1R that operates in response to a request from another host (1P or 1R). In this system, when a user sends a request from the client 2 to the host 1P, the host 1P executes the script specified in the request, and the execution of the script of the remote host 1R is described in the script. If so, the host 1P sends a script execution request to the remote host 1R, and continues its processing in response to the processing result. An instruction to execute a script executed by another host 1P or 1R can also be described in a script executed by the remote host 1R. The request to the host 1P or 1R is described in the form of a URL, similar to the URL (1) exemplified in the first embodiment.

For processing cooperation via the network 3, the processing control unit 10 of each host 1P and 1R has a function of creating a request for instructing another host 1P or 1R processing control unit 10 to execute a script. This function may be incorporated into the eval method 12, for example. For example, the following expression (41) described in the script is “script1” for a host 1P or 1R named host1 (which is a host different from the host host0 executing this script). This indicates that a script named “.groovy” is executed with the data indicated by the processing result ID “id1” as an argument.

id2 = Evaluator.eval (host1, "script1.groovy", id1)… (41)

When receiving the instruction of the expression (41), the processing control unit 10 of the host 0 that is executing the script creates the following HTTP request as a request for the host 1 and transmits it to the host 1.

http: //host1.domain/Evaluator? method = eval & script = script1.groovy & arg0 = id1… (42)

  The processing control unit 10 of the host 1 executes the script indicated by the URL, creates an HTTP response including the processing result ID of the processing result, and returns this to the caller host host 0. Receiving the response, the processing control unit 10 of host0 substitutes the value of the processing result ID included in the response for the variable id2 of the equation (41), and proceeds to the processing of the following equation. Then, when the processing result is used in the subsequent processing, the processing result entity corresponding to the processing result ID “id2” is copied from host1.

That is, when executing the script on host0, if the data processing unit 30 or the processing control unit 10 performs processing using the processing result entity corresponding to the processing result ID “id2”, the data processing unit 30 or the processing control The unit 10 uses the access method 52 to request the entity of id2 from the processing result storage unit 50 of its own host host0. If the entity data corresponding to id2 is held in the processing result storage unit 50 of host0, the entity data is returned to the caller. On the other hand, if the entity data corresponding to id2 is not in the processing result storage unit 50 of host0, the access method 52 creates an HTTP request for requesting the processing result entity corresponding to id2, and this is processed as the processing result entity. To host host1 with The HTTP request created at this time is, for example, as follows.

http: //host1.domain/Pool? method = access & eid = 12345678… (43)

  Here, eid indicates the processing result ID, and 12345678 is the value of the requested processing result ID. In other words, it is the value of the processing result ID returned from host1 in response to the request of equation (41). This request calls the access method 52 of the Pool class of host1 (that is, the processing result storage unit 50) and instructs to pass the processing result entity corresponding to the processing result ID. The processing result entity thus extracted is incorporated into the HTTP response and returned to the processing result storage unit 50 of the caller host0. The processing result storage unit 50 of the host 0 passes the received processing result entity to the data processing unit 30 or the processing control unit 10 that is the access method call source, and associates the processing result entity with the processing result ID to the processing result management table. 53. If the processing result of the remote host is also obtained once in this way and registered in the processing result management table 53 of the own host, it can be read from the processing result management table 53 when the processing result in the future is required. Yes, there is no need to get from a remote host.

  In order to create a request such as the expression (43) in which the access method 52 of the processing result storage unit 50 requests a processing result entity from another host, the host holding the processing result entity is not known. Don't be. For this reason, in the present embodiment, a processing result ID that includes host identification information is used. For example, the processing result ID is obtained by merging the identification information of the host and the identification number unique within the host. When registering the processing result, the register method 51 generates such a processing result ID and assigns it to the processing result. If, for example, the host IP address is used as the host identification information to be incorporated in the processing result ID, when creating an HTTP request for requesting the processing result entity, the IP address is extracted from the processing result ID, and this is designated as the destination host. Can be used. In addition, a network that can be accessed within each host or from each host without using the IP address itself, and a means for replying by searching for the corresponding URL or IP address from the host identification information in the processing result ID. If it is provided in the server 3, the same thing can be done.

Next, the cooperation operation of the plurality of hosts 1P and 1R will be described with an example of a script. Here, it is assumed that the portal host 1P (host0) receives a request for executing the following script from the client 2 (however, only a part of the script is illustrated here. Some processing instructions are described before and after).

id1 = Evaluator.eval (host1, "scriptA.groovy", parameter1)… (51)
id2 = Evaluator.eval (host2, "scriptB.groovy", id1)… (52)
id3 = Evaluator.eval (host2, "scriptC.groovy", id1)… (53)

In this script, (51), (52), and (53) are expressions that instruct execution of the eval method 12 of the processing control unit 10 of the portal host 1P. The arguments of the eval method 12 are only the script name and parameters in the first embodiment that does not consider distributed processing on the network, but in this embodiment, the host name is added. Of the three arguments, the first host1 etc. is the host name. For example, Expression (51) indicates an instruction to cause the remote host1 to execute the script “scriptA.groovy” using the parameter parameter1 and to set the processing result ID of the execution result to the variable id1. .

  When the processing control unit 10 of the portal host 1P first receives the processing instruction of the formula (51) from the processing control procedure interpretation unit 20, it instructs the remote host host1 to execute the script “scriptA.groovy” (42). Create and send an HTTP request similar to Then, when the processing result ID of the processing result of the request is returned from host1, it is set in the variable id1, and the process proceeds to the next processing instruction (52).

  In the processing of (52), the processing control unit 10 of host0 sends an HTTP request to execute “scriptB.groovy” to another remote host host2 with the processing result ID set in the variable id1 as an argument. To do. Upon receiving this request, the processing control unit 10 of host 2 requests the processing result storage unit 50 for the processing result entity corresponding to the processing result ID (id1). However, since the processing result entity is only host1 at this time, the processing result storage unit 50 of host2 creates an HTTP request similar to (43) for obtaining the processing result entity corresponding to the processing result ID (id1). In response to this, the processing result entity returned from host 1 is registered in its own processing result management table 53 in association with the processing result ID. When the process result entity corresponding to the process result ID (id1) is obtained in this way, the host 2 process control unit 10 can proceed with the execution of the script.

  In addition, portal host0 further causes host2 to execute "scriptC.groovy" according to the instruction of (53). Since “scriptC.groovy” takes id1 as an argument, a corresponding processing result entity is required, but host2 has already acquired the processing result entity in the processing of (52) and registered it in the processing result management table 53. Since it can be obtained from the processing result management table 53 at this time, there is no need to make a request to the remote host 1.

  In this way, in this embodiment, a plurality of hosts 1P and 1R cooperate to execute a request from the client 2.

  As described above, the mechanism of distributed processing of requests in the present embodiment has been described. However, in this embodiment as well, a mechanism for preventing unauthorized access to processing results between requests can be used as in the second embodiment.

  That is, in this case, the portal host 1P and the remote host 1R are provided with the same usable range control unit 60 as in the second embodiment. However, the function of the usable range control unit 60 is slightly different between the portal host 1P and the remote host 1R. That is, the usable range control unit 60 of the portal host 1P is the same as that of the second embodiment, and when the open method 61 is called, a unique usable range ID is assigned, whereas the remote host 1R is open. No method is required. This is because the available range ID is assigned for each request from the client 2. The remote host 1R receives and inherits the available range ID assigned by the portal host 1P.

More specifically, when the portal host 1P requests script execution to the remote host 1R during processing for a certain request, this is the available range ID of the request set in the variable of the currently executing thread. Is incorporated into the HTTP request sent to the remote host 1R. For example, it can be included in the request header as follows.

X-VirtualThreadID: 11111… (61)

Here, X-VirtualThreadID indicates an available range ID, and 11111 is a value of the available range ID.

  Receiving such a request, the remote host 1R activates the processing control unit 10 and sets the available range ID to a thread variable. In the remote host 1R, if there is a newly activated thread, the available range ID is inherited by the variable in the same manner as in the second embodiment.

  In this case, registering the inherited usable range ID in the usable range control unit 60 of the remote host 1R is realized by the function extension of the add method 63. That is, when the processing result of the data processing unit 30 in the remote host 1R is registered in the processing result storage unit 50 in the host 1R by the register method 51, the ID of the processing result is registered in the usable range ID management table 66. The add method 63 of the available range control unit 60 in the host 1R is called from the register method 51. At this time, if it is the add method 63 of the second embodiment, the available range ID management table 66 is used. The processing result ID as an argument is only registered in the processing result ID array corresponding to the usable range ID passed as a thread variable at that time. On the other hand, the add method 63 of this embodiment checks whether or not the available range ID received as the thread variable has been registered in the available range ID management table 66. After creating a new entry for the possible range ID, the argument processing result ID is registered in the processing result ID array of the entry.

  Since the script processing result at the remote host 1R is returned to the calling host 1P or 1R in the form of a processing result ID, the calling source uses the processing result ID and the use of the thread that called the script. It can be registered in the usable range ID management table 66 in association with the possible range ID.

  In the access control based on the usable range ID, when the processing result storage unit 50 creates and transmits an HTTP request as described in (43) that requests a processing result entity on another host, Then, the usable range ID is incorporated and sent as in (61) above. The processing result storage unit 50 of the host that has received this request calls the validate method 64 for the usable range control unit 60 in its own host, and the usable range ID embedded in the request header is a process requested by the request. It is determined whether or not the processing result of the result ID is accessible. If access is possible as a result of the determination, an HTTP response including the processing result is returned to the processing result storage unit 50 of the calling host. On the other hand, when it is determined that access is impossible, an HTTP response including data indicating that is returned to the determination result storage unit 50 of the calling host.

  When the processing of the script requested by the request from the client 2 is completed, the processing control unit 10 of the portal host 1P calls the close method 62 of the available range control unit 60 in the host 1P and relates to the request The processing result is deleted. At this time, the available range control unit 60 calls the close method 62 of the available range control unit 60 of the remote host 1R that is called when the request is processed. This call may be made with an HTTP request as in the case of other request transmissions between hosts. The target available range ID is incorporated in the header of this HTTP request.

  This HTTP request may be transmitted to all the remote hosts 1R existing in the system, but only the remote host 1R used for execution when processing the request from the client 2 is narrowed down and deleted. HTTP requests can also be sent. That is, by examining each processing result ID registered in the entry of the usable range ID to be closed in the usable range ID management table 66 of the portal host 1P, it can be seen which host 1P or 1R each processing result is in. This is because the processing result ID includes the identification information of the host that generated it, so that the corresponding remote host 1R can be specified. In the script processing on the remote host 1R, the script processing of another remote host 1R may be called. In this case, the ID of the processing result of the latter remote host 1R may not be returned to the portal host 1P. is there. However, if the remote host 1R that has called the close method 62 calls the close method 62 for another host that it calls, the remote host 1R can process the request from the client 2 even in such a case. It is possible to delete all intermediate processing results generated on the host.

  As described above, the available range ID-based access management in the distributed processing via the network has been described. However, the processing for securing the storage area by the effective period management unit 70 can also support the distributed processing by the same mechanism.

  In other words, if a process in a plurality of hosts 1P and 1R is described between the start point and end point of the valid period in the script, the host executing the script generates a valid period ID at the start point. When calling script processing at another host, the valid period ID may be incorporated into the HTTP request header or the like and transmitted to the called host. The called host registers the valid period ID in the valid period ID management table 75 of its own host. This can be dealt with by expanding the function of the add method 73 in the same manner as registering the usable range ID inherited by the remote host 1R by adding the function of the add method 63 in the management table 66. When calling another script of another host in the script instructed to be executed by the caller, the validity period ID is chained to be inherited by sending the HTTP request including the validity period ID. . The processing control unit 10 of the host B that has received the script execution request from the processing control unit 10 of the host A returns at least the processing result ID of the processing result of the script to the processing control unit 10 of the host A. The control unit 10 can associate the processing result ID with the effective period ID of the thread and register it in the effective period ID management table 75 of the host A.

  In the execution of the script, when the end point of the valid period is reached, the host executing the script sends an HTTP request for requesting the close method 72 to each host called during the valid period. In this request, the target valid period ID is incorporated as a header. The destination of the request for the close process can be determined from each process result ID registered in the entry of the valid period ID in the valid period ID management table 75.

  With the above mechanism, even in a distributed environment, the intermediate processing result generated by the processing within the effective period can be deleted after the effective period ends.

  Note that the start point and end point of another valid period may be described in a script called from within the valid period set for a script. When both scripts are executed on the same host, the validity period management unit 70 assigns different validity period IDs to them, so there is no management problem, but the scripts are distributedly processed on different hosts. In this case, appropriate management cannot be performed if different hosts give valid period IDs having the same value. Therefore, for example, if the identification information of the host to which the valid period ID is added is incorporated in the effective period ID, such a problem can be solved.

  Next, a processing flow of the processing control unit 10 of the portal host 1P and the remote host 1R in this embodiment will be described with reference to the flowcharts of FIGS. This processing procedure corresponds to the system configuration including the usable range control unit 60. 9 and 10, steps that perform the same processing as the steps in the flowcharts of FIGS. 3 and 7 are assigned the same reference numerals, and detailed descriptions thereof are omitted.

  FIG. 9 shows a processing procedure of the processing control unit 10 of the portal host 1P. This procedure is obtained by adding steps S40 to S44 to the procedure of the processing control unit 10 of the second embodiment shown in FIG. That is, in this embodiment, when the process control unit 10 determines that the next process instruction is a script execution instruction in S18, the process control unit 10 further determines whether or not the host that should execute the script is the own host ( S40). This determination can be made by examining the value of the first argument indicating the execution designated host in the description instructing script execution shown in (41). In this determination, if the execution designation host is the own host, the process returns to S12 to call the script. If the execution designation host is another host (remote host 1R), the host information and arguments in the script execution instruction description are obtained. The URL for starting the processing result control unit 10 (servlet) of the other host is created, and an HTTP request corresponding to the URL is sent (S42). And when the HTTP response with respect to the request is received, the process result ID shown in it will be acquired (S44), and it will return to S14.

  FIG. 10 shows a processing procedure of the processing control unit 10 of the remote host 1R. This procedure does not include step S5 of receiving an available range ID from the available range control unit 60 when compared with the processing procedure of the portal host 1P of FIG. This is because the usable range ID is given to the request of the client 2 by the portal host 1P, and other hosts called for the request may inherit the usable range ID. Further, in the procedure of the portal host 1P, after the processing of the requested script is completed (the determination result in S16 is No), it is determined whether the script is a script called from another script (S24). In the remote host 1R, since the script to be executed is always called from another script, the determination processing in S24 is not necessary, and simply performing processing for returning the ID of the final processing result of the script to the caller. Good (S26). Since the processing control unit 10 of the remote host 1R does not generate the usable range ID (open method 61) as described above when starting the processing of the requested script, when the script ends. Then, the related information is not deleted (close method 62). The deletion of the related information is performed based on an instruction from the portal host 1R when the processing of the script designated by the request from the client 2 is completed.

  According to the third embodiment described above, the same effects as those of the first and second embodiments can be obtained even in a system configuration in which a plurality of hosts 1P and 1R perform processing in cooperation.

  In this embodiment, each unit (for example, the data processing unit 30) in each host 1P or 1R requests data (intermediate processing result) required for processing from the processing result storage unit 50 in its own host, Only when the processing result storage unit 50 does not have the requested data, the data is acquired from the host having the data and is registered in the processing result storage unit 50. As a result, if the actual data of the processing result is transferred once from the called host to the calling host and copied, the processing result copied when the processing result data is required at the calling host thereafter. The entity can be reused. On the other hand, in the method of Patent Document 2, each processing server stores its processing result (snapshot), but the processing result of another processing server that it calls can be copied and reused. Not up to. For this reason, although the network load is large in Patent Document 2, such a problem can be solved or reduced in the present embodiment.

  In the present embodiment, the processing results held in the hosts 1P and 1R are managed in association with the available range ID by the available range control unit 60, respectively. For this reason, if a usable range ID is specified during script debugging, a processing result corresponding to the usable range ID can be acquired from each of the hosts 1P and 1R and analyzed.

  In the above description, the host (calling destination) instructed to execute the script from another host (calling source) returns only the processing result ID to the calling source when the script processing is completed. When the processing result becomes necessary, the caller obtains the processing result entity from the callee using the processing result ID and copies it to the own processing result storage unit 50. However, this is only an example of a processing procedure. Instead, when the call destination finishes the script processing, both the processing result ID and the processing result entity are sent to the calling source, and the calling source registers this in the processing result storage unit 50 of its own host. Procedures can also be adopted. Further, in this case, only the processing result entity is sent from the call destination to the call source, and the call source that receives this process assigns a new process result ID to the process result entity and registers it in the process result storage unit 50. It is also possible to use a procedure.

[Fourth Embodiment]
In the third embodiment, there is no particular limitation on how the remote host 1R obtains a script requested to be executed from another host. However, if a request to the remote host 1R is made, the script name of a script in an arbitrary location on the network such as the Internet can be designated as an execution target, or the script itself can be incorporated in the request. In this case, an arbitrary script may be executed from an unknown host, which may cause a security problem. The fourth embodiment addresses such a problem.

  FIG. 11 shows the system configuration of this embodiment. This system is obtained by adding script management units 80P and 80R to the hosts 1P and 1R, and is otherwise the same as the system of the third embodiment.

  In the present embodiment, the remote host 1R acquires a script from the portal host 1P and executes it. A script from other than the portal host 1P is not accepted.

  All scripts that can be executed by the distributed processing system of this embodiment are registered in the script management unit 80P of the portal host 1P. Each script is assigned identification information (called a script ID) that is unique within the system. In the script execution instruction to the remote host 1R, the script ID to be executed is described. Upon receiving this execution instruction, the processing control unit 10 of the remote host 1R requests the script entity indicated by the script ID from the script management unit 80R in the host. The script management unit 80R that has received this request returns the script entity corresponding to the requested script ID to the processing control unit 10 if it has. If not, a request including the script ID information is transmitted to the script management unit 80P of the portal host 1P using, for example, HTTP, the script entity is acquired, and passed to the processing control unit 10. Here, if the acquired script entity is registered in the script management unit 80R in association with the script ID, it is not necessary to acquire a script from the portal host 1P when a request for the script ID is received in the future. .

  According to such a mechanism, the remote host 1R can only execute a script that it has from the beginning or that is acquired from the portal host 1P, so that an arbitrary script can be executed from an unknown host. That doesn't happen.

  In the above example, the remote host 1R has acquired the script only from the portal host 1P, but it is also possible to acquire the script from the remote host 1R. In this case, a script ID incorporating the identification information of the host 1P or 1R having the script entity is used. If the script management unit 80P or 80R of each host does not have the requested script, the script management unit 80P or 80R sends a request for requesting a script entity to the host indicated by the script ID to acquire the script. Even with this mechanism, a script on an unknown host cannot be executed.

[Fifth Embodiment]
In the third embodiment, the distribution of processing to the remote host 1R is script units. In contrast, in the fifth embodiment, a system configuration in the case where distribution is performed in units of processing of the data processing unit 30 will be described.

  The system configuration of the fifth embodiment is shown in FIG. In FIG. 12, the same reference numerals are given to the constituent elements that come to the constituent elements shown in FIG. 1.

In this embodiment, only the portal host 1P executes the script, and the remote host 1R is not provided with the processing control unit 10. Each processing instruction in the script describes information about the host that executes the processing as follows.

id1 = Host1.Component1.execute (url1)

In this instruction, Host1 indicates the host that executes the processing. When receiving the processing instruction, the processing control unit 10 of the portal host 1P determines whether or not the host information in the processing instruction is that of the own host. A URL for executing the processing is created for another host, and an HTTP request is sent to the other host based on the URL. For example, the URL to be created is as follows.

http: //host1.domain/Component1? method = execute & arg1 = url1

This request is accepted by the web server of the remote host 1R. Then, the web server activates a servlet (data processing unit 30-1) indicated by the name Component1, and executes processing based on the raw material data indicated by the argument url1. The result of this processing is registered in the processing result storage unit 50 of the remote host 1R, and the processing result ID assigned by the processing result storage unit 50 at that time is returned to the data processing unit 30-1. The data processing unit 30-1 returns the processing result ID to the web server, and the web server returns an HTTP response including the processing result ID to the processing control unit 10 of the portal host 1P. When the data processing unit 30 of the portal host 1P needs the processing result, it is provided to the data processing unit 30 if the processing result storage unit 50 of the portal host 1P has it, as in the third embodiment. If not, it is obtained from the processing result storage unit 50 of the remote host 1R and provided to the data processing unit 30. The same applies when the remote host 1R needs the processing result of another remote host 1R.

  In each of the embodiments described above, requests and responses between the client and the host and between the hosts are transferred using HTTP, but this is merely an example. In the above example, the host 1 executes the script and the request is made by designating the script to be executed. However, this is just an example.

It is a figure which shows the system configuration | structure of 1st Embodiment of this invention. It is a figure which shows the data structure of a process result management table. It is a flowchart which shows the processing content of a process control part. It is a figure which shows the structure of the host of 2nd Embodiment of this invention. It is a figure which shows the data structure of an available range ID management table. It is a figure which shows the data structure of an effective period ID management table. It is a flowchart which shows the process of the process control part in 2nd Embodiment. It is a figure which shows the system configuration | structure of 3rd Embodiment. It is a flowchart which shows the process of the process control part of the portal host of 3rd Embodiment. It is a flowchart which shows the process of the process control part of the remote host of 3rd Embodiment. It is a figure which shows the system configuration | structure of 4th Embodiment. It is a figure which shows the system configuration | structure of 5th Embodiment.

Explanation of symbols

  1 host, 2 clients, 10 processing control unit, 12 eval method, 20 processing control procedure interpretation unit, 30 data processing unit, 32 execute method, 40 raw material data storage unit, 50 processing result storage unit, 51 register method, 52 access method 53 Processing result management table.

Claims (9)

A cooperative processing device that executes a requested process by operating a plurality of data processing units, each of which executes a predetermined unit process,
A shared storage unit for storing processing result data of the plurality of data processing units;
When a registration request for processing result data from the data processing unit to the shared storage unit is received, unique processing result identification information is given to the processing result data, and the given processing result identification information is used as the processing result. Processing result registration means for registering in the shared storage unit in association with data and returning the processing result identification information to the data processing unit as a return value for the registration request;
When receiving an acquisition request specifying processing result identification information from the data processing unit, processing result providing means for acquiring processing result data corresponding to the processing result identification information from the shared storage unit and returning it to the data processing unit When,
With
When each data processing unit is activated by an activation request including processing result identification information as a processing parameter, the data processing unit sends an acquisition request including the processing result identification information to the processing result providing unit, and corresponds to the processing result identification information processing result received data, with its own execution unit processing using the processing result data, have rows registration request to the processing result registration means for storing the processing result data obtained by the unit process,
The cooperative processing device receives a request for execution of a processing procedure including a plurality of unit processes from the client device, and sequentially activates each data processing unit corresponding to each unit processing described in the processing procedure to execute each unit processing. A processing control unit to be executed;
Each of the data processing units returns processing result identification information received from the processing result registration unit in response to the registration request to the processing control unit,
The processing control unit passes the processing result identification information returned from the data processing unit as a processing parameter to another data processing unit that performs unit processing using the processing result data of the data processing unit,
The cooperation processing device
A usable range identification information giving means for giving unique usable range identification information to the execution request of the processing procedure from the client device, and passing the given usable range identification information to the processing control unit;
Usable range information management means for holding one or more processing result identification information corresponding to each usable range identification information;
Further comprising
The processing control unit passes the usable range identification information given from the usable range identification information giving unit to the data processing unit activated in the processing procedure,
The data processing unit passes the usable range identification information passed from the processing control unit to the processing result registration unit at the time of a registration request to the processing result registration unit,
The processing result registration unit associates the usable range identification information passed from the data processing unit at the time of the registration request with the processing result identification information corresponding to the processing result data that is the target of the registration request, and Register with the possible range information management means,
The data processing unit passes the usable range identification information passed from the processing control unit to the processing result providing unit in an acquisition request to the processing result providing unit,
The processing result providing unit holds the processing result identification information related to the acquisition request from the data processing unit in the usable range information management unit in association with the usable range identification information passed at the time of the acquisition request. Whether or not, and only when it is held, processing result data corresponding to the processing result identification information is acquired from the shared storage unit and returned to the data processing unit,
A cooperative processing apparatus characterized by that. A debug mode management means for storing that the usable range identification information is a debug target when a debug mode with usable range identification information is instructed;
The process control unit, when executing a debug mode instruction during the process procedure, sends a debug mode instruction with usable range identification information of the process procedure to the debug mode management means,
The processing result providing means refers to the debug mode management means to determine whether or not the usable range identification information passed at the time of the acquisition request is a debug target. Regardless of whether or not the processing result identification information that is the target of the request is held in the usable range information management unit in association with the usable range identification information, the processing result providing unit includes the processing result identification information. Provide corresponding processing result data to the data processing unit,
The cooperation processing apparatus according to claim 1 . A cooperative processing device that executes a requested process by operating a plurality of data processing units, each of which executes a predetermined unit process,
A shared storage unit for storing processing result data of the plurality of data processing units;
When a registration request for processing result data from the data processing unit to the shared storage unit is received, unique processing result identification information is given to the processing result data, and the given processing result identification information is used as the processing result. Processing result registration means for registering in the shared storage unit in association with data and returning the processing result identification information to the data processing unit as a return value for the registration request;
When receiving an acquisition request specifying processing result identification information from the data processing unit, processing result providing means for acquiring processing result data corresponding to the processing result identification information from the shared storage unit and returning it to the data processing unit When,
With
When each data processing unit is activated by an activation request including processing result identification information as a processing parameter, the data processing unit sends an acquisition request including the processing result identification information to the processing result providing unit, and corresponds to the processing result identification information Receives the processing result data, executes its own unit processing using the processing result data, and makes a registration request to the processing result registration means for storing the processing result data obtained by the unit processing,
The cooperative processing device receives a request for execution of a processing procedure including a plurality of unit processes from the client device, and sequentially activates each data processing unit corresponding to each unit processing described in the processing procedure to execute each unit processing. A processing control unit to be executed;
Each of the data processing units returns processing result identification information received from the processing result registration unit in response to the registration request to the processing control unit,
The processing control unit passes the processing result identification information returned from the data processing unit as a processing parameter to another data processing unit that performs unit processing using the processing result data of the data processing unit,
The cooperation processing device
In response to the effective period start request, an effective period starting unit that assigns unique effective period identification information and returns the granted effective period identification information to the processing control unit,
Valid period information management means for holding one or more processing result identification information corresponding to each valid period identification information;
In response to an effective period end request specifying effective period identification information, the shared storage unit stores processing result data corresponding to each processing result identification information corresponding to the effective period identification information held in the effective period information management unit. Expiration date expiry means to be removed from,
Further comprising
The process control unit, when executing an instruction to start an effective period in the processing procedure, makes an effective period start request to the effective period start unit, and in response to the request, the effective period start unit assigns the effective period start unit The period identification information is received, and the validity period identification information is passed to the data processing unit that is activated until the end instruction corresponding to the validity period start instruction in the processing procedure,
The data processing unit passes the valid period identification information passed from the processing control unit to the processing result registration unit at the time of a registration request to the processing result registration unit,
The processing result registration means associates the validity period identification information passed at the time of a registration request from the data processing unit with the processing result identification information corresponding to the processing result data that is the object of the registration request, and Register with information management means,
The process control unit, when executing an instruction to end an effective period in the processing procedure, makes an effective period end request with effective period identification information of the effective period to the effective period end unit.
Collaboration processing apparatus you wherein a. In response to the deletion target exclusion request accompanied by the processing result identification information, further comprising a deletion target exclusion means for excluding the processing result data corresponding to the processing result identification information from the deletion target from the shared storage unit by the valid period ending means. ,
When the deletion target exclusion instruction specifying the processing result identification information is described in the processing procedure, the processing control unit causes the deletion target exclusion unit to execute a deletion target exclusion request with the processing result identification information. ,
The cooperation processing apparatus according to claim 3 . A debug mode management means for storing that the valid period identification information is a debug target when a debug mode with valid period identification information is instructed;
The process control unit, when executing a debug mode instruction during the processing procedure, sends a debug mode instruction with valid period identification information to the debug mode management means,
The effective period ending means obtains whether or not the effective period identification information specified in the effective period end request is a debug target by referring to the debug mode management means. Do not delete the processing result data corresponding to each processing result identification information corresponding to the validity period identification information held in the period information management means from the shared storage unit,
The cooperation processing apparatus according to claim 3 . A cooperative processing system that executes a requested process by operating a plurality of host devices connected via a network in a cooperative manner,
Each host device
One or more data processing units each executing unit processing;
A shared storage unit for storing processing result data of the data processing unit;
When a registration request for processing result data from the data processing unit to the shared storage unit is received, unique processing result identification information is given to the processing result data, and the given processing result identification information is used as the processing result. Processing result registration means for registering in the shared storage unit in association with data and returning the processing result identification information to the data processing unit as a return value for the registration request;
When receiving an acquisition request specifying processing result identification information from the data processing unit, processing result providing means for acquiring processing result data corresponding to the processing result identification information from the shared storage unit and returning it to the data processing unit When,
With
When each data processing unit is activated by an activation request including processing result identification information as a processing parameter, the data processing unit sends an acquisition request including the processing result identification information to the processing result providing unit, and corresponds to the processing result identification information The processing result data is received, the unit processing is executed using the processing result data, and a registration request is made to the processing result registration means to store the processing result data obtained by the unit processing. If the data processing unit is called from another host device, the processing result identification information received as a return value for the registration request is returned to the other host device that is the call source,
The processing result providing means indicates the processing result identification information when there is no processing result data corresponding to the processing result identification information specified in the acquisition request from the data processing unit in the shared storage unit of the own host device. An acquisition request with the processing result identification information is made to the shared storage unit of the host device, and the processing result data returned from the shared storage unit in response to the acquisition request is passed to the data processing unit, and the processing The result data is registered in the shared storage unit of the own host device in association with the processing result identification information,
The plurality of host devices include, as one of the data processing units, a processing control unit that controls execution of a processing procedure including a plurality of unit processes, and the processing control among the plurality of data processing units in the host device. Only the activation request to the data processing unit in the other host device,
The processing control unit of the host device can issue an activation request only to the processing control unit among a plurality of data processing units of other host devices,
The plurality of host devices are classified into a portal host device that receives a processing procedure execution request from a client device, and other remote host devices,
The portal host device
A usable range identification information giving means for giving unique usable range identification information to a processing procedure execution request from a client device, and passing the given usable range identification information to the processing control unit of the portal host device;
Usable range information management means for holding one or more processing result identification information corresponding to each usable range identification information;
With
The processing control unit of the portal host device sends the usable range identification information given from the usable range identification information giving unit to the data processing unit in the own host device that is activated in the processing procedure. When the processing procedure includes an instruction to execute the second processing procedure for another host device, a request to execute the second processing procedure is sent to the processing control unit of the other host device. Pass along with its available range identification information,
The remote host device is
Usable range information management means for holding one or more processing result identification information corresponding to each usable range identification information;
Means for registering the usable range identification information received together with the execution request in the usable range information managing means in the host device when a processing procedure execution request is received from another host device;
With
The processing control unit of the remote host device uses the usable range identification information received together with the execution request of the processing procedure from the other host device, and the data processing unit in the own host device that starts in the processing procedure And when the execution instruction of the second processing procedure for another host device is included in the processing procedure, the processing control unit of the other host device is informed of the second processing procedure. Pass the execution request along with its available range identification information,
The data processing unit of each host device sends the usable range identification information passed from the processing control unit of the host device to the processing result registration unit at the time of a registration request to the processing result registration unit of the host device. Hand over,
The processing result registration unit of each host device uses the usable range identification information passed from the data processing unit of the host device at the time of the registration request to the processing corresponding to the processing result data that is the target of the registration request. In association with the result identification information, register it in the usable range information management means of the own host device,
The data processing unit of each host device sends the usable range identification information passed from the processing control unit of its own host device to the processing result providing unit at the time of an acquisition request to the processing result providing unit of its own host device. Hand over,
The processing result providing means of each of the host devices, when the processing result identification information related to the acquisition request from the data processing unit of the own host device is in the shared storage unit of the own host device, Corresponding to the usable range identification information passed along with the acquisition request, it is checked whether it is held in the usable range information management means of the own host device, and if it is held, it corresponds to the processing result identification information Processing result data to be acquired from the shared storage unit and returned to the data processing unit, and processing result identification information related to an acquisition request from the data processing unit of the own host device is not in the shared storage unit of the own host device Makes an acquisition request with the processing result identification information and the usable range identification information to the shared storage unit of the host device indicated by the processing result identification information,
When the processing result providing unit of each host device receives an acquisition request with processing result identification information and usable range identification information from the processing result providing unit of another host device, the processing result identification information is automatically stored in the processing result providing unit. It is checked whether or not the usable range management means in the host device is held in association with the usable range identification information, and if it is held, the processing result data corresponding to the processing result identification information is automatically stored. Acquired from the shared storage unit of the host device and returned to the processing result providing means of the other device;
A cooperative processing system characterized by that. A cooperative processing system that executes a requested process by operating a plurality of host devices connected via a network in a cooperative manner,
Each host device
One or more data processing units each executing unit processing;
A shared storage unit for storing processing result data of the data processing unit;
When a registration request for processing result data from the data processing unit to the shared storage unit is received, unique processing result identification information is given to the processing result data, and the given processing result identification information is used as the processing result. Processing result registration means for registering in the shared storage unit in association with data, and returning the processing result identification information to the data processing unit as a return value for the registration request;
When receiving an acquisition request specifying processing result identification information from the data processing unit, processing result providing means for acquiring processing result data corresponding to the processing result identification information from the shared storage unit and returning it to the data processing unit When,
With
When each data processing unit is activated by an activation request including processing result identification information as a processing parameter, the data processing unit sends an acquisition request including the processing result identification information to the processing result providing unit, and corresponds to the processing result identification information The processing result data is received, the unit processing is executed using the processing result data, and a registration request is made to the processing result registration means to store the processing result data obtained by the unit processing. If the data processing unit is called from another host device, the processing result identification information received as a return value for the registration request and the corresponding processing result data registered in the shared storage unit at the caller Return to some other host device,
When each data processing unit calls a data processing unit of another host device for partial processing in the execution of its unit processing, it is returned from the data processing unit of the other host device in response to the call. processing result identification information and the processing result data registered in said shared storage unit that,
The plurality of host devices include, as one of the data processing units, a processing control unit that controls execution of a processing procedure including a plurality of unit processes, and the processing control among the plurality of data processing units in the host device. Only the activation request to the data processing unit in the other host device,
The processing control unit of the host device can issue an activation request only to the processing control unit among a plurality of data processing units of other host devices,
The plurality of host devices are classified into a portal host device that receives a processing procedure execution request from a client device, and other remote host devices,
The portal host device
A usable range identification information giving means for giving unique usable range identification information to a processing procedure execution request from a client device, and passing the given usable range identification information to the processing control unit of the portal host device;
Usable range information management means for holding one or more processing result identification information corresponding to each usable range identification information;
With
The processing control unit of the portal host device sends the usable range identification information given from the usable range identification information giving unit to the data processing unit in the own host device that is activated in the processing procedure. When the processing procedure includes an instruction to execute the second processing procedure for another host device, a request to execute the second processing procedure is sent to the processing control unit of the other host device. Pass along with its available range identification information,
The remote host device is
Usable range information management means for holding one or more processing result identification information corresponding to each usable range identification information;
Means for registering the usable range identification information received together with the execution request in the usable range information managing means in the host device when a processing procedure execution request is received from another host device;
With
The processing control unit of the remote host device uses the usable range identification information received together with the execution request of the processing procedure from the other host device, and the data processing unit in the own host device that starts in the processing procedure And when the execution instruction of the second processing procedure for another host device is included in the processing procedure, the processing control unit of the other host device is informed of the second processing procedure. Pass the execution request along with its available range identification information,
The data processing unit of each host device sends the usable range identification information passed from the processing control unit of the host device to the processing result registration unit at the time of a registration request to the processing result registration unit of the host device. Hand over,
The processing result registration unit of each host device uses the usable range identification information passed from the data processing unit of the host device at the time of the registration request to the processing corresponding to the processing result data that is the target of the registration request. In association with the result identification information, register it in the usable range information management means of the own host device,
The data processing unit of each host device sends the usable range identification information passed from the processing control unit of its own host device to the processing result providing unit at the time of an acquisition request to the processing result providing unit of its own host device. Hand over,
The processing result providing means of each of the host devices, when the processing result identification information related to the acquisition request from the data processing unit of the own host device is in the shared storage unit of the own host device, Corresponding to the usable range identification information passed along with the acquisition request, it is checked whether it is held in the usable range information management means of the own host device, and if it is held, it corresponds to the processing result identification information Processing result data to be acquired from the shared storage unit and returned to the data processing unit, and processing result identification information related to an acquisition request from the data processing unit of the own host device is not in the shared storage unit of the own host device Makes an acquisition request with the processing result identification information and the usable range identification information to the shared storage unit of the host device indicated by the processing result identification information,
When the processing result providing unit of each host device receives an acquisition request with processing result identification information and usable range identification information from the processing result providing unit of another host device, the processing result identification information is automatically stored in the processing result providing unit. It is checked whether or not the usable range management means in the host device is held in association with the usable range identification information, and if it is held, the processing result data corresponding to the processing result identification information is automatically stored. Acquired from the shared storage unit of the host device and returned to the processing result providing means of the other device;
A cooperative processing system characterized by that. A cooperative processing system that executes a requested process by operating a plurality of host devices connected via a network in a cooperative manner,
Each host device
One or more data processing units each executing unit processing;
A shared storage unit for storing processing result data of the data processing unit;
When a registration request for processing result data from the data processing unit to the shared storage unit is received, unique processing result identification information is given to the processing result data, and the given processing result identification information is used as the processing result. Processing result registration means for registering in the shared storage unit in association with data and returning the processing result identification information to the data processing unit as a return value for the registration request;
When receiving an acquisition request specifying processing result identification information from the data processing unit, processing result providing means for acquiring processing result data corresponding to the processing result identification information from the shared storage unit and returning it to the data processing unit When,
With
When each data processing unit is activated by an activation request including processing result identification information as a processing parameter, the data processing unit sends an acquisition request including the processing result identification information to the processing result providing unit, and corresponds to the processing result identification information The processing result data is received, the unit processing is executed using the processing result data, and a registration request is made to the processing result registration means to store the processing result data obtained by the unit processing. If the data processing unit is called from another host device, the processing result identification information received as a return value for the registration request is returned to the other host device that is the call source,
The processing result providing means indicates the processing result identification information when there is no processing result data corresponding to the processing result identification information specified in the acquisition request from the data processing unit in the shared storage unit of the own host device. An acquisition request with the processing result identification information is made to the shared storage unit of the host device, and the processing result data returned from the shared storage unit in response to the acquisition request is passed to the data processing unit, and the processing The result data is registered in the shared storage unit of the own host device in association with the processing result identification information,
The plurality of host devices include, as one of the data processing units, a processing control unit that controls execution of a processing procedure including a plurality of unit processes, and the processing control among the plurality of data processing units in the host device. Only the activation request to the data processing unit in the other host device,
The processing control unit of the host device can issue an activation request only to the processing control unit among a plurality of data processing units of other host devices,
Each of the host devices is
In response to the effective period start request, an effective period starting unit that assigns unique effective period identification information and returns the granted effective period identification information to the processing control unit,
Valid period information management means for holding one or more processing result identification information corresponding to each valid period identification information;
In response to an effective period end request specifying effective period identification information, the shared storage unit stores processing result data corresponding to each processing result identification information corresponding to the effective period identification information held in the effective period information management unit. Expiration date expiry means to be removed from,
Further comprising
The process control unit, when executing an instruction to start an effective period in the processing procedure, makes an effective period start request to the effective period start unit, and in response to the request, the effective period start unit assigns the effective period start unit The period identification information is received, and the validity period identification information is sent to the data processing unit and the processing control unit of another host device that are activated before the termination instruction corresponding to the validity period start instruction in the processing procedure. Against
The data processing unit passes the valid period identification information passed from the processing control unit to the processing result registration unit at the time of a registration request to the processing result registration unit,
The processing result registration means associates the validity period identification information passed at the time of a registration request from the data processing unit with the processing result identification information corresponding to the processing result data that is the object of the registration request, and Register with information management means,
The process control unit, when executing an instruction to end an effective period in the processing procedure, makes an effective period end request with effective period identification information of the effective period to the effective period end unit.
A cooperative processing system characterized by that. A cooperative processing system that executes a requested process by operating a plurality of host devices connected via a network in a cooperative manner,
Each host device
One or more data processing units each executing unit processing;
A shared storage unit for storing processing result data of the data processing unit;
When a registration request for processing result data from the data processing unit to the shared storage unit is received, unique processing result identification information is given to the processing result data, and the given processing result identification information is used as the processing result. Processing result registration means for registering in the shared storage unit in association with data and returning the processing result identification information to the data processing unit as a return value for the registration request;
When receiving an acquisition request specifying processing result identification information from the data processing unit, processing result providing means for acquiring processing result data corresponding to the processing result identification information from the shared storage unit and returning it to the data processing unit When,
With
When each data processing unit is activated by an activation request including processing result identification information as a processing parameter, the data processing unit sends an acquisition request including the processing result identification information to the processing result providing unit, and corresponds to the processing result identification information The processing result data is received, the unit processing is executed using the processing result data, and a registration request is made to the processing result registration means to store the processing result data obtained by the unit processing. If the data processing unit is called from another host device, the processing result identification information received as a return value for the registration request and the corresponding processing result data registered in the shared storage unit at the caller Return to some other host device,
When each data processing unit calls a data processing unit of another host device for partial processing in the execution of its unit processing, it is returned from the data processing unit of the other host device in response to the call. processing result identification information and the processing result data registered in said shared storage unit that,
The plurality of host devices include, as one of the data processing units, a processing control unit that controls execution of a processing procedure including a plurality of unit processes, and the processing control among the plurality of data processing units in the host device. Only the activation request to the data processing unit in the other host device,
The processing control unit of the host device can issue an activation request only to the processing control unit among a plurality of data processing units of other host devices,
Each of the host devices is
In response to the effective period start request, an effective period starting unit that assigns unique effective period identification information and returns the granted effective period identification information to the processing control unit,
Valid period information management means for holding one or more processing result identification information corresponding to each valid period identification information;
In response to an effective period end request specifying effective period identification information, the shared storage unit stores processing result data corresponding to each processing result identification information corresponding to the effective period identification information held in the effective period information management unit. Expiration date expiry means to be removed from,
Further comprising
The process control unit, when executing an instruction to start an effective period in the processing procedure, makes an effective period start request to the effective period start unit, and in response to the request, the effective period start unit assigns the effective period start unit The period identification information is received, and the validity period identification information is sent to the data processing unit and the processing control unit of another host device that are activated before the termination instruction corresponding to the validity period start instruction in the processing procedure. Against
The data processing unit passes the valid period identification information passed from the processing control unit to the processing result registration unit at the time of a registration request to the processing result registration unit,
The processing result registration means associates the validity period identification information passed at the time of a registration request from the data processing unit with the processing result identification information corresponding to the processing result data that is the object of the registration request, and Register with information management means,
The process control unit, when executing an instruction to end an effective period in the processing procedure, makes an effective period end request with effective period identification information of the effective period to the effective period end unit.
A cooperative processing system characterized by that.

Images