Building management system with timeseries processing

1. A building management system comprising:

building equipment that provide raw data samples of one or more data points in the building management system, the building equipment comprising one or more physical devices that operate to monitor or control a physical building condition, the physical devices comprising at least one of a sensor, an air handling unit, a heater, a chiller, a boiler, a pump, a valve, a fan, an actuator, or a controller;

a processing system comprising one or more processors and one or more memories having instructions stored thereon that, when executed by the one or more processors, cause the processing system to operate as a data collector, a timeseries processing engine, a control application, and a timeseries storage interface;

the data collector operates to collect the raw data samples from the building equipment and generate one or more raw data timeseries comprising a plurality of the raw data samples, each of the raw data samples comprising a timestamp and a data value;

the timeseries processing engine operates to:

identify an initial timeseries processing workflow that applies to the raw data timeseries, the initial timeseries processing workflow being stored in a timeseries processing workflow database, and retrieve the initial timeseries processing workflow from the timeseries processing workflow database, the initial timeseries processing workflow comprising a predefined sequence of timeseries processing operations;

identify one or more other data timeseries required as inputs to the initial timeseries processing workflow;

generate an enriched timeseries processing workflow comprising the initial timeseries processing workflow, the raw data timeseries, and the other data timeseries; and

execute the enriched timeseries processing workflow to generate one or more derived data timeseries from the raw data timeseries and the one or more other data timeseries;

the timeseries storage interface operates to store the raw data timeseries and the derived data timeseries in a timeseries database; and

the control application operates to:

generate a control signal for the building equipment based at least in part on the derived data timeseries stored in the timeseries database; and

control the physical building condition by operating the building equipment based on the control signal.

2. The building management system of claim 1 , wherein the timeseries processing engine operates to:

identify and obtain samples of the raw data timeseries and the other data timeseries required to perform the timeseries processing operations; and

generate the enriched timeseries processing workflow comprising the identified samples of the raw data timeseries and the other data timeseries.

3. The building management system of claim 1 , wherein the timeseries processing engine operates to:

determine a time window based on an aggregation period specified by the timeseries processing operations; and

obtain samples of the raw data timeseries and the other data timeseries that have timestamps within the time window.

4. The building management system of claim 3 , wherein the timeseries processing engine operates to determine the time window based on the timestamp of the raw data samples and a duration of the aggregation period specified by the timeseries processing operations.

5. The building management system of claim 1 , wherein the timeseries processing engine operates to:

tag each of the timeseries processing operations in the enriched timeseries processing workflow with an indication of an execution engine; and

execute each timeseries processing operation using the indicated execution engine.

6. The building management system of claim 1 , wherein the timeseries processing engine operates to:

accept a post-sample request associated with the raw data timeseries; and

execute the post-sample request in response to obtaining one or more new samples of the raw data timeseries.

7. The building management system of claim 1 , wherein the initial timeseries processing workflow comprises:

an indication of one or more input timeseries to which the initial timeseries processing workflow applies;

the predefined sequence of timeseries processing operations; and

an indication of one or more derived data timeseries generated by applying the predefined sequence of timeseries processing operations to the input timeseries.

8. The building management system of claim 7 , wherein the input timeseries comprise at least one of:

the one or more raw data timeseries generated by the data collector; or

the one or more derived data timeseries generated by the timeseries processing engine.

9. The building management system of claim 1 , wherein the initial timeseries processing workflow comprises a directed acyclic graph visually representing the predefined sequence of timeseries processing operations in the initial timeseries processing workflow.

10. The building management system of claim 9 , wherein the directed acyclic graph comprises:

one or more input blocks representing one or more input timeseries to which the initial timeseries processing workflow applies;

one or more functional blocks representing the predefined sequence of timeseries processing operations in the initial timeseries processing workflow; and

one or more output blocks representing one or more derived data timeseries generated by applying the predefined sequence of timeseries processing operations to the input timeseries.

11. The building management system of claim 1 , wherein the processing system is distributed across a plurality of computing devices, wherein the plurality of computing devices comprises at least one of one or more heating, ventilation, and air conditioning (HVAC) controllers or one or more cloud-based computing systems;

