IoT Edge Event Aggregation Module

This project hosts the source code for the IoT Edge Event Aggregation module. The edge module is a NodeJS application that aggregates events from EdgeHub according to the specified OUTPUT_FREQUENCY and compress them using gzip.

For downstream the events, the SplitMessagesFunction uncompressed the events from IoT Hub and splits them into individual messages into the output event hub.

Usage

To use the module, you need to deploy the following Azure IoT Edge module:

 "AggregationModule": {
        "restartPolicy": "always",
        "settings": {
            "image": "ghcr.io/kbeaugrand-org/azure-iotedge-aggregationmodule:latest",
            "createOptions": "{}"
        },
        "status": "running",
        "type": "docker",
        "env": {
          "OUTPUT_FREQUENCY" : {
            "value": "1000"
          }
        }
    }

Edge Hub routing

    "routes": {
        "EdgeModuleToAggregation": "FROM /messages/modules/* INTO BrokeredEndpoint(\"/modules/AggregationModule/inputs/inputMessage\")",
        "AggregationModuleToUpstream": "FROM /messages/modules/AggregationModule/outputs/* INTO $upstream"
    },

Environment variables

OUTPUT_FREQUENCY: The frequency in milliseconds to aggregate events.

License

This project is licensed under the MIT License (see ./LICENSE.md) for more details.