Data processing apparatus, data processing method, and program
First Claim
1. A data processing apparatus which manages a record based on a plurality of management time periods each having a predetermined width, comprising:
- a data receiver that receives a plurality of pieces of data from a plurality of data transmission apparatuses, the pieces of data having been transmitted by the plurality of data transmission apparatuses periodically according to a predetermined period, the pieces of received data each including a time stamp indicating time;
a time determining part which, each time the data receiver receives a piece of data, determines the management time period in the plurality of management time periods that corresponds to the time of the time stamp in the received piece of data based on the predetermined width of the management time period, and classifies the received piece of data under the determined management time period;
a record generating part that generates a record by arranging a first piece of data, which is classified by the time determining part under the determined management time period and which is inputted from the time determining part during a predetermined acceptance time since a start of input of data classified under the determined management time period, adds to the record a second piece of data classified under the determined management time period and inputted from the time determining part after an end of an acceptance time period and before an end of a wait time, and if a piece of data from one or more of the plurality of data transmission apparatuses has not been inputted yet at the end of the wait time, determines that an un-arrived data exists, and adds a value representing the existence of the un-arrived data to the record, and completes generation of the record; and
a table adding part that receives the record completely generated from the record generation part, and adds the record completely generated by the record generation part, to a predetermined table, whereinthe record generating part, when the un-arrived data exists, determines whether or not to wait for input of the un-arrived data at the end of the acceptance time based on predetermined configuration data,if input of the un-arrived data is determined to be waited for, the record generating part waits for input of the un-arrived data during the wait time, and if input of the un-arrived data is determined not to be waited for, the record generating part adds the value representing the existence of the un-arrived data to the record at the end of the acceptance time,the data receiver receives data transmitted from the plurality of data transmission apparatuses at every predetermined period,the data processing apparatus further comprises a delay status monitoring part which monitors a delay status of data reception based on the data that the data receiver receives from the plurality of data transmission apparatuses for each of the data transmission apparatuses, andthe record generation part, if the un-arrived data exists, determines whether or not to wait for input of the un-arrived data based on a monitoring result of the delay status monitoring part for a data transmission apparatus which is a sender of the un-arrived data.
1 Assignment
0 Petitions
Accused Products
Abstract
A data receiving part receives data transmitted from a plurality of measuring devices. A time determining part distinguishes management time from date and time of the data. The record generating part stores data of the same management time which are received during a predetermined acceptance time, in the same record. When un-arrived data belonging to the same management time exists at the end of the acceptance time, arrival of the un-arrived data is waited for during a predetermined wait time. Even if the data is arrived with some delay, arrival-delayed data can be stored in the same record. Thus, the missing data occurrence frequency can be suppressed.
-
Citations
19 Claims
-
1. A data processing apparatus which manages a record based on a plurality of management time periods each having a predetermined width, comprising:
-
a data receiver that receives a plurality of pieces of data from a plurality of data transmission apparatuses, the pieces of data having been transmitted by the plurality of data transmission apparatuses periodically according to a predetermined period, the pieces of received data each including a time stamp indicating time; a time determining part which, each time the data receiver receives a piece of data, determines the management time period in the plurality of management time periods that corresponds to the time of the time stamp in the received piece of data based on the predetermined width of the management time period, and classifies the received piece of data under the determined management time period; a record generating part that generates a record by arranging a first piece of data, which is classified by the time determining part under the determined management time period and which is inputted from the time determining part during a predetermined acceptance time since a start of input of data classified under the determined management time period, adds to the record a second piece of data classified under the determined management time period and inputted from the time determining part after an end of an acceptance time period and before an end of a wait time, and if a piece of data from one or more of the plurality of data transmission apparatuses has not been inputted yet at the end of the wait time, determines that an un-arrived data exists, and adds a value representing the existence of the un-arrived data to the record, and completes generation of the record; and a table adding part that receives the record completely generated from the record generation part, and adds the record completely generated by the record generation part, to a predetermined table, wherein the record generating part, when the un-arrived data exists, determines whether or not to wait for input of the un-arrived data at the end of the acceptance time based on predetermined configuration data, if input of the un-arrived data is determined to be waited for, the record generating part waits for input of the un-arrived data during the wait time, and if input of the un-arrived data is determined not to be waited for, the record generating part adds the value representing the existence of the un-arrived data to the record at the end of the acceptance time, the data receiver receives data transmitted from the plurality of data transmission apparatuses at every predetermined period, the data processing apparatus further comprises a delay status monitoring part which monitors a delay status of data reception based on the data that the data receiver receives from the plurality of data transmission apparatuses for each of the data transmission apparatuses, and the record generation part, if the un-arrived data exists, determines whether or not to wait for input of the un-arrived data based on a monitoring result of the delay status monitoring part for a data transmission apparatus which is a sender of the un-arrived data. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13)
-
-
14. A data processing method executed by a computer that manages a record based on a plurality of management time periods each having a predetermined width, the method comprising:
-
receiving, by the computer, pieces of data from a plurality of data transmission apparatuses, the pieces of data having been transmitted by the plurality of data transmission apparatuses periodically according to a predetermined period, the received pieces of data each including a time stamp indicating time; each time a piece of data is received, determining, by the computer, the management time period in the plurality of management time periods that corresponds to the time of the time stamp in the received piece of data, and classifying the received piece of data under the determined management time; generating a record by arranging a first piece of data, which is classified under the determined management time period and which is received during a predetermined acceptance time since a start of reception of data classified under the determined management time period; adding to the record a second piece of data classified under the determined management time period and received after an end of the predetermined acceptance time; and before an end of a predetermined wait time; if a piece of data from one or more of the plurality of data transmission apparatuses has not been received yet at the end of the wait time, determining that an un-arrived data exists, and adding a value representing the existence of the un-arrived data to the record, and completing generation of the record; adding the record completely generated, to a predetermined table, wherein when the un-arrived data exists, determining whether or not to wait for input of the un-arrived data at the end of the acceptance time based on predetermined configuration data, if input of the un-arrived data is determined to be waited for, waiting for input of the un-arrived data during the wait time, and if input of the un-arrived data is determined not to be waited for, adding the value representing the existence of the un-arrived data to the record at the end of the acceptance time; receiving data transmitted from the plurality of data transmission apparatuses at every predetermined period; and monitoring a delay status of data reception based on the data received from the plurality of data transmission apparatuses for each of the data transmission apparatuses, wherein if the un-arrived data exists, determining whether or not to wait for input of the un-arrived data based on a monitoring result of the delay status for a data transmission apparatus which is a sender of the un-arrived data. - View Dependent Claims (15, 16)
-
-
17. A non-transitory computer readable medium which causes a computer that manages a record based on management time of a predetermined width, to execute:
-
a data reception process of receiving pieces of data from a plurality of data transmission apparatuses, the pieces of data having been transmitted by the plurality of data transmission apparatuses periodically according to a predetermined period, the received pieces of data each including a time stamp indicating time; a time determining process of determining, each time a piece of data is received, the management time period in the plurality of management time periods that corresponds to the time of the time stamp in the received piece of data, and classifying the received piece of data under the determined management time; a record generating process of generating a record by arranging a first piece of data, which is classified under the determined management time period and which is received during a predetermined acceptance time since a start of reception of data classified under the determined management time period;
adding to the record a second piece of data classified under the determined management time period and received after an end of the predetermined acceptance time; and
before an end of a predetermined wait time, and if a piece of data from one or more of the plurality of data transmission apparatuses has not been received yet at the end of the wait time, determining that an un-arrived data exists, and adding a value representing the existence of the un-arrived data to the record, and completing generation of the record;a table adding process of adding the record completely generated by the record generation process, to a predetermined table, wherein the record generating process includes, when the un-arrived data exists, determining whether or not to wait for input of the un-arrived data at the end of the acceptance time based on predetermined configuration data, if input of the un-arrived data is determined to be waited for, the record generating process includes waiting for input of the un-arrived data during the wait time, and if input of the un-arrived data is determined not to be waited for, the record generating process includes adding the value representing the existence of the un-arrived data to the record at the end of the acceptance time, the data reception process includes receiving data transmitted from the plurality of data transmission apparatuses at every predetermined period; and a delay status monitoring process of monitoring a delay status of data reception based on the data received from the plurality of data transmission apparatuses for each of the data transmission apparatuses, wherein the record generation process includes, if the un-arrived data exists, determining whether or not to wait for input of the un-arrived data based on a monitoring result of the delay status monitoring process for a data transmission apparatus which is a sender of the un-arrived data. - View Dependent Claims (18, 19)
-
Specification