Use AWS Lambda with MQTT

Open the Amazon Location Service console at https://console.aws.amazon.com/location/.

In the left navigation pane, choose Trackers.

Choose Create tracker.

Fill out the following boxes:

Choose Create tracker.

Open the AWS Lambda console at https://console.aws.amazon.com/lambda/.

From the left navigation, choose Functions.

Choose Create Function, and make sure that Author from scratch is selected.

Fill out the following boxes:

Choose Create function.

Choose the Code tab to open the editor.

Overwrite the placeholder code in lambda_function.py with the following, replacing the value assigned to TRACKER_NAME with the name of the tracker that you created as a prerequisite.

from datetime import datetime
import json
import os

import boto3

# Update this to match the name of your Tracker resource
TRACKER_NAME = "MyTracker"

"""
This Lambda function receives a payload from AWS IoT Core and publishes device updates to 
Amazon Location Service via the BatchUpdateDevicePosition API.

Parameter 'event' is the payload delivered from AWS IoT Core.

In this sample, we assume that the payload has a single top-level key 'payload' and a nested key
'location' with keys 'lat' and 'long'. We also assume that the name of the device is nested in
the payload as 'deviceid'. Finally, the timestamp of the payload is present as 'timestamp'. For
example:

>>> event
{ 'payload': { 'deviceid': 'thing123', 'timestamp': 1604940328,
  'location': { 'lat': 49.2819, 'long': -123.1187 },
  'accuracy': {'Horizontal': 20.5 },
  'positionProperties': {'field1':'value1','field2':'value2'} }
}

If your data doesn't match this schema, you can either use the AWS IoT Core rules engine to
format the data before delivering it to this Lambda function, or you can modify the code below to
match it.
"""
def lambda_handler(event, context):
  update = {
      "DeviceId": event["payload"]["deviceid"],
      "SampleTime": datetime.fromtimestamp(event["payload"]["timestamp"]).strftime("%Y-%m-%dT%H:%M:%SZ"),
      "Position": [
        event["payload"]["location"]["long"],
        event["payload"]["location"]["lat"]
        ]
    }
  if "accuracy" in event["payload"]:
      update["Accuracy"] = event["payload"]['accuracy']
  if "positionProperties" in event["payload"]:
      update["PositionProperties"] = event["payload"]['positionProperties']
 
  client = boto3.client("location")
  response = client.batch_update_device_position(TrackerName=TRACKER_NAME, Updates=[update])

  return {
    "statusCode": 200,
    "body": json.dumps(response)
  }

Choose Deploy to save the updated function.

Choose the Configuration tab.

In the Permissions section, choose the hyperlinked Role name to grant Amazon Location Service permissions to your Lambda function.

From your role's Summary page, choose Add permissions, and then from the dropdown list, select Create inline policy.

Choose the JSON tab, and overwrite the policy with the following document. This allows your Lambda function to update device positions managed by all tracker resources across all Regions.

{
  "Version": "2012-10-17",
  "Statement": [
    {
      "Sid": "WriteDevicePosition",
      "Effect": "Allow",
      "Action": "geo:BatchUpdateDevicePosition",
      "Resource": "arn:aws:geo:*:*:tracker/*"
    }
  ]
}

Choose Review policy.

Enter a policy name. For example, AmazonLocationTrackerWriteOnly.

Choose Create policy.

Sign in to the AWS IoT Core console at https://console.aws.amazon.com/iot/.

In the left navigation, expand Act, and choose Rules.

Choose Create a rule to start the new rule wizard.

Enter a name and description for your rule.

For the Rule query statement, update the FROM attribute to refer to a topic where at least one device is publishing telemetry that includes location. If you are testing the solution, no modification is needed.

SELECT * FROM 'iot/topic'

Under Set one or more actions , choose Add action.

Select Send a message to a lambda function.

Choose Configure action.

Find and select your Lambda function from the list.

Choose Add action.

Choose Create rule.

Sign in to the AWS IoT Core console at https://console.aws.amazon.com/iot/.

In the left navigation, expand Test, and choose MQTT test client.

Under Publish to a topic, set the Topic name to iot/topic (or the name of the topic that you set up in your AWS IoT Core rule, if different), and provide the following for the Message payload. Replace the timestamp 1604940328 with a valid timestamp within the last 30 days (any timestamps older than 30 days are ignored).

{
  "payload": {
    "deviceid": "thing123",
    "timestamp": 1604940328,
    "location": { "lat": 49.2819, "long": -123.1187 },
    "accuracy": { "Horizontal": 20.5 },
    "positionProperties": { "field1": "value1", "field2": "value2" }
  }
}

Choose Publish to topic to send the test message.

To validate that the message was received by Amazon Location Service, use the following AWS CLI command. If you modified them during setup, replace the tracker name and device id with the ones that you used.

aws location batch-get-device-position --tracker-name MyTracker --device-ids thing123