通过 MQTT 使用 AWS Lambda - Amazon Location Service
先决条件创建 Lambda 函数创建 AWS IoT Core 规则可选：测试您的 AWS IoT Core 规则

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

通过 MQTT 使用 AWS Lambda

虽然在向 Amazon Location 发送设备位置数据进行跟踪时不再需要使用 AWS Lambda，但在某些情况下，您可能仍想使用 Lambda。例如，如果您想在将设备位置数据发送到 Amazon Location 之前自己处理设备位置数据。以下主题介绍如何在消息发送到您的跟踪器之前使用 Lambda 处理消息。有关此模式的更多信息，请参阅参考架构。

先决条件

在开始追踪之前，必须先创建跟踪器资源。要创建跟踪器资源，您可以使用 Amazon Location 控制台、AWS CLI 或 Amazon Location API。

以下示例使用 Amazon Location Service 控制台创建跟踪器资源：

  1. 打开 Amazon Location Service 控制台：https://console.aws.amazon.com/location/。

  2. 在左侧导航窗格中，选择跟踪器。

  3. 选择创建跟踪器。

  4. 填写以下选框：

    • 名称——输入一个最多包含 100 个字符的唯一名称。有效条目包括：字母数字字符、连字符和下划线。例如，MyTracker。

    • 描述——输入可选描述。例如，用于存储 AWS IoT Core 设备位置的跟踪器。

    • 位置筛选——选择要用于位置更新的筛选。例如，基于精度的筛选。

  5. 选择创建跟踪器。

创建 Lambda 函数

要在 AWS IoT Core 和 Amazon Location Service 之间建立连接，您需要一个 AWS Lambda 函数来处理由 AWS IoT Core 转发的消息。此函数将提取所有位置数据，将其格式化为 Amazon Location Service，然后通过 Amazon Location 跟踪器 API 提交。您可以通过 AWS Lambda 控制台创建此函数，也可以使用 AWS Command Line Interface (AWS CLI) 或 AWS Lambda API。

要使用控制台创建 Lambda 函数，将位置更新发布到 Amazon Location，请执行以下操作：

  1. 通过 https://console.aws.amazon.com/lambda/ 打开 AWS Lambda 控制台。

  2. 从左侧导航窗格中，选择函数。

  3. 选择创建函数，并确保选择从头开始创作。

  4. 填写以下选框：

    • 函数名称——输入您的函数的唯一名称。有效条目包括字母数字字符、连字符和下划线，不带空格。例如，MyLambda。

    • 运行时系统——选择 Python 3.8。

  5. 选择创建函数。

  6. 选择 代码 选项卡以打开编辑器。

  7. 用以下代码替换 lambda_function.py 中的占位符代码，将分配给 TRACKER_NAME 的值替换为您作为先决条件创建的跟踪器的名称。

    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)
  }

  8. 选择部署以保存您更新的函数。

  9. 选择配置选项卡。

  10. 在权限部分，选择超链接的角色名称以授予 Amazon Location Service 对您的 Lambda 函数的权限。

  11. 在角色的摘要页面中，选择添加权限，然后从下拉列表中选择创建内联策略。

  12. 选择 JSON 选项卡，并用以下文档覆盖策略。这允许您的 Lambda 函数更新由所有区域的所有跟踪器资源管理的设备位置。

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

  13. 选择查看策略。

  14. 输入策略名称。例如，AmazonLocationTrackerWriteOnly。

  15. 选择创建策略。

您可以根据需要修改此函数代码，以适应您自己的设备消息架构。

创建 AWS IoT Core 规则

接下来，创建一条 AWS IoT Core 规则，将设备的位置遥测数据转发给 AWS Lambda 函数，以便转换并发布到 Amazon Location Service。提供的示例规则假设设备有效负载的任何必要转换均由您的 Lambda 函数处理。您可以通过 AWS IoT Core 控制台、AWS Command Line Interface (AWS CLI) 或 AWS IoT Core API 创建此规则。

注意

虽然 AWS IoT 控制台处理允许 AWS IoT Core 调用您的 Lambda 函数所需的权限，但如果您从 AWS CLI 或 SDK 创建规则，则必须配置策略以授予 AWS IoT 权限。

使用控制台创建 AWS IoT Core

  1. 登录AWS IoT Core控制台，网址为 https://console.aws.amazon.com/iot/。

  2. 在左侧导航窗格中，展开行动，并选择规则。

  3. 选择创建规则以启动新规则向导。

  4. 为您的规则输入名称和描述。

  5. 对于规则查询语句，请更新 FROM 属性，以引用至少一台设备正在发布包含位置的遥测的主题。如果您正在测试解决方案，则无需进行任何修改。

    SELECT * FROM 'iot/topic'

  6. 在设置一个或多个操作下，选择添加操作。

  7. 选择向 Lambda 函数发送消息。

  8. 选择 Configure action。

  9. 从列表中选择您的 Lambda 函数。

  10. 选择添加操作。

  11. 选择创建规则。

在控制台中测试 AWS IoT Core。

如果当前没有设备发布包含位置信息的遥测数据，则可以使用 AWS IoT Core 控制台测试您的规则和此解决方案。控制台有一个测试客户端，您可以在其中发布一条示例消息来验证解决方案的结果。

  1. 登录AWS IoT Core控制台，网址为 https://console.aws.amazon.com/iot/。

  2. 在左侧导航窗格中，展开测试，然后选择 MQTT 测试客户端。

  3. 在发布到主题下，将主题名称设置为 iot/topic（或设置为您在 AWS IoT Core 规则中设置的主题名称，如果不同的话），然后为消息负载提供以下内容。将时间戳 1604940328 替换为最近 30 天内的有效时间戳（任何超过 30 天的时间戳都将被忽略）。

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

  4. 选择发布到主题来发送测试消息。

  5. 要验证 Amazon Location Service 是否已收到该消息，请使用以下 AWS CLI 命令。如果您在设置过程中对其进行了修改，请将跟踪器名称和设备 ID 替换为您使用的跟踪器名称和设备 ID。

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