Method to combine partially aggregated sensor data in a distributed sensor system

A method for processing sensor data, comprising

• receiving sensor data messages from at least one sensor of a distributed sensor system, the distributed sensor system including a plurality of spatially distributed sensor nodes in communication with a data network, each sensor node including one or more sensors configured to measure at least one of an air quality parameter and an environment parameter;
• processing the sensor data messages using distributed stateless processing to generate sensor data values;
• generating aggregated sensor data values from the sensor data values, the aggregated sensor data values being associated with a first sensor and belonging to one or more aggregation time intervals, the generating being performed using multiple distributed, parallel aggregation processes running on one or more processors, the generating the aggregated sensor data values further including tagging each aggregated sensor data value with an aggregation indicator, the aggregation indicator having a first value to indicate that the aggregated sensor data value comprises a partially aggregated sensor data value having aggregated a unique portion of the sensor data values for the first sensor within a given aggregation time interval, and the aggregation indicator having a second value to indicate that the aggregated sensor data value comprises a complete aggregated sensor data value having aggregated all of the sensor data values for the first sensor within the given aggregation time interval;
• and
• storing in a memory the aggregated sensor data values tagged with the aggregation indicator.

A system for processing sensor data comprising:

• a processor configured to:
• receive sensor data messages from at least one sensor of a distributed sensor system, the distributed sensor system including a plurality of spatially distributed sensor nodes in communication with a data network, each sensor node including one or more sensors configured to measure at least one of an air quality parameter and an environment parameter;
• process the sensor data messages using distributed stateless processing to generate sensor data values;
• and
• generate aggregated sensor data values from the sensor data values, the aggregated sensor data values being associated with a first sensor and belonging to one or more aggregation time intervals, the generating being performed using multiple distributed, parallel aggregation processes running on one or more processors, the generating the aggregated sensor data values further including tagging each aggregated sensor data value with an aggregation indicator, the aggregation indicator having a first value to indicate that the aggregated sensor data value comprises a partially aggregated sensor data value having aggregated a unique portion of the sensor data values for the first sensor within a given aggregation time interval, and the aggregation indicator having a second value to indicate that the aggregated sensor data value comprises a complete aggregated sensor data value having aggregated all of the sensor data values for the first sensor within the given aggregation time interval;
• and
• store in a memory the aggregated sensor data values tagged with the aggregation indicator;
• and
• a memory coupled to the processor and configured to provide the processor with instructions.