Data reduction in a system

• US 10,499,283 B2
• Filed: 07/01/2015
• Issued: 12/03/2019
• Est. Priority Date: 07/01/2015
• Status: Active Grant

• Current Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Original Assignee: Red Hat, Inc. (International Business Machines Corporation)
• Inventors: Elias, Filip, Nguyen, Filip
• Primary Examiner(s): Sefcheck, Gregory B
• Assistant Examiner(s): Esmaeilian, Majid
• Application Number:
  US14/789,012
• Publication Number:
  US 20170006500A1
• Time in Patent Office: 1,616 Days
• Field of Search: 370326
• CPC Class Codes: H04L 47/70 Admission control; Resource allocation
• CPC Class Codes: H04L 67/12 specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
• CPC Class Codes: H04Q 2209/823 where the data is sent when the measured values exceed a threshold, e.g. sending an alarm
• CPC Class Codes: H04Q 9/00 Arrangements in telecontrol or telemetry systems for selectively calling a substation from a main station, in which substation desired apparatus is selected for applying a control signal thereto or for obtaining measured values therefrom
• CPC Class Codes: H04W 28/12 using signalling between network elements

Abstract

An example method for reducing data communications includes receiving, at a data hub, a first set of messages from a first device. Each message of the first set includes a value. The method also includes sending one or more messages of the first set to one or more devices. The method further includes receiving a second set of messages from a second device. Each message of the second set indicates whether a state change occurred in the second device for one or more values included in the first set. The method also includes computing a value interval based on the one or more values associated with the first set. Values within the value interval were indicated in the second set as causing a state change in the second device. The method further includes configuring the first device to transmit messages for values within the value interval.

Claims

1. A method for reducing data communications, comprising:

receiving, at a data hub coupled to a network, a first plurality of messages from a first device, each message of the first plurality of messages including a value;

sending, by the data hub, one or more values included in the first plurality of messages to one or more devices of a plurality of devices coupled to the network;

responsive to sending the one or more values included in the first plurality of messages, receiving, by the data hub, a second plurality of messages from a second device of the plurality of devices, each message of the second plurality of messages indicating whether a state change occurred in the second device for a corresponding value included in the first plurality of messages, and a metric of the corresponding value being different from a metric of the state change;

computing a value interval based on the one or more values included in the first plurality of messages for which a state change occurred in the second device; and

configuring the first device to not transmit messages for values outside of the value interval.

2. The method of claim 1, further including:

computing a second value interval based on the one or more values included in the first plurality of messages for which a state change occurred in the second device; and

configuring the first device to transmit messages for values within the second value interval.

3. The method of claim 1, further comprising:

after configuring the first device to not transmit messages for values outside of the value interval, configuring the first device to transmit values outside of the value interval for a time period.

4. The method of claim 3, further including:

receiving, at the data hub, a third set of messages from the first device during the time period, one or more messages of the third set including a value outside of the value interval.

5. The method of claim 4, further including:

sending one or more messages of the third set to one or more devices of the plurality of devices;

receiving a fourth set of messages from the second device, each message of the fourth set indicating whether a state change occurred in the second device for one or more values included in the third set; and

computing a second value interval based on the one or more values included in the third set, wherein values within the second value interval were indicated as causing a state change in the second device, and the first value interval is different from the second value interval.

6. The method of claim 5, further comprising:

re-configuring the first device to not transmit messages for values outside of the second value interval, the first value interval being different from the second value interval.

7. The method of claim 5, further comprising:

re-configuring the first device to transmit messages for values within the value interval.

8. The method of claim 1, further including:

responsive to sending the one or more values included in the first plurality of messages, receiving a third plurality of messages from a third device of the plurality of devices, each message of the third plurality of messages indicating whether a second state change occurred in the third device for a corresponding value included in the first plurality of messages, and a metric of the corresponding value being different from a metric of the second state change;

computing a third value interval based on the one or more values included in the first plurality of messages for which a second state change occurred in the third device, wherein the first value interval is different from the third value interval, and values within the third value interval were indicated in the third plurality of messages as causing a state change in the third device; and

configuring the third device to not transmit messages for values outside of the third value interval.

9. The method of claim 1, further including:

aggregating data received from one or more devices of the plurality of devices;

sending the first aggregated data to a second data hub;

receiving second data from the second data hub, wherein the second data includes values, and wherein a portion of the second data is marked as important;

obtaining a second value interval based on the second data; and

determining whether to send the second aggregated data.

10. The method of claim 1, further including:

sending a second portion of the second aggregated data, but not a third portion of the second aggregated data, wherein the second portion is within the second value interval and the third portion is outside of the second value interval.

11. The method of claim 1, wherein each value within the value interval is indicated in the second plurality of messages as causing a state change in the second device.

12. The method of claim 1, wherein a state indicates one of an on state or an “

OFF”

state.

13. The method of claim 12, wherein the state indicates one of a “

silent”

state or a “

sleep”

state.

14. A system for reducing data communications, the system comprising:

a plurality of devices including a first device and a second device; and

a data hub that receives a first plurality of messages from the first device, sends one or more messages of the first plurality of messages to one or more devices of the plurality of devices, and responsive to sending the one or more messages of the first plurality of messages, receives a second plurality of messages from the second device,

wherein each message of the first plurality of messages includes a value, each message of the second plurality of messages indicates whether a state change occurred in the second device for a corresponding value included in the first plurality of messages, and a metric of the corresponding value is different from a metric of the state change,

wherein the data hub computes a value interval based on the one or more values included in the first plurality of messages for which a state change occurred in the second device and configures the first device to transmit messages for values within the value interval.

15. The system of claim 14, wherein the plurality of devices and data hub are part of an Internet of Things (IoT) network.

16. The system of claim 14, wherein the data hub computes a second value interval based on the one or more values included in the first plurality of messages for which a state change occurred in the second device and configures the first device to not transmit messages for values outside of the second value interval.

17. The system of claim 14, further comprising:

a second data hub coupled to the first data hub, wherein the first data hub aggregates data received from one or more devices, sends the first aggregated data to the second data hub, obtains a third value interval based on the second data, determines whether to send the second aggregated data to the second data hub based on the third value interval, and re-configures the first data hub to send aggregated data for values within the third value interval.

18. The system of claim 14, the system further comprising:

a data hub manger that stores a plurality of rules, wherein the second data hub marks data that conforms to a rule of the plurality of rules as important.

19. A non-transitory machine-readable medium comprising a plurality of machine-readable instructions that when executed by one or more processors is adapted to cause the one or more processors to perform a method comprising:

receiving, at a data hub coupled to a network, a first plurality of messages from a first device, each message of the first plurality of messages including a value;

sending, by the data hub, one or more values included in the first plurality of messages to one or more devices of a plurality of devices coupled to the network;

responsive to sending the one or more values included in the first plurality of messages, receiving a second plurality of messages from a second device of the plurality of devices, each message of the second plurality of messages indicating whether a state change occurred in the second device for a corresponding value included in the first plurality of messages, and a metric of the corresponding value being different from a metric of the state change;

computing a value interval based on the one or more values included in the first plurality of messages for which a state change occurred in the second device; and

configuring the first device to not transmit messages for values outside of the value interval.