US 11,669,573 B2
Data management system
Yuzo Ishida, Tokyo (JP); Nobuo Suga, Tokyo (JP); Satoshi Otake, Tokyo (JP); and Daisuke Shimizu, Tokyo (JP)
Assigned to Nomura Research Institute, Ltd., Tokyo (JP)
Filed by Nomura Research Institute, Ltd., Tokyo (JP)
Filed on Nov. 8, 2019, as Appl. No. 16/678,407.
Application 16/678,407 is a continuation of application No. PCT/JP2017/018041, filed on May 12, 2017.
Prior Publication US 2020/0097505 A1, Mar. 26, 2020
Int. Cl. G06F 16/9035 (2019.01); G06F 16/901 (2019.01); G06F 3/06 (2006.01); G06F 40/10 (2020.01); G16Y 40/10 (2020.01); G16Y 30/00 (2020.01)
CPC G06F 16/9035 (2019.01) [G06F 3/065 (2013.01); G06F 3/067 (2013.01); G06F 3/0619 (2013.01); G06F 16/901 (2019.01); G16Y 30/00 (2020.01); G16Y 40/10 (2020.01)] 4 Claims
OG exemplary drawing
 
1. A data management system comprising:
an AP (application) node to which one or more sensors are connected; and
a DB (database) node connected to the AP node,
wherein the AP node includes:
a receiving unit configured to receive measurement data including values of a plurality of measurement items output from the sensors at a predetermined timing;
a storage configured to store a most recent value in units of measurement items of each of the sensors;
a determination unit configured to compare the value included in the measurement data with the most recent value stored in the storage and then determine whether the value of each of the measurement items has changed, every time the measurement data is output from the sensor;
a transmission unit configured to, in a case where there is a measurement item having a value change, generate one or more pieces of child data including the value of the measurement item for each of the measurement items and transmit the generated one or more pieces of child data to the DB node; and
an overwriting unit configured to overwrite the most recent value in the storage with a newest value of the measurement item, and
the DB node includes:
a plurality of tables that stores a value included in the measurement data for each of the measurement items of each of the sensors;
a storing unit configured to store each one of the one or more pieces of child data transmitted from the AP node in one of the plurality of tables for the measurement item included in the each one of the one or more pieces of child data; and
a parent data registration table, and
when the AP node generates the one or more pieces of child data related to at least one piece of the measurement data, the AP node generates parent data associated with the measurement data of the one or more pieces of child data, and executes processing of assigning ID of the parent data to the one or more pieces of child data dependent on the parent data such that the one or more pieces of child data and the parent data include a same parent ID, and
after the AP node requests the DB node to register each one of the one or more pieces of child data, and in a case where a registration completion notification regarding the all of the one or more pieces of child data having the same parent ID has arrived from the DB node, the AP node requests the DB node to register the parent data having the same parent ID, and in a case where a registration completion notification of any of the one or more pieces of child data having the same parent ID has not arrived within a prescribed time, the AP node cancels registration of the parent data having the same parent ID, and
the AP node handles, as a target of reference, only the one or more pieces of child data in which the parent data has been registered and excludes the one or more pieces of child data that have been registered in the DB node and stored in the one of the plurality of tables of the DB node but have no registration of the parent data from the target of reference at the time of reference to the registered one or more pieces of child data.