wherein the processing system operates as the control application via the one or more HVAC controllers;

wherein the processing system operates as the data collector, the timeseries processing engine, and the timeseries storage interface via the one or more cloud-based computing systems.

12. A method for processing timeseries data, the method comprising:

operating building equipment comprising one or more physical devices to monitor or control a physical building condition and to generate raw data samples of one or more data points, the physical devices comprising at least one of a sensor, an air handling unit, a heater, a chiller, a boiler, a pump, a valve, a fan, an actuator, or a controller;

collecting the raw data samples from the building equipment at a processing system, the processing system comprising one or more processors and one or more memories;

generating, by the processing system, one or more raw data timeseries comprising a plurality of the raw data samples, each of the raw data samples comprising a timestamp and a data value;

identifying, by the processing system, an initial timeseries processing workflow that applies to the raw data timeseries, the initial timeseries processing workflow being stored in a timeseries processing workflow database, the initial timeseries processing workflow comprising a predefined sequence of timeseries processing operations;

retrieving, by the processing system, the initial timeseries processing workflow from the timeseries processing workflow database;

identifying, by the processing system, one or more other data timeseries required as inputs to the initial timeseries processing workflow;

generating, by the processing system, an enriched timeseries processing workflow comprising the initial timeseries processing workflow, the raw data timeseries, and the other data timeseries;

executing, by the processing system, the enriched timeseries processing workflow to generate one or more derived data timeseries from the raw data timeseries and the one or more other data timeseries;

storing, by the processing system, the raw data timeseries and the derived data timeseries in a timeseries database

generating, by the processing system, a control signal for the building equipment based at least in part on the derived data timeseries stored in the timeseries database; and

controlling, by the processing system, the physical building condition by operating the building equipment based on the control signal.

13. The method of claim 12 , comprising:

identifying and obtaining samples of the raw data timeseries and the other data timeseries required to perform the timeseries processing operations; and

generating the enriched timeseries processing workflow comprising the identified samples of the raw data timeseries and the other data timeseries.

14. The method of claim 12 , comprising:

determining a time window based on an aggregation period specified by the timeseries processing operations; and

obtaining samples of the raw data timeseries and the other data timeseries that have timestamps within the time window.

15. The method of claim 14 , comprising determining the time window based on a timestamp of the raw data samples and a duration of the aggregation period specified by the timeseries processing operations.

16. The method of claim 12 , comprising:

tagging each of the timeseries processing operations in the enriched timeseries processing workflow with an indication of an execution engine; and

executing each timeseries processing operation using the indicated execution engine.

17. The method of claim 12 , comprising:

accepting a post-sample request associated with the raw data timeseries; and

executing the post-sample request in response to obtaining one or more new samples of the raw data timeseries.

18. The method of claim 12 , wherein the initial timeseries processing workflow comprises:

an indication of one or more input timeseries to which the initial timeseries processing workflow applies;

the predefined sequence of timeseries processing operations; and

an indication of one or more derived data timeseries generated by applying the predefined sequence of timeseries processing operations to the input timeseries.

19. The method of claim 18 , wherein the input timeseries comprise at least one of:

the one or more raw data timeseries; or

the one or more derived data timeseries.

20. The method of claim 12 , wherein the initial timeseries processing workflow comprises a directed acyclic graph visually representing the predefined sequence of timeseries operations in the initial timeseries processing workflow.

21. The method of claim 20 , wherein the directed acyclic graph comprises:

one or more input blocks representing one or more input timeseries to which the initial timeseries processing workflow applies;

one or more functional blocks representing the predefined sequence of timeseries processing operations in the initial timeseries processing workflow; and

one or more output blocks representing one or more derived data timeseries generated by applying the predefined sequence of timeseries processing operations to the input timeseries.

22. The method of claim 12 , wherein the processing system is distributed across a plurality of computing devices, wherein the plurality of computing devices comprises at least one of one or more heating, ventilation, and air conditioning (HVAC) controllers or one or more cloud-based computing systems.