Data processing method and data processing program

1 . A method implemented by a data processing device that includes:

one or more storage devices storing

a common digital twin configured to store first processed data obtained by processing source data received from one or more sensor devices, and

a plurality of specific digital twins, each specific digital twin being associated with a corresponding service of a plurality of services and being configured to store second processed data obtained by processing the first processed data based on a processing rule corresponding to the corresponding service, the first processed data being data to be processed in common to the plurality of services, the second processed data being data to be processed specifically to the corresponding service of the plurality of services; and

a processor circuitry coupled to the one or more storage devices, the method comprising:

the processor circuitry receiving a request from any of devices including the one or more sensor devices and a plurality of service processors, each service processor corresponding to a respective one of the plurality of services; and

the processor circuitry accessing, in response to the received request, either the common digital twin or at least any one of the plurality of specific digital twins, in accordance with a predetermined data distribution rule, the accessing including:

(1) the processor circuitry writing, in response to the request being a write request including a first source data from any one of the one or more sensor devices, a first processed data item obtained from the first source data to the common digital twin;

(2) in response to the request being a read request from a specific service processor among the plurality of service processors,

(2-1) the processor circuitry accessing, among the plurality of specific digital twins, a specific digital twin corresponding to the specific service processor to retrieve the second processed data from the specific digital twin and provide the retrieved second processed data to the specific service processor, and

(2-2) in a case where no specific second processed data to be read by the read request is determined to exist in the specific digital twin, the processor circuitry retrieving the first processed data from the common digital twin to provide the retrieved first processed data to the specific service processor; and

(3) the processor circuitry writing, in response to the request being a write request including the second processed data from the specific service processor, the second processed data included in the write request from the specific service processor to the specific digital twin corresponding to the specific service processor.

2 . The method according to claim 1 , wherein

when a request source of the received request has a specific distribution rule, the processor circuitry obtaining the specific distribution rule associated with the request source of the received request, and

the processor circuitry accesses, in response to the received request, the common digital twin or the specific digital twin in accordance with the obtained specific distribution rule.

3 . The method according to claim 1 , wherein the each service processor of the plurality of service processors is configured to perform processing including:

(1) transmitting the read request to the processor circuitry to process;

(2) in a case where the first processed data is received in response to the transmitting of the read request,

(2-1) generating the second processed data obtained by processing the first processed data, and one or more pieces of the and

(2-2) transmitting the write request including the generated second processed data to the processor circuitry; and

(3) in a case where the second processed data is received in response to the transmitting of the read request, processing the second processed data received from the processor circuitry.

4 . The method according to claim 1 , wherein

the each service processor makes access of reading and writing to data of a same attribute in the common digital twin and the specific digital twin.

5 . The method according to claim 3 , wherein

in a case where the specific processing processor switches between execution and non-execution of a process in which the first processed data is read from the common digital twin and the second processed data that has been processed is generated,

the analysis circuit is configured to:

read the first processed data from the common digital twin at a time of the non-execution of the specific processing circuit; and

read the second processed data from the specific digital twin at a time of the execution of the specific processing circuit.

6 . The method according to claim 3 , wherein

the analysis circuit is configured to:

read, based on data accuracy or an update frequency of the source data, the second processed data from the specific digital twin when the data accuracy of the source data is low accuracy or the update frequency of the source data is a low update frequency; and

read the first processed data from the common digital twin when the data accuracy of the source data is high accuracy or the update frequency of the source data is a high update frequency.

7 . The method according to claim 1 , wherein

in accordance with the predetermined data distribution rule,

the first processed data obtained by processing the received source data is written in the common digital twin, and

the each of the plurality of service processors

writes the second processed data obtained by processing the source data in the specific digital twin for each of the plurality of services.

8 . A non-transitory computer-readable recording medium storing a data processing program to be executed by a computer that includes:

one or more storage devices that store

a common digital twin configured to store first processed data obtained by processing source data received from one or more sensor devices, and

a plurality of specific digital twins, each specific digital twin being associated with a corresponding service of a plurality of services and being configured to store second processed data obtained by processing one or more pieces of the source data based on a processing rule corresponding to the corresponding service, the first processed data being data to be processed in common to the plurality of services, the second processed data being data to be processed specifically to the corresponding service of the plurality of services; and

a processor circuitry coupled to the one or more storage devices, the data processing program being a program causing the processor circuitry of the computer to execute processing comprising:

receiving a request from any of devices including the one or more sensor devices and a plurality of service processors, each service processor corresponding to a respective one of the plurality of services; and

accessing, in response to the received request, either the common digital twin or at least any one of the plurality of specific digital twins, in accordance with a predetermined data distribution rule, the accessing including:

(1) writing, in response to the request being a write request including a first source data from any one of the one or more sensor devices, a first processed data item obtained from the first source data to the common digital twin;

(2) in response to the request being a read request from a specific service processor among the plurality of service processors,

(2-1) accessing, among the plurality of specific digital twins, a specific digital twin corresponding to the specific service processor to retrieve, the second processed data from the specific digital twin and provide the retrieved second processed data to the specific service processor, and

(2-2) in a case where no specific second processed data to be read by the read request is determined to exist in the specific digital twin, retrieving the first processed data from the common digital twin to provide the retrieved first processed data to the specific service processor; and

(3) writing, in response to the request being a write request including the second processed data from the specific service processor, the second processed data included in the write request from the specific service processor to the specific digital twin corresponding to the specific service processor.

9 . A data processing apparatus comprising:

one or more storage devices that store

a common digital twin configured to store first processed data obtained by processing source data received from one or more sensor devices, and

a plurality of specific digital twins, each specific digital twin being associated with a corresponding service of a plurality of services and being configured to store second processed data obtained by processing one or more pieces of the source data based on a processing rule corresponding to the corresponding service, the first processed data being data to be processed in common to the plurality of services, the second processed data being data to be processed specifically to the corresponding service of the plurality of services; and

a processor circuitry coupled to the one or more storage devices, the processor being configured to perform processing comprising:

receiving a request from any of devices including the one or more sensor devices and a plurality of service processors, each service processor corresponding to a respective one of the plurality of services; and

accessing, in response to the received request, either the common digital twin or at least any one of the plurality of specific digital twins, in accordance with a predetermined data distribution rule, the accessing including:

(1) writing, in response to the request being a write request including a first source data from any one of the one or more sensor devices, a first processed data item obtained from the first source data to the common digital twin;

(2) in response to the request being a read request from a specific service processor among the plurality of service processors,

(2-1) accessing, among the plurality of specific digital twins, a specific digital twin corresponding to the specific service processor to retrieve the second processed data from the specific digital twin and provide the retrieved second processed data to the specific service processor, and

(2-2) in a case where no specific second processed data to be read by the read request is determined to exist in the specific digital twin, retrieving the first processed data from the common digital twin to provide the retrieved first processed data to the specific service processor; and

(3) writing, in response to the request being a write request including the second processed data from the specific service processor, the second processed data included in the write request from the specific service processor to the specific digital twin corresponding to the specific service processor.