Building management system with nested stream generation

• US 10,452,043 B2
• Filed: 09/26/2018
• Issued: 10/22/2019
• Est. Priority Date: 02/10/2017
• Status: Active Grant

• Current Assignee: Johnson Controls Technology Company (Johnson Controls International plc)
• Original Assignee: Johnson Controls Technology Company (Johnson Controls International plc)
• Inventors: Park, Youngchoon, Sinha, Sudhi R., Venkiteswaran, Vaidhyanathan, Paulson, Erik S., Chennupati, Vijaya S.
• Primary Examiner(s): Moser, Bruce M
• Application Number:
  US16/142,943
• Publication Number:
  US 20190025786A1
• Time in Patent Office: 391 Days
• CPC Class Codes: G05B 15/02 electric
• CPC Class Codes: G05B 19/042 using digital processors G05B19/05 takes precedence
• CPC Class Codes: G05B 2219/24024 Safety, surveillance
• CPC Class Codes: G05B 2219/25011 Domotique, I-O bus, home automation, building automation
• CPC Class Codes: G05B 2219/2614 HVAC, heating, ventillation, climate control
• CPC Class Codes: G05B 23/0264 Control of logging system, e.g. decision on which data to store; time-stamping measurements
• CPC Class Codes: G06F 16/2474 Sequence data queries, e.g. querying versioned data
• CPC Class Codes: G06F 16/258 Data format conversion from or to a database
• CPC Class Codes: G06F 16/9024 Graphs; Linked lists G06F16/9027 takes precedence

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.

Claims

1. A building management system comprising:

building equipment configured to provide samples of one or more data points in the building management system;

a data collector configured to collect the samples from the building equipment and generate one or more input timeseries comprising a plurality of the samples;

a timeseries service comprising one or more processors, and one or more non-transitory computer-readable media communicably coupled to the one or more processors having instructions stored thereon that, when executed by the one or more processors, cause the one or more processors to;

identify a first timeseries processing workflow that uses the one or more input timeseries as an input and defines one or more processing operations to be applied to the samples of the one or more input timeseries;

perform the one or more 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 one or more processing operations to be applied to the samples of the first derived timeseries; and

perform the one or more processing operations defined by the second timeseries processing workflow to generate a second derived timeseries comprising a second set of derived timeseries samples;

a timeseries storage interface configured to store the one or more input timeseries and the first and second derived timeseries in a timeseries database; and

a directed acyclic graph (DAG) database storing a plurality of DAGs, each of the DAGs defining a timeseries processing workflow,

wherein the timeseries service comprises a DAG identifier configured to determine whether any of the DAGs stored in the DAG database use the one or more input timeseries or the first derived timeseries as an input.

2. The building management system of claim 1, wherein the building equipment comprise at least one of sensors, HVAC equipment lighting equipment, access control equipment, or security equipment.

3. The building management system of claim 1, wherein generating the first derived timeseries comprises:

transforming one or more samples of the one or more input timeseries into one or more samples of the first set of derived timeseries samples by applying the one or more samples of the one or more input timeseries as an input to the first timeseries processing workflow; and

assembling the first set of derived timeseries samples to form the first derived timeseries.

4. The building management system of claim 1, wherein generating the second derived timeseries comprises:

transforming one or more samples of the first set of derived timeseries samples into one or more samples of the second set of derived timeseries samples by applying the one or more samples of the first set of derived timeseries samples as an input to the second timeseries processing workflow; and

assembling the second set of derived timeseries samples to form the second derived timeseries.

5. The building management system of claim 1, wherein the timeseries service is configured to:

identify one or more other timeseries to be used as inputs to the first timeseries processing workflow; and

generate an enriched timeseries processing workflow comprising the first timeseries processing workflow, the one or more input timeseries, and the one or more other timeseries.

6. The building management system of claim 1, wherein upon generating a derived timeseries, the timeseries service is configured to:

(a) determine whether the derived timeseries is used as an input to any of a plurality of stored timeseries processing workflows;

(b) in response to a determination that the derived timeseries is used as an input to at least one of the stored timeseries processing workflows, perform one or more processing operations defined by the timeseries processing workflows that use the derived timeseries as an input to generate another derived timeseries; and

(c) iteratively repeat steps (a) and (b) until the derived timeseries generated in step (b) is not used as an input to any of the plurality of stored timeseries processing workflows.

7. A building management system for managing timeseries data provided by building equipment, the building management system comprising:

one or more non-transitory computer-readable storage media having instructions stored thereon that, when executed by one or more processors, cause the one or more processors to;

collect samples of the timeseries data from the building equipment and generate one or more input timeseries, the one or more input timeseries corresponding to a time correlated data stream comprising a plurality of the samples;

identify a first timeseries processing workflow that uses the one or more input timeseries as an input and defines one or more processing operations to be applied to the time correlated data stream including the samples of the one or more input timeseries;

perform the one or more processing operations defined by the first timeseries processing workflow on the time correlated data stream of the samples to transform one or more of the samples into a first set of derived timeseries samples to generate a first derived timeseries corresponding to a first derived time correlated data stream comprising the first set of derived timeseries samples;

identify a second timeseries processing workflow that uses the first derived timeseries as an input and defines one or more processing operations to be applied to the first derived time correlated data stream including the first set of derived time series samples of the first derived timeseries;

perform the one or more processing operations defined by the second timeseries processing workflow on the first derived time correlated data stream to transform one or more of the first set of derived time series samples into a second set of derived timeseries samples to generate a second derived timeseries corresponding to a second derived time correlated data stream comprising the second set of derived timeseries samples; and

store the one or more input timeseries and the first and second derived timeseries in a timeseries database.

8. The building management system of claim 7, wherein the building equipment comprise at least one of sensors, HVAC equipment lighting equipment, access control equipment, or security equipment.

9. The building management system of claim 7, wherein generating the first derived timeseries comprises:

transforming one or more samples of the one or more input timeseries into one or more samples of the first set of derived timeseries samples by applying the one or more samples of the one or more input timeseries as an input to the first timeseries processing workflow; and

assembling the first set of derived timeseries samples to form the first derived timeseries.

10. The building management system of claim 7, wherein generating the second derived timeseries comprises:

transforming one or more samples of the first set of derived timeseries samples into one or more samples of the second set of derived timeseries samples by applying the one or more samples of the first set of derived timeseries samples as an input to the second timeseries processing workflow; and

assembling the second set of derived timeseries samples to form the second derived timeseries.

11. The building management system of claim 7, wherein the instructions cause the one or more processors to:

identify one or more other timeseries to be used as inputs to the first timeseries processing workflow; and

generate an enriched timeseries processing workflow comprising the first timeseries processing workflow, the one or more input timeseries, and the one or more other timeseries.

12. The building management system of claim 7, further comprising a directed acyclic graph (DAG) database storing a plurality of DAGs, each of the DAGs defining a timeseries processing workflow;

wherein the instructions cause the one or more processors to determine whether any of the DAGs stored in the DAG database use the one or more input timeseries or the first derived timeseries as an input.

13. The building management system of claim 7, wherein upon generating a derived timeseries, the instructions cause the one or more processors to:

(a) determine whether the derived timeseries is used as an input to any of a plurality of stored timeseries processing workflows;

(b) in response to a determination that the derived timeseries is used as an input to at least one of the stored timeseries processing workflows, perform one or more processing operations defined by the timeseries processing workflows that use the derived timeseries as an input to generate another derived timeseries; and

(c) iteratively repeat steps (a) and (b) until the derived timeseries generated in step (b) is not used as an input to any of the plurality of stored timeseries processing workflows.

14. A method for managing timeseries data provided by building equipment, the method comprising:

collecting samples of the timeseries data from the building equipment and generating one or more input timeseries comprising a plurality of the samples;

identifying a first timeseries processing workflow that uses the one or more input timeseries as an input and defines one or more processing operations to be applied to the samples of the one or more input timeseries;

performing the one or more processing operations defined by the first timeseries processing workflow to generate a first derived timeseries comprising a first set of derived timeseries samples;

identifying a second timeseries processing workflow that uses the first derived timeseries as an input and defines one or more processing operations to be applied to the samples of the first derived timeseries;

performing the one or more processing operations defined by the second timeseries processing workflow to generate a second derived timeseries comprising a second set of derived timeseries samples;

storing the one or more input timeseries and the first and second derived timeseries in a timeseries database;

storing a plurality of directed acyclic graphs (DAGs), each of the DAGs defining a timeseries processing workflow; and

determining whether any of the stored DAGs use the one or more input timeseries or the first derived timeseries as an input.

15. The method of claim 14, wherein the building equipment comprise at least one of sensors, HVAC equipment lighting equipment, access control equipment, or security equipment.

16. The method of claim 14, wherein generating the first derived timeseries comprises:

transforming one or more samples of the one or more input timeseries into one or more samples of the first set of derived timeseries samples by applying the one or more samples of the one or more input timeseries as an input to the first timeseries processing workflow; and

assembling the first set of derived timeseries samples to form the first derived timeseries.

17. The method of claim 14, wherein generating the second derived timeseries comprises:

transforming one or more samples of the first set of derived timeseries samples into one or more samples of the second set of derived timeseries samples by applying the one or more samples of the first set of derived timeseries samples as an input to the second timeseries processing workflow; and

assembling the second set of derived timeseries samples to form the second derived timeseries.

18. The method of claim 14, further comprising:

identifying one or more other timeseries to be used as inputs to the first timeseries processing workflow; and

generating an enriched timeseries processing workflow comprising the first timeseries processing workflow, the one or more input timeseries, and the one or more other timeseries.

19. The method of claim 14, further comprising, upon generating a derived timeseries:

(a) determining whether the derived timeseries is used as an input to any of a plurality of stored timeseries processing workflows;

(b) in response to a determination that the derived timeseries is used as an input to at least one of the stored timeseries processing workflows, performing one or more processing operations defined by the timeseries processing workflows that use the derived timeseries as an input to generate another derived timeseries; and

(c) iteratively repeating steps (a) and (b) until the derived timeseries generated in step (b) is not used as an input to any of the plurality of stored timeseries processing workflows.