Method and apparatus for managing sensor data and method and apparatus for analyzing sensor data

• US 9,405,714 B2
• Filed: 11/14/2011
• Issued: 08/02/2016
• Est. Priority Date: 03/22/2011
• Status: Active Grant

• Current Assignee: Samsung Electronics Co. Ltd.
• Original Assignee: Samsung Electronics Co. Ltd.
• Inventors: Roh, Yohan J, Hong, Seok-jin, Mo, Sang-dok
• Primary Examiner(s): Donabed, Ninos
• Application Number:
  US13/295,785
• Publication Number:
  US 20120246261A1
• Time in Patent Office: 1,723 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: A61B 5/0022 Monitoring a patient using a global network, e.g. telephone networks, internet
• CPC Class Codes: G06F 13/385 for adaptation of a particular data processing system to different peripheral devices
• CPC Class Codes: G06F 2213/3808 Network interface controller
• CPC Class Codes: G16H 40/67 for remote operation
• CPC Class Codes: H04L 43/0817 by checking functioning
• CPC Class Codes: H04L 65/1053 IP private branch exchange [PBX] functionality entities or arrangements circuit switched PBXs H04M3/00
• CPC Class Codes: H04L 65/1083 In-session procedures
• CPC Class Codes: H04L 67/75 Indicating network or usage conditions on the user display

Abstract

Provided are an apparatus and method for transmitting only sensor data actually used to process a user request among sensor data received from a sensor when communication restarts between a sensor data management device and a sensor data analysis device. Accordingly, the amount of data transmitted to the sensor data analysis device is reduced. The sensor data analysis device may analyze the sensor data received from the sensor data management device to process the user request.

Claims

1. A method comprising:

receiving, at a first device, a first piece of sensor data and a second piece of sensor data from a sensor;

storing, in a storage unit included in the first device, the first piece of sensor data and the second piece of sensor data in response to communication being disconnected between the first device and a second device configured to analyze sensor data;

determining that communication has been connected between the first device and the second device;

receiving, at the first device and from the second device, a first query; and

transmitting to the second device, in response to the determination that communication has been connected, the stored first piece of sensor data, but excluding the stored second piece of sensor data, as sensor data selected by the first query,

wherein the first query comprises a continuous query specifying repeated queries, each repeated query requiring pieces of sensor data,

wherein the first query further comprises an allowable delay limit indicating a maximum allowable amount of time that may elapse from a time that sensor data is generated to a predetermined time, and

selecting sensor data selected by the first query comprises;

generating query windows where each query window is a basic unit of a set of sensor data that is used to process each repeated query in the continuous query;

calculating a time elapsed from a generation time of a last sensor data of each query window to the predetermined time; and

extracting sensor data contained in at least one query window of which the calculated elapsed time is less than the allowable delay limit.

2. The method of claim 1, wherein

the receiving from a sensor further includes receiving, while communication is disconnected between the first device and the second device, a third piece of sensor data from the sensor;

the storing comprises determining not to store the third piece of sensor data based on the third piece of sensor data not relating to the first query.

3. The method of claim 1, wherein

the first query comprises a query definition in which a user request for sensor data is defined.

4. The method of claim 1, wherein the transmitting comprises transmitting the selected sensor data according to a data transmission policy defining which sensor data is first transmitted among the sensor data selected by the first query.

5. The method of claim 4, wherein the data transmission policy indicates a First-In First-Out (FIFO) policy by which the sensor data selected by the first query is sequentially transmitted from a first generated sensor data.

6. The method of claim 4, wherein,

in response to the first query comprising a continuous query, the data transmission policy indicates a policy of transmitting the sensor data selected by the first query in a query window,

the continuous query specifying repeated queries, each repeated query requiring a pieces of sensor data, and

the query window is a length of time that is less than a value obtained by subtracting a time elapsed from a generation time of a last sensor data in the query window from a predetermined time for an allowable delay limit.

7. The method of claim 1, wherein

the storing comprises selectively storing received pieces of sensor data based on a data storage policy defining which sensor data received at the first device is stored in the storage unit.

8. The method of claim 7, wherein

the data storage policy is based on at least one condition selected from the group consisting of a value of each piece of sensor data, a generation time of each piece of sensor data, a number of pieces of sensor data, and the first query.

9. A sensor data managing apparatus comprising:

an interface device configured to receive sensor data from a sensor;

a network interface processor;

a communication connection determiner processor configured to check a communication connection state for communication between the sensor data managing apparatus and an apparatus for analyzing sensor data via the network interface processor;

a storage unit configured to store a portion of the received sensor data in response to the communication connection determiner processor indicating communication has disconnected; and

a processor configured to;

receive a first piece of sensor data and a second piece of sensor data via the interface processor,

store in the storage unit the first piece of sensor data and the second piece of sensor data in response to the communication connection determiner processor indicating communication is disconnected,

transmit to the apparatus for analyzing sensor data via the network interface processor, in response to the communication connection determiner processor indicating communication with the apparatus for analyzing sensor data has been connected, the stored first piece of sensor data, but excluding the stored second piece of sensor data, as sensor data selected by a first query,

wherein the first query comprises an allowable delay limit indicating a maximum allowable amount of time that may elapse from a time that the first and second sensor data is generated to a predetermined time, and

select sensor data through the first query comprising;

generating query windows where each query window is a basic unit of a set of sensor data that is used to process each repeated query in the continuous query;

calculating a time elapsed from a generation time of a last sensor data of each query window to the predetermined time; and

extracting sensor data contained in at least one query window of which the calculated elapsed time is less than the allowable delay limit.

10. A non-transitory computer-readable storage medium having stored therein program instructions to cause a processor to implement a method, the method comprising:

receiving a first piece of sensor data and a second piece of sensor data from a sensor;

storing, in a storage unit connected to the processor, the first piece of sensor data and the second piece of sensor data in response to communication being disconnected between the processor and a second device configured to analyze sensor data;

determining that communication has been connected between the processor and the second device;

receiving from the second device a first query, wherein the first query comprises an allowable delay limit indicating a maximum allowable amount of time that may elapse from a time that the first and second sensor data is generated to a predetermined time; and

transmitting to the second device, in response to the determination that communication has been connected, the stored first piece of sensor data, but excluding the stored second piece of sensor data, as sensor data selected by the first query,

wherein the first query further comprises a continuous query specifying repeated queries, each repeated query requiring pieces of sensor data, and

selecting sensor data selected by the first query comprises;

generating query windows where each query window is a basic unit of a set of sensor data that is used to process each repeated query in the continuous query;

calculating a time elapsed from a generation time of a last sensor data of each query window to the predetermined time; and

extracting sensor data contained in at least one query window of which the calculated elapsed time is less than the allowable delay limit.

11. A method, comprising:

receiving a user'"'"'s query comprising a query definition indicating a continuous query by which a single query corresponding to the user'"'"'s query is continuously repeated;

receiving sensor data selected based on the query from among sensor data generated by a sensor;

analyzing the received sensor data,

wherein the receiving of the sensor data comprises;

generating query windows, wherein each query window is a unit of a set of sensor data and the set of sensor data is used to process each query in the continuous query,

calculating a time elapsed from a generation time of a last sensor data of each query window to a predetermined time, and

receiving sensor data in a query window of which the calculated elapsed time is less than an allowable delay limit,

the query further comprises the allowable delay limit indicating a maximum allowable amount of time that may elapse from a time that the sensor data is generated to a predefined time; and

the receiving of the sensor data comprises receiving sensor data used to process the user request based on whether the time elapsed from a generation time of the received sensor data to the predefined time is within the allowable delay limit.

12. The method of claim 11, wherein

the query comprises the query definition in which a user request for sensor data is defined, and

the receiving of the sensor data comprises receiving sensor data that is used to process the user request.

13. An apparatus comprising:

a user interface configured to receive a user'"'"'s query comprising a query definition indicating a continuous query by which a single query corresponding to the user'"'"'s query is continuously repeated;

a network interface processor configured to receive sensor data selected based on the query from among sensor data generated from a sensor; and

a query processor configured to analyze the received sensor data,

wherein the network interface processor is further configured to receive the sensor data based on

generated query windows, wherein each query window is a unit of a set of sensor data and the set of sensor data is used to process each query in the continuous query,

a calculated elapsed time from a generation time of a last sensor data of each query window to a predetermined time, and

a query window of which the calculated elapsed time is less than an allowable delay limit;

the first query comprises a maximum allowable amount of time that may elapse from a time that the sensor data is generated to a predefined time

the query processor is further configured to select the sensor data based on the first query through;

generating query windows where each query window is a basic unit of a set of sensor data that is used to process each repeated query in the continuous query,

calculating a time elapsed from a generation time of a last sensor data of each query window to the predefined time, and

extracting sensor data contained in at least one query window of which the calculated elapsed time is less than the allowable delay limit.

14. A non-transitory computer-readable storage medium having stored therein program instructions to cause a processor to implement a method, the method comprising:

receiving a user'"'"'s query information comprising a query definition indicating a continuous query by which a single query corresponding to the user'"'"'s query is continuously repeated;

receiving sensor data selected based on the query from among sensor data generated by a sensor; and

analyzing the received sensor data,

wherein the receiving of the sensor data comprises;

generating query windows, wherein each query window is a unit of a set of sensor data and the set of sensor data is used to process each query in the continuous query,

calculating a time elapsed from a generation time of a last sensor data of each query window to a predetermined time, and

receiving sensor data in a query window of which the calculated elapsed time is less than an allowable delay limit,

the first query comprises a maximum allowable amount of time that may elapse from a time that the sensor data is generated to a predefined time; and

the receiving of the sensor data comprises receiving sensor data used to process the user request based on whether the time elapsed from a generation time of the received sensor data to the predefined time is within the allowable delay limit.