DATA PROCESSING APPARATUS, DATA PROCESSING METHOD, AND PROGRAM

• US 20130103643A1
• Filed: 06/18/2010
• Published: 04/25/2013
• Est. Priority Date: 06/18/2010
• Status: Active Grant

• Current Assignee: Mitsubishi Electric Corporation
• Original Assignee: Mitsubishi Electric Corporation
• Inventors: Hirai, Norio, Kori, Mitsunori
• Granted Patent: US 9,146,927 B2
• Time in Patent Office: Days
• US Class Current: 707/609
• CPC Class Codes: G06F 16/11 File system administration, e.g. details of archiving or snapshots file system backup G06F11/14
• CPC Class Codes: G06F 16/116 Details of conversion of file system types or formats
• CPC Class Codes: G06F 16/20 of structured data, e.g. relational data
• CPC Class Codes: G06F 16/285 Clustering or classification

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.

Claims

1. A data processing apparatus which manages a record based on management time of a predetermined width, comprising:

a data receiving part which receives data to which a time stamp is added and which is transmitted with a predetermined period, the time stamp indicating time;

a time determining part which, each time the data receiving part receives data, determines management time corresponding to the time of the time stamp added to the received data, and classifies the received data under the management time;

a record generating part which updates record target management time, being a target of record generation, in the course of time;

generates a record by arranging data, which is classified under current record target management time and which is inputted from the time determining part during a predetermined acceptance time since start of input of data classified under the current record target management time from the time determining part;

if un-arrived data exists which has not been inputted yet at an end of the acceptance time among data classified under the current record target management time, waits for input of the un-arrived data during a predetermined wait time, adds un-arrived data inputted by an end of the wait time to the record, and completes generation of the record; and

if un-arrived data exists which has not been inputted yet at the end of the wait time, adds a value representing an existence of the un-arrived data to the record, and completes generation of the record; and

a table adding part which adds the record completely generated by the record generation part, to a predetermined table.

2. The data processing apparatus according to claim 1,

wherein the record generating part, if data classified under past record target management time is inputted, with a delay, from the time determining part, generates a record of delay data inputted with the delay;

if un-arrived data exists which is data classified under the same management time as the delay data and which has not been inputted yet, waits for input of the un-arrived data during a predetermined wait time, adds un-arrived data inputted by the end of the wait time to the record, and completes generation of the record; and

if un-arrived data exists which has not been inputted yet at the end of the wait time, adds a value representing an existence of the un-arrived data to the record, and completes generation of the record, and

wherein the table adding part adds the record that describes the delay data and that is completely generated by the record generating part, to the table.

3. The data processing apparatus according to claim 1,

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;

and if input of the un-arrived data is to be waited for, waits for input of the un-arrived data during the wait time, and if input of the un-arrived data is not to be waited for, adds a value representing an existence of the un-arrived data to the record at the end of the acceptance time.

4. The data processing apparatus according to claim 3,

wherein the data reception part receives data transmitted from a plurality of data transmission apparatuses at every predetermined period,

wherein the data processing apparatus further comprises a delay status monitoring part which monitors a delay status of data reception for each of the data transmission apparatuses, and

wherein 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.

5. The data processing apparatus according to claim 4,

wherein the delay status monitoring part counts the number of times data is received behind an appropriate reception timing consecutively, as a number of times of consecutive delay, for each of the data transmission apparatuses, and

wherein the record generating part, if the number of times of consecutive delay of a data transmission apparatus, being the sender of the un-arrived data, is equal to or smaller than a predetermined threshold, waits for input of the un-arrived data, and if the number of times of consecutive delay of the data transmission apparatus, being the sensor of the un-arrived data, exceeds the threshold, does not wait for input of the un-arrived data.

6. The data processing apparatus according to claim 4,

wherein the delay status control part counts a number of times data is received behind an appropriate reception timing within a predetermined monitor period, as a number of times of delay occurrence, for each of the data transmission apparatuses, and

wherein the record generating part, if the number of times of delay occurrence of a data transmission apparatus, being the sender of the un-arrived data, is equal to or smaller than a predetermined threshold, waits for input of the un-arrived data, and if the number of times of delay occurrence of the data transmission apparatus, being the sensor of the un-arrived data, exceeds the threshold, does not wait for input of the un-arrived data.

7. The data processing apparatus according to claim 4,

wherein the delay status monitoring part, each time data is received behind an appropriate reception timing, measures a delay time behind the appropriate reception timing, and calculates an average value of the measured delay time within a predetermined monitoring period for each of the data transmission apparatuses, and

wherein the record generating part, if the average value of the delay time of a data transmission apparatus, being the sender of the un-arrived data, is equal to or smaller than a predetermined threshold, waits for input of the un-arrived data, and if the average value of the delay time of the data transmission apparatus, being the sensor of the un-arrived data, exceeds the threshold, does not wait for input of the un-arrived data.

8. The data processing apparatus according to claim 3,

wherein the record generating part, if a plurality of un-arrived data exist, determines whether or not to wait for input of each of the un-arrived data.

9. The data processing apparatus according to claim 1,

wherein the record generating part, if all data classified under a current record target management time are stored in the record by the end of the acceptance time, completes generation of the record without waiting for the end of the acceptance time.

10. The data processing apparatus according to claim 1,

wherein the table adding part, if generation of a record by the record generating part is completed before the end of the wait time, adds the completely generated record to the table without waiting for the end of the wait time.

11. The data processing apparatus according to claim 1,

wherein the time determining part, each time data is received by the data receiving part, determines management time corresponding to time of a time stamp added to the received data, by executing any one operation of round-up, round-off, and round-down of the time of the time stamp.

12. The data processing apparatus according to claim 1,

wherein the data receiving part receives data indicating a measurement value measured by each of a plurality of measuring devices, to be related to device ID (Identification) of a measuring device,

wherein the data processing apparatus further includes a configuration information storing part which stores configuration information that designates a position of data in a record, for each device ID, and

wherein the record generating part generates a record by arranging data classified under a current record target management time, at positions designated by the configuration information, based on the device ID related to the data inputted from the time determining part.

13. The data processing apparatus according to claim 12,

wherein the data receiving part receives data indicating a measurement value measured by each of a plurality of measuring devices installed at a plurality of locations, and

wherein the configuration information storing part stores configuration information representing at least one of:

an installation location of a measuring device;

an attribute of the measurement value; and

a precision of the measurement value, for each device ID.

14. A data processing method executed by a computer that manages a record based on management time of a predetermined width, the method comprising:

receiving data to which a time stamp is added and which is transmitted with a predetermined period, the time stamp indicating time, by the computer;

each time the data is received, determining management time corresponding to the time of the time stamp added to the received data, and classifying the received data under the management time, by the computer;

updating record target management time, being a target of record generation, in the course of time;

generating a record by arranging data, which is classified under current record target management time and which is received during a predetermined acceptance time since start of reception of data classified under the current record target management time;

if un-arrived data exists which has not been received yet at an end of the acceptance time among data classified under the current record target management time, waiting for reception of the un-arrived data during a predetermined wait time, adding un-arrived data received by an end of the wait time to the record, and completing generation of the record; and

if un-arrived data exists which has not been received yet at the end of the wait time, adding a value representing an existence of the un-arrived data to the record, and completing generation of the record, by the computer; and

adding the record completely generated, to a predetermined table, by the computer.

15. 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 data to which a time stamp is added and which is transmitted with a predetermined period, the time stamp indicating time;

a time determining process of determining management time corresponding to the time of the time stamp added to the received data, and classifying the received data under the management time, each time the data is received;

a record generating process of updating record target management time, being a target of record generation, in the course of time;

generating a record by arranging data, which is classified under current record target management time and which is inputted from the time determining process during a predetermined acceptance time since start of input of data classified under the current record target management time from the time determining process;

if un-arrived data exists which has not been inputted yet at an end of the acceptance time among data classified under the current record target management time, waiting for input of the un-arrived data during a predetermined wait time, adding un-arrived data inputted by an end of the wait time to the record, and completing generation of the record; and

if un-arrived data exists which has not been inputted yet at the end of the wait time, adding a value representing an existence of the un-arrived data to the record, and completing generation of the record; and

a table adding process of adding the record completely generated by the record generation process, to a predetermined table.