Aggregation Node

Combines multiple data points to produce a summary measure, such as sum, average, min, max, etc. This is useful for generating insights from raw data, like average temperature readings from a sensor.

What is an aggregation?

The aggregation node is designed to consolidate multiple data points into a single payload according to specified interval and group by configuration settings. This node collects data over a defined period or from specific categories, then processes and combines this information into a unified dataset. The primary purpose of the aggregation node is to simplify and summarize large volumes of data, making it easier to analyze and derive meaningful insights. By aggregating data, users can identify trends, patterns, and anomalies more effectively, enhancing the overall efficiency of data processing and reporting within their IoT systems. This node is particularly useful for creating concise and actionable summaries from continuous data streams, facilitating better decision-making and resource management.

Inputs

The Aggregation node has mandatory inputs.

Input

Requirement

Comments

Field to Aggregate

Mandatory

Enter the JSON key that holds data to be aggregated

Output Field Name

Mandatory

Enter the JSON key that will hold the aggregated output


Functionality 

The Aggregation node can be used to aggregate data for a single device or to a device label into a single payload.

Outputs 

Single payload output for the time period and the device grouping configuration.

How to Use

Implementation

In the Rayven Workflow Builder:

  • Select Functions.
  • Drag the Aggregation node to the canvas.
  • Provide an input to the Aggregation node by connecting it to another node.
  • Double click on the Aggregation node to open the configuration window.

Configuration

Section: General

This section contains basic configuration elements required for any Aggregation implementation

Field

Requirement

Comments

Node Name

Mandatory

Enter a name for this node.


This provides a handle to which you and others can refer, so it should be simple but meaningful and explain the node’s purpose.

Aggregation Interval

Mandatory

Select the interval period for the aggregation function to occur from the dropdown menu

  • 5 minutes
  • 10 minutes
  • 15 minutes
  • 30 minutes
  • Hour
  • Day
  • Week (Starts on Sunday)
  • Week (Starts on Monday)
  • Month
  • Year (Starts from January)
  • Year (Starts from July)

Output Delay (Minutes)

Optional

Enter a numerical value to set the output delay period in minutes.

Time Zone Source

Mandatory

Select from the dropdown to set the time zone used.


If Device Time Zone is selected, the time zone used will be taken from the Device Filter that was configured.


If Custom Time Zone is used, please select the Time Zone in the next dropdown menu.

Time Zone

Mandatory 


(Only if Time Zone Source is set to Custom)

Select the Time Zone to ensure that the aggregation is done for the right interval in the time zone selected.

Delay Between Devices (Milliseconds)

Optional

Enter a numerical value to set the delay between devices in milliseconds.

Field to Aggregate

Mandatory

Enter the JSON key that holds the payload to be aggregated.

Function

Mandatory

Select the calculation function from the dropdown menu

  • Average
  • Sum
  • Min
  • Max
  • First Value
  • Last Value

Output Field Name

Mandatory

Enter the JSON key that will be created to hold the output value of the aggregation. 


If the key exists in the input of the aggregation node, the previous value will be overwritten.

Group by

Mandatory

Select from the dropdown to aggregate the value by Device or by Device Label.


If Device is selected, the aggregation will be done only on the device.


If Device Label is selected, the aggregation will be done across all the devices that share the same Device Label value as configured in Device Management..