beetaone/aggregator repository overview

⁠Aggregator

• Aggregator⁠
  • Description⁠
  • Environment Variables⁠
    • Module Specific⁠
    • Set by the beetaone Agent on the edge-node⁠
  • Dependencies⁠
  • Input⁠
  • Output⁠

⁠Description

Aggregator is a processing module responsible for aggregating data passing through beetaone data services. Aggregator collects data within a time interval specified by a data service developer, and then it applies a chosen aggregation function. This module is containerized using Docker.

Supported functions:

• mean (mean value that arrived within the specified interval)
• max (maximum value)
• spread (maximum - minimum value)
• median (median value recorded within the interval)
• sum (sum of all received values)
• stddv (standard deviation of values)
• count (number of data that arrived within the interval)
• first (first recorded data)
• min (minimum value)
• last (last recorded data)

⁠Environment Variables

⁠Module Specific

The following module configurations can be provided in a data service designer section on beetaone platform:

⁠Set by the beetaone Agent on the edge-node

Other features required for establishing the inter-container communication between modules in a data service are set by beetaone agent.

⁠Dependencies

bottle
requests

⁠Input

Input to this module is JSON body single object:

Example:

{
  temperature: 15,
  input_unit: Celsius
}

⁠Output

Output of this module is JSON body array of objects.

Output of this module is JSON body:

{
    "<OUTPUT_LABEL>": <Processed data>,
}

• Here OUTPUT_LABEL is specified at the module creation and Processed data is data processed by Module Main function.

Example:

{
  meanTemp: 54.7,
}