System and Protocol To Dynamically Query Sensor Data Collections

• US 20130073576A1
• Filed: 09/19/2011
• Published: 03/21/2013
• Est. Priority Date: 09/19/2011
• Status: Abandoned Application

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Sailer, Anca, Lillethun, David J., Mohindra, Ajay
• Application Number:
  US13/236,497
• Publication Number:
  US 20130073576A1
• Time in Patent Office: Days
• US Class Current: 707/758
• CPC Class Codes: H04W 4/38 for collecting sensor information

Abstract

A sensor registry includes a query dispatcher, a registration dispatcher, and a continuous query engine. The query dispatcher receives a query from a subscriber, searches a sensor database for at least one sensor that satisfies the query, and returns a result set corresponding to the query to the subscriber. The result set includes the at least one sensor. The registration dispatcher receives a message from a requesting sensor in a sensor network, and updates the sensor database based on the message. The continuous query engine receives the query from the query dispatcher, updates the result set corresponding to the query based on the received message, and notifies the subscriber upon determining that a change has been made to the result set.

Claims

1. A sensor registry, comprising:

a query dispatcher configured to receive a query from a subscriber, search a sensor database for at least one sensor in a sensor network that satisfies the query, and return a result set corresponding to the query to the subscriber, wherein the result set includes the at least one sensor;

a registration dispatcher configured to receive an update request from a requesting sensor in the sensor network, and update the sensor database based on the update request; and

a continuous query engine configured to receive the query from the query dispatcher, update the result set corresponding to the query based on the update request, and notify the subscriber upon determining that a change has been made to the result set.

2. The sensor registry of claim 1, wherein the update request is one of a registration request, a removal request, or a metadata update request.

3. The sensor registry of claim 2, wherein the registration dispatcher is configured to add the requesting sensor to the sensor database upon receiving the registration request, remove the requesting sensor from the sensor database upon receiving the removal request, and update metadata of the requesting sensor in the sensor database upon receiving the metadata update request.

4. The sensor registry of claim 1, further comprising:

a continuous query database configured to store continuous queries, wherein the continuous query engine is configured to store the query in the continuous query database as one of the continuous queries.

5. The sensor registry of claim 4, wherein the continuous query engine is configured to update a result set corresponding to one of the continuous queries stored in the continuous query database based on the update request.

6. The sensor registry of claim 5, wherein the result set corresponding to the one of the continuous queries is updated based on a comparison of metadata of the requesting sensor and the one of the continuous queries.

7. The sensor registry of claim 6, wherein the continuous query engine is configured to add the requesting sensor to the result set corresponding to the one of the continuous queries upon determining that the requesting sensor satisfies the one of the continuous queries and is not included in the one of the continuous queries,

remove the requesting sensor from the result set corresponding to the one of the continuous queries upon determining that the requesting sensor does not satisfy the one of the continuous queries and is not included in the one of the continuous queries, and

update the result set corresponding to the one of the continuous queries upon determining that the requesting sensor satisfies the one of the continuous queries, the metadata of the requesting sensor has changed, and the requesting sensor is included in the one of the continuous queries.

8. The sensor registry of claim 1, further comprising:

a value query engine configured to receive a sensor value portion of the query from the query dispatcher,

wherein the query includes the sensor value portion and a sensor metadata portion, the query dispatcher is configured to generate a preliminary result set including every sensor in the sensor database matching the sensor metadata portion of the query, and the value query engine is configured to generate a final result set including sensors in the preliminary result set having a value matching the value portion of the query.

9. The sensor registry of claim 1, further comprising:

a dynamic query database configured to store dynamic queries,

wherein the query dispatcher is configured to receive a dynamic query update message including a new sensor value from the subscriber, and update one of the stored queries corresponding to the dynamic query update message based on the new sensor value.

10. The sensor registry of claim 1, wherein the query dispatcher is configured to receive a callback from the subscriber with the query, and the continuous query engine is configured to receive the callback from the query dispatcher and notify the subscriber via the callback.

11. The sensor registry of claim 1, wherein the query is a nested query including an

inner query and an outer query, and the outer query is generated based on results of the inner query.

12. The sensor registry of claim 1, further comprising a transformation database,

wherein the query is an intentional query, and the query dispatcher is configured to cross-reference the transformation database with the sensor database to search for sensors that satisfy the intentional query.

13. The sensor registry of claim 12, wherein transformation information is appended to sensor entries in the result set that correspond to the sensors that satisfy the intentional query.

14. The sensor registry of claim 1, wherein the query is a dynamic query including a replaceable parameter, and the subscriber updates the query by supplying a new value corresponding to the replaceable parameter.

15. The sensor registry of claim 1, wherein the subscriber is an application.

16. A method of querying sensors in a sensor network, comprising:

receiving a query from a subscriber;

searching a sensor database for at least one sensor that satisfies the query;

returning a result set including the at least one sensor to the subscriber; and

notifying the subscriber upon determining that a change has been made to the result set.

17. The method of claim 16, further comprising:

receiving an update request from a requesting sensor in the sensor network; and

updating the sensor database based on the update request.

18. The method of claim 17, further comprising:

adding the requesting sensor to the sensor database upon determining that the update request is a registration request;

removing the requesting sensor from the sensor database upon determining that the update request is a removal request; and

updating metadata of the requesting sensor in the sensor database upon determining that the update request is a metadata update request,

wherein the update request is one of the registration request, the removal request, or the metadata update request.

19. The method of claim 17, further comprising:

storing the query as one of a plurality of continuous queries in a continuous query database;

monitoring the plurality of continuous queries; and

updating a result set corresponding to one of the continuous queries based on the update request.

20. The method of claim 19, further comprising:

adding the requesting sensor to the result set corresponding to the one of the continuous queries upon determining that the requesting sensor satisfies the one of the continuous queries and is not included in the one of the continuous queries;

removing the requesting sensor from the result set corresponding to the one of the continuous queries upon determining that the requesting sensor does not satisfy the one of the continuous queries and is not included in the one of the continuous queries; and

updating the result set corresponding to the one of the continuous queries upon determining that the requesting sensor satisfies the one of the continuous queries, metadata of the requesting sensor has changed, and the requesting sensor is included in the one of the continuous queries.

21. The method of claim 16, further comprising:

generating a preliminary result set including all sensors in the sensor database matching a sensor metadata portion of the query; and

generating a final result set including sensors in the preliminary result set having a value matching a value portion of the query,

wherein the query includes the sensor metadata portion and the value portion.

22. The method of claim 16, further comprising:

receiving a dynamic query update message including a new sensor value from the subscriber; and

updating a stored query corresponding to the dynamic query update message based on the new sensor value.

23. The method of claim 16, further comprising:

receiving a callback from the subscriber with the query; and

notifying the subscriber via the callback.

24. The method of claim 16, further comprising:

generating an outer query based on results of an inner query, wherein the query received from the subscriber includes the outer query and the inner query.

25. The method of claim 16, wherein the subscriber is an application.