チュートリアル: MQTT で AWS Lambda を使用する

Amazon Location Service コンソール (https://console.aws.amazon.com/location/) を開きます。

左のナビゲーションペインから、[トラッカー] を選択します。

トラッカーを作成を選択します。

次のボックスに入力します。

トラッカーを作成を選択します。

AWS Lambda コンソールを https://console.aws.amazon.com/lambda/ で開きます。

ナビゲーションペインで、[関数] を選択します。

関数を作成を選択し、最初から作成するが選択されていることを確認します。

次のボックスに入力します。

機能の作成を選択します。

[コード] タブを選択してエディタを開きます。

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

[デプロイ] を選択して、関数を更新します。

設定タブを選択します。

権限セクションで、ハイパーリンク付きのロール名を選択し、Lambda 関数に Amazon Location Service アクセス権限を付与します。

ロールの概要ページからアクセス権限の追加を選択し、ドロップダウンリストからインラインポリシーの作成を選択します。

[JSON] タブを選択して、次の JSON ポリシードキュメントを入力します。これにより、Lambda 関数は、すべてのリージョンのすべてのトラッカーリソースによって管理されているデバイスの位置の更新ができます。

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

ポリシーの確認を選択します。

ポリシー名を入力します。例えば、AmazonLocationTrackerWriteOnly などです。

ポリシーを作成を選択します。

AWS IoT Core コンソール (https://console.aws.amazon.com/iot/) にサインインします。

左のナビゲーションペインで、[ACT] を拡張し、[ルール] の順に選択します。

ルールを作成を選択して新しいルールウィザードを起動します。

ルールの名前と説明を入力します。

ルールクエリステートメントでは、FROM 属性を更新して、少なくとも 1 つのデバイスが位置を含むテレメトリを公開しているトピックを参照する。ソリューションをテストする場合、変更は必要ありません。

SELECT * FROM 'iot/topic'

1 つ以上のアクションを設定するで、アクションの追加を選択します。

[Lambda 関数にメッセージを送信する] を選択します。

アクションの設定を選択します。

リストから Lambda 関数を探して選択します。

Add actionを選択します。

ルールの作成を選択します。

AWS IoT Core コンソール (https://console.aws.amazon.com/iot/) にサインインします。

左側のナビゲーションメニューの [テスト] で、[MQTT テストクライアント] を選択します。

トピックに公開で、トピック名を 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" }
  }
}

テストメッセージを送信するには、[発行] を選択します。

メッセージが Amazon Location Service によって受信されたことを確認するには、次の AWS CLI コマンドを使用します。セットアップ中に変更した場合は、トラッカー名とデバイス ID を使用していたものに置き換えてください。

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