Building system with brokering architecture to provide timeseries compression and extensions

Patent metadata

Field	Value
Publication number	US-2025088201-A1
Application number	US-202418882680-A
Country	US
Kind code	A1
Filing date	Sep 11, 2024
Priority date	Sep 12, 2023
Publication date	Mar 13, 2025
Grant date	—

Abstract

A brokering architecture is disclosed. The brokering architecture focuses on storing changes to the building system. Measurements are quantized to an integer representation and encoded so that time series data is stored in a series of changes of value. The encoded timeseries may be compressed using compression schemes that advantageously make use of small changes between adjacent stored values of the timeseries. Compressed timeseries values allow more data to be stored in RAM or other short-term storage and provide a more responsive system to control physical systems like buildings. Timeseries compression may be provided through extensions accessed through a structured data format on the message bus. Extensions can cause the execution of certain instructions based on the fields in the structured data and may be used to provide functionality in addition to timeseries compression including BACnet communications, predictions, and simulations.

First claim

What is claimed is:

1 . A method for controlling or monitoring a physical system, the method comprising:
quantizing a value to generate an integer representation of a variable of the physical system; encoding a timeseries comprising the integer representation by calculating a series of differences of time adjacent values of the timeseries to obtain an encoded timeseries; and performing an integer compression on the encoded timeseries to obtain a compressed timeseries.

2 . The method of claim 1 , wherein:
encoding the timeseries comprises subtracting the integer representation from a most recent stored value in the timeseries to obtain a difference; performing the integer compression comprises performing the integer compression on the difference; and storing the compressed timeseries comprises merging the difference with the timeseries and replacing the most recent stored value in the timeseries with the integer representation.

3 . The method of claim 1 , further comprising:
further encoding the timeseries by calculating a second series of differences of time adjacent values of the timeseries to obtain a second encoded timeseries; performing a second integer compression on the second encoded timeseries to obtain a second compressed timeseries; and storing the second compressed timeseries.

4 . The method of claim 1 , wherein encoding the timeseries comprises performing double delta encoding.

5 . The method of claim 1 , wherein performing the integer compression on the encoded timeseries comprises performing bit packing.

6 . The method of claim 1 , comprising storing a first portion of the compressed timeseries in a first storage and storing a second portion of the compressed timeseries in a second storage, wherein the first storage is configured to respond faster than the second storage.

7 . The method of claim 6 , comprising accessing the first portion of the compressed timeseries and the second portion of the compressed timeseries using a single message.

8 . The method of claim 1 , wherein at least one of quantizing the value, encoding the timeseries, or performing the integer compression is performed on an edge device.

9 . The method of claim 8 , wherein at least one of quantizing the value, encoding the timeseries, or performing the integer compression is performed on a cloud computing platform.

10 . The method of claim 1 , further comprising performing an automated action to affect the physical system based on data related to the timeseries.

11 . One or more memory devices having instructions stored thereon that, when executed by one or more processors, cause the one or more processors to perform operations comprising:
quantizing a value to generate an integer representation of a variable of a physical system; encoding a timeseries comprising the integer representation by calculating a series of differences of time adjacent values of the timeseries to obtain an encoded timeseries; and performing integer compression on the encoded timeseries to obtain a compressed timeseries.

12 . The one or more memory devices of claim 11 , wherein a most recent stored value in the timeseries is not encoded or compressed,
wherein encoding the timeseries comprises subtracting the integer representation from the most recent stored value in the timeseries to obtain a difference and replacing the most recent stored value in the timeseries with the difference, wherein storing the compressed timeseries comprises storing the integer representation as the most recent stored value, and wherein performing the integer compression comprises performing integer compression on the difference.

13 . The one or more memory devices of claim 11 , the operations further comprising:
further encoding the timeseries by calculating a second series of differences of time adjacent values of the timeseries to obtain a second encoded timeseries; performing a second integer compression on the second encoded timeseries to obtain a second compressed timeseries; and storing the second compressed timeseries.

14 . The one or more memory devices of claim 11 , wherein performing the integer compression on the encoded timeseries comprises performing bit packing.

15 . The one or more memory devices of claim 11 , the operations further comprising storing a first portion of the compressed timeseries in a first storage and storing a second portion of the compressed timeseries in a second storage, wherein the first storage is configured to respond faster than the second storage.

16 . The one or more memory devices of claim 15 , the operations further comprising accessing the first portion of the compressed timeseries and the second portion of the compressed timeseries using a single message.

17 . One or more memory devices having instructions stored thereon that, when executed by one or more processors, cause the one or more processors to perform operations comprising:
operating a first set of one or more message brokers in a first set of isolated compute environments, the one or more message brokers configured to communicate over a message bus and provide one or more features, wherein the one or more features are executed in response to a field in a first message communicated to a message broker of the one or more message brokers; and creating a second set of the one or more message brokers in a second set of isolated compute environments, the second set of the one or more message brokers capable of performing an additional feature in addition to the one or more features, wherein communications over the message bus comprise sending a structured data format, wherein the second set of one or more message brokers are configured to execute extension instructions related to the additional feature in response to a second message containing a specified field in the structured data format, and wherein the second set of one or more message brokers are deployed to the message bus while the first set of one or more message brokers communicates over the message bus.

18 . The one or more memory devices of claim 17 , wherein the specified field is a field indicative of timeseries data, wherein the instructions related to the additional feature comprise:
representing a value of the timeseries data as an integer by performing a quantization step on the value; encoding the timeseries data by calculating a series of differences of time adjacent values of the timeseries data to obtain an encoded timeseries; and performing integer compression on the encoded timeseries to obtain a compressed timeseries.

19 . The one or more memory devices of claim 17 , the operations further comprising:
storing, in a first storage device, less recent data than data stored in a second storage device; and storing data in the second storage device, requesting data from both the first storage device and the second storage device using a single message on the message bus.

20 . The one or more memory devices of claim 17 , wherein the instructions related to the additional feature comprise at least one of:
reading a BACnet point; simulating a portion of a building; detecting faults in the building; or performing an optimization.

Assignees

• Tyco Fire & Security Gmbh

Inventors

• Przybylski Andrew J
• Mueller Jon T
• Burroughs John H
• Hazelberg Peter J

Classifications

• G06F30/20

  Design optimisation, verification or simulation (optimisation, verification or simulation of circuit designs G06F30/30) · CPC title

• G06F3/0655

  Vertical data movement, i.e. input-output transfer; data movement between one or more hosts and one or more storage devices · CPC title

• G06F8/61 Primary

  Installation · CPC title

• G06F11/2023 Primary

  Failover techniques · CPC title

• G06F11/2028

  eliminating a faulty processor or activating a spare · CPC title