Building management system with nested stream generation

Patent metadata

Field	Value
Publication number	US-12055908-B2
Application number	US-202217856353-A
Country	US
Kind code	B2
Filing date	Jul 1, 2022
Priority date	Feb 10, 2017
Publication date	Aug 6, 2024
Grant date	Aug 6, 2024

Abstract

A building management system (BMS) includes building equipment configured to provide samples of one or more data points in the building management system and a timeseries service. The timeseries service is configured to identify a first timeseries processing workflow that uses an input timeseries as an input and defines processing operations to be applied to the samples of the input timeseries, perform the processing operations defined by the first timeseries processing workflow to generate a first derived timeseries comprising a first set of derived timeseries samples, identify a second timeseries processing workflow that uses the first derived timeseries as an input and defines processing operations to be applied to the samples of the first derived timeseries, and perform the processing operations defined by the second timeseries processing workflow to generate a second derived timeseries comprising a second set of derived timeseries samples.

First claim

What is claimed is:

1. A building system comprising:
a directed acyclic graph (DAG) database storing a plurality of DAGs defining processing workflows;
one or more non-transitory computer-readable media having instructions stored thereon that, when executed by one or more processors, cause the one or more processors to:
generate a first derived time correlated data stream according to a first processing workflow defined by a first DAG of the DAG database;
identify a second DAG of the DAG database that uses the first derived time correlated data stream as an input to derive a second derived time correlated data stream by determining whether any of the plurality of DAGs stored in the DAG database use the first derived time correlated data stream as an input, wherein the second DAG defines one or more processing operations of a second processing workflow to be applied to the first derived time correlated data stream; and
generate the second derived time correlated data stream based on the second DAG and the first derived time correlated data stream.

2. The building system of claim 1 , wherein the first derived time correlated data stream is a first timeseries and the second derived time correlated data stream is a second timeseries.

3. The building system of claim 1 , wherein the instructions cause the one or more processors to:
store the first derived time correlated data stream and the second derived time correlated data stream in a data stream database.

4. The building system of claim 1 , comprising:
building equipment configured to provide samples of one or more data points to the one or more processors;
wherein the instructions cause the one or more processors to:
collect the samples from the building equipment and generate an input time correlated data streams comprising a plurality of the samples of the one or more data points;
identify the first DAG defining the first processing workflow that uses the input time correlated data streams as an input, wherein the first DAG defines one or more first processing operations to be applied to the samples of the input time correlated data streams; and
generate the first derived time correlated data stream according to the first DAG by performing the one or more first processing operations defined by the first DAG, the first derived time correlated data stream comprising a first set of derived samples.

5. The building system of claim 1 , wherein the instructions cause the one or more processors to:
generate the first derived time correlated data stream according to the first processing workflow based on data received from building equipment, wherein the building equipment include at least one of a sensor, heating, ventilation, and air conditioning (HVAC) equipment, lighting equipment, access control equipment, or security equipment.

6. The building system of claim 1 , wherein the instructions cause the one or more processors to:
identify one or more other timeseries to be used as inputs to the first DAG; and
generate an enriched processing workflow comprising the first DAG, an input time correlated data streams, and the one or more other timeseries.

7. The building system of claim 1 , wherein the instructions cause the one or more processors to generate the first derived time correlated data stream by:
transforming one or more samples of an input time correlated data streams into one or more samples of a first set of derived samples by applying the one or more samples of the input time correlated data streams as an input to the first processing workflow of the first DAG; and
assembling the first set of derived samples to form the first derived time correlated data stream.

8. The building system of claim 1 , wherein the first DAG defines a first timeseries processing workflow and one or more first processing operations of the first DAG are timeseries processing operations;
wherein the second DAG defines a second timeseries processing workflow and the one or more processing operations of the second DAG are timeseries processing operations.

9. The building system of claim 1 , wherein the instructions cause the one or more processors to:
identify the second DAG that uses the first derived time correlated data stream as an input, wherein the second DAG defines the one or more processing operations to be applied to samples of the first derived time correlated data stream; and
generate the second derived time correlated data stream by performing the one or more processing operations defined by the second DAG, the second derived time correlated data stream comprising a second set of derived samples.

10. The building system of claim 1 , wherein the instructions cause the one or more processors to generate the second derived time correlated data stream by:
transforming one or more samples of a first set of derived samples of the first derived time correlated data stream into one or more samples of a second set of derived samples by applying the one or more samples of the first set of derived samples as an input to the second DAG; and
assembling the second set of derived samples to form the second derived time correlated data stream.

11. A method comprising:
generating, by one or more processing circuits, a first derived time correlated data stream according to a first processing workflow defined by a first directed acyclic graph (DAG) of a DAG database storing a plurality of DAGs defining processing workflows;
identifying, by the one or more processing circuits, a second DAG of the DAG database that uses the first derived time correlated data stream as an input to derive a second derived time correlated data stream by determining whether any of the plurality of DAGs stored in the DAG database use the first derived time correlated data stream as an input, wherein the second DAG defines one or more processing operations of a second processing workflow to be applied to the first derived time correlated data stream; and
generating, by the one or more processing circuits, the second derived time correlated data stream based on the second DAG and the first derived time correlated data stream.

12. The method of claim 11 , wherein the first derived time correlated data stream is a first timeseries and the second derived time correlated data stream is a second timeseries.

13. The method of claim 11 , comprising:
storing, by the one or more processing circuits, the first derived time correlated data stream and the second derived time correlated data stream in a data stream database.

14. The method of claim 11 , comprising:
collecting, by the one or more processing circuits, samples from building equipment and generate an input time correlated data streams comprising a plurality of the samples of one or more data points of building equipment configured to provide the samples of the one or more data points;
identifying, by the one or more processing circuits, the first DAG defining the first processing workflow that uses the input time correlated data streams as an input, wherein the first DAG defines one or more first processing operations to be applied to the samples of the input time correlated data streams; and
generating, by the one or more processing circuits, the first derived time correlated data stream according to the first DAG by performing the one or more first processing operations defined by the first DAG, the first derived time correlated data stream comprising a first set of derived samples.

15. The method of claim 11 , further comprising:
generating, by the one or more processing circuits, the first derived time correlated data stream acc

Assignees

• Johnson Controls Tech Co

Inventors

• Park Youngchoon
• Sinha Sudhi R
• Venkiteswaran Vaidhyanathan
• Paulson Erik S
• Chennupati Vijaya S

Classifications

• G05B23/0264

  Control of logging system, e.g. decision on which data to store; time-stamping measurements · CPC title

• G05B15/02 Primary

  electric · CPC title

• G06F16/2474

  Sequence data queries, e.g. querying versioned data · CPC title

• G06F16/9024

  Graphs; Linked lists (G06F16/9027 takes precedence) · CPC title

• G06F16/258

  Data format conversion from or to a database · CPC title