How To Send Device Telemetry Data From AWS Lambda to WEGnology

Amazon Web Services (AWS) IoT and WEGnology can work together to power your Experiences. This enables you to send device telemetry data to WEGnology and trigger workflows, build dashboards, and end-user applications. This guide walks through integrating AWS IoT with WEGnology using Lambda.

At the heart of AWS IoT is an MQTT broker and a rules engine. The rules engine is what tells AWS IoT what to do with the data once it’s received by the broker. Rules are made up of a query and one or more actions. Queries, which are similar to SQL, control the data that’s sent to the rule’s actions.

The most powerful of these, and the one we’ll be focusing on in this guide, is invoking a Lambda function. Once the data is inside Lambda, you can perform numerous tasks, including sending the data to WEGnology.

Prerequisites

Before you begin, you will need familiarity with:

• A device reporting to AWS IOT.
• Familiarity with AWS IoT.
• Familiarity with Lambda.
• Familiarity with Webhooks.

If you’re new to AWS IoT, see AWS’s Getting Started Guide before continuing with this guide.

Create WEGnology Device

First, we will create a device within WEGnology. You will be storing data from AWS as Device Attributes within WEGnology.

If you haven’t already, sign up for a WEGnology account and create an application. Once you’ve done that, let’s create a device:

1. Navigate to the Add Device Page.
2. Add one or more device attributes depending on the telemetry information your device reports.

The device below reports the temperature, so there is one attribute named “manifold_temperature” with the data type set to “Number”.

Create WEGnology Webhook

Since Lambda Functions can invoke HTTP requests, you can trigger a WEGnology Webhook and trigger a workflow.

Pro Tip: You may also trigger Lambda functions using the AWS Lambda Node. This architecture allows for bi-directional communication between AWS and WEGnology.

Let’s create a Webhook:

1. Navigate to “Webhooks” in the Application Menu.
2. Name the webhook.
3. Click “Create Webhook.”

After you create the webhook, you’ll be presented with its URL.

https://console.app.wnology.io/webhooks/YT6wZZcDB-SYrDKbbM5NTm1U4cqATjTYdd58rNSb

Keep note of the URL as we will use it in our Lambda Function.

Create the Lambda Function

Within the AWS portal, create a new blank Lambda function.

Many of the other settings are specific to your AWS environment. Refer to the Lambda Getting Started Guide for more details.

Invoke the Webhook from Lambda

Let’s update your Lambda function with Node.js using the built-in HTTP module to request the WEGnology webhook.

1. Copy and paste the following JavaScript into your function:

var https = require('https');

exports.handler = (event, context, callback) => {

  var postData = JSON.stringify(event);

  var options = {
    hostname: 'triggers.wnology.io',
    port: 443,
    path: '/webhooks/my-webhook-id',
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'Content-Length': Buffer.byteLength(postData)
    }
  };

  var req = https.request(options, (res) => {
    console.log(`STATUS: ${res.statusCode}`);
    console.log(`HEADERS: ${JSON.stringify(res.headers)}`);
    res.setEncoding('utf8');
    res.on('data', (chunk) => {
      console.log(`BODY: ${chunk}`);
    });
    res.on('end', () => {
      callback();
    });
  });

  req.on('error', (e) => {
    console.log(`problem with request: ${e.message}`);
    callback();
  });

  // write data to request body
  req.write(postData);
  req.end();
};

2. Replace '/webhooks/my-webhook-id' with the path in your Webhook URL.

In this case event will be device telemetry data from AWS IoT and then sent with an HTTP POST to a WEGnology Webhook.

Now, we can configure AWS IoT to trigger the Lambda Function.

Create the AWS IoT Rule

The rule you create will send data into Lambda whenever specific topic or attribute is recorded. To create the rule:

1. Within AWS IoT, navigate to the Rules section.
2. Create a new rule.

3. Configure the “Rule Query Statement”;

Here is an example query:

SELECT temperature FROM 'iot/topic' WHERE temperature > 50

With the above query, we can trigger the rule using AWS Publishing Tool with the following data:

For more information see AWS IOT SQL Reference.

3. Add an action and select the Lambda.

5. Choose your newly created Lambda function from the list and click the “Add action” button.

6. Click the “Create Rule” button to complete the process.

Now that our rule is created, we can build a WEGnology Workflow to accept incoming data.

Trigger a Workflow

Here is the Application Workflow we are going to create:

When this Workflow is triggered, you will get a payload that looks like this:

We can see that the data from the Lambda HTTP POST request can be found at:

data.body.temperature

We can now build our workflow to use this data within WEGnology. To create this workflow:

1. Drag a Webhook Trigger onto the workflow canvas. Select your Webhook in the node’s configuration.
2. Connect a Device: State Node to the Webhook Trigger. This allows a workflow to save data to WEGnology’s time-series database.
3. Connect a Debug Node to the Device: State Node.

Next, we can configure the Device: State Node:

1. Select your Device you created in the previous step.
2. In the state configuration, add a template with the payload payload path of: {{data.body.temperature}}.

Deploy this workflow using the “Deploy Workflow” button at the top-right of the screen.

If your device is properly reporting state, you can see this reflected in your Device Logs:

What’s next?

With the data on a WEGnology device, you can now easy build complex, data-driven solutions using our dashboards, workflows, and build Experiences.

Here are some great resources:

• Application Templates
• Template Library
• How-to Guides