Message schema control
AssigneeIntel Corporation
InventorsMichael Nolan, Niall Cahill, Keith Nolan, John Brady, Mark Kelly
Life of this patent
Estimating the term…
Abstract
A method and apparatus for controlling message schema and size for internet-of-things (IoT) devices is provided. An exemplary method includes receiving an orchestration message from a downstream device, and calculating a new message size for a current schema, based, at least in part, on the orchestration message. A data message using the new message size and the current schema.
Claims26
An apparatus for communicating using a message schema, comprising an internet-of-things (IoT) device, comprising:
- a communications device to communicate between the IoT device and other devices;
- an orchestration controller to:
- determine if a congestion rate is greater than a congestion rate threshold;
- calculate a change in the congestion rate;
- determine if the change in the congestion rate is greater than a change threshold;
- and
- accept an orchestration message from a downstream device;
- a schema selector to adjust a message size based, at least in part, on the orchestration message;
- and
- a message dispatcher to aggregate data into an aggregated data message according to a current schema, and send the aggregated data message to a data sink.
A method for selecting a message schema in an internet-of-things (IoT) device, comprising:
- determining if a congestion rate is greater than a congestion rate threshold;
- calculating a change in the congestion rate;
- and
- determining if the change in the congestion rate is greater than a change threshold;
- receiving an orchestration message from a downstream device;
- calculating a new message size for a current schema, based, at least in part, on the orchestration message;
- and
- sending a data message using the new message size and current schema.
A method for selecting a message schema in an internet-of-things (IoT) device, comprising:
- receiving an orchestration message from a downstream device;
- calculating a new message size for a current schema, based, at least in part, on the orchestration message;
- sending a data message using the new message size and current schema;
- and
- determining if a cost function for a new schema or message size is less than the cost function of a current schema or message size by:
- calculating the cost function for each of a plurality of schema and message size combinations;
- and
- determining if a cost function for one of the plurality of schema and message size combinations is lower than a current schema and message size combination.
A non-transitory, computer readable medium comprising instructions, which when executed, direct a processor to:
- determine if a congestion rate is greater than a congestion rate threshold;
- calculate a change in the congestion rate;
- determine if the change in the congestion rate is greater than a change threshold;
- determine if a change is needed in a message size or schema;
- and
- send an orchestration message to an internet-of-things device to change the message size, the schema, or both.
Dependencies are inferred from the claim text.