Amazon Location Service入門ワークショップ-トラッカー

2023/02/05

トラッカーでデバイスの位置や移動履歴を追跡できます。

GetDevicePosition

デバイスの位置を取得できます。

aws location get-device-position --device-id Vehicle-1 --tracker-name WorkshopAssets

1 2	aws location get-device-position --device-id Vehicle-1 --tracker-name WorkshopAssets

ワークショップアプリで[Trackers]を押下して、マップ上をクリックすると、車アイコンのデバイスが追加されます。
これがVehicle-1なので上記のようなコマンドで位置情報が得られます。

{
    "DeviceId": "Vehicle-1",
    "Position": [
        135.50136786073773,
        34.6693451694434
    ],
    "PositionProperties": {
        "DriverId": "321",
        "VehicleSpeed": "22 km/h"
    },
    "ReceivedTime": "2023-02-04T23:45:51.418000+00:00",
    "SampleTime": "2023-02-04T23:45:51+00:00"
}

{

"DeviceId": "Vehicle-1",

"Position": [

135.50136786073773,

34.6693451694434

"PositionProperties": {

"DriverId": "321",

"VehicleSpeed": "22 km/h"

"ReceivedTime": "2023-02-04T23:45:51.418000+00:00",

"SampleTime": "2023-02-04T23:45:51+00:00"

}

GetDevicePositionHistory

ワークショップアプリでマップを数回クリックしてデバイスを複数地点に移動させて、[View History]ボタンを押下すると移動履歴が表示できます。

GetDevicePositionHistoryアクションで情報が取得できています。

aws location get-device-position-history --device-id Vehicle-1 --tracker-name WorkshopAssets

1 2	aws location get-device-position-history --device-id Vehicle-1 --tracker-name WorkshopAssets

CLIの場合、このようなコマンドです。

{
    "DevicePositions": [
        {
            "DeviceId": "Vehicle-1",
            "Position": [
                135.50240395254173,
                34.66936701898287
            ],
            "PositionProperties": {
                "DriverId": "321",
                "VehicleSpeed": "44 km/h"
            },
            "ReceivedTime": "2023-02-04T23:32:45.676000+00:00",
            "SampleTime": "2023-02-04T23:32:45+00:00"
        },
        {
            "DeviceId": "Vehicle-1",
            "Position": [
                135.50136786073773,
                34.6693451694434
            ],
            "PositionProperties": {
                "DriverId": "321",
                "VehicleSpeed": "22 km/h"
            },
            "ReceivedTime": "2023-02-04T23:45:51.418000+00:00",
            "SampleTime": "2023-02-04T23:45:51+00:00"
        },
        ~省略~
    ]
}

{

"DevicePositions": [

{

"DeviceId": "Vehicle-1",

"Position": [

135.50240395254173,

34.66936701898287

"PositionProperties": {

"DriverId": "321",

"VehicleSpeed": "44 km/h"

"ReceivedTime": "2023-02-04T23:32:45.676000+00:00",

"SampleTime": "2023-02-04T23:32:45+00:00"

{

"DeviceId": "Vehicle-1",

"Position": [

135.50136786073773,

34.6693451694434

"PositionProperties": {

"DriverId": "321",

"VehicleSpeed": "22 km/h"

"ReceivedTime": "2023-02-04T23:45:51.418000+00:00",

"SampleTime": "2023-02-04T23:45:51+00:00"

~省略~

]

}

位置情報のリストが取得できます。
この情報は30日間Amazon Location Serviceに保存されています。
30日間以上保存が必要な場合は定期的に出力してS3などに保存します。

BatchUpdateDevicePosition

デバイスを移動させます。

aws location batch-update-device-position \
--tracker-name WorkshopAssets \
--updates Accuracy={Horizontal=24},\
DeviceId=Vehicle-1,\
Position=135.527926,34.687185,\
SampleTime=$(date +%s)

aws location batch-update-device-position \

--tracker-name WorkshopAssets \

--updates Accuracy={Horizontal=24},\

DeviceId=Vehicle-1,\

Position=135.527926,34.687185,\

SampleTime=$(date +%s)

大阪城に移動させるコマンドです。
このコマンドではドライバーIDや速度といった属性をもたせることができていません。
パラメータにPositionPropertiesを追加することでもたせられます。

aws location batch-update-device-position \
--tracker-name WorkshopAssets \
--updates Accuracy={Horizontal=24},\
DeviceId=Vehicle-1,\
Position=135.492302,34.700360,\
SampleTime=$(date +%s),\
PositionProperties='{DriverId=321,VehicleSpeed="14 km/h"}'

aws location batch-update-device-position \

--tracker-name WorkshopAssets \

--updates Accuracy={Horizontal=24},\

DeviceId=Vehicle-1,\

Position=135.492302,34.700360,\

SampleTime=$(date +%s),\

PositionProperties='{DriverId=321,VehicleSpeed="14 km/h"}'

IoT CoreとMQTTを使ったトラッキング

IoT CoreルールからLambda関数を呼び出してトラッカーを更新します。

IAMロールの作成

Lambda関数用のIAMロールを作成しました。
ポリシーは、AWS管理ポリシーAWSLambdaBasicExecutionRoleと、次のインラインポリシーを追加しました。

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "geo:BatchUpdateDevicePosition",
            "Resource": "arn:aws:geo:us-east-1:123456789012:tracker/WorkshopAssets"
        }
    ]
}

{

"Version": "2012-10-17",

"Statement": [

{

"Effect": "Allow",

"Action": "geo:BatchUpdateDevicePosition",

"Resource": "arn:aws:geo:us-east-1:123456789012:tracker/WorkshopAssets"

}

]

}

Lambda関数の作成

ワークショップ手順に用意されている次のコードでPython3.9ランタイムのLambda関数を作成しました。
IoT Coreイベントから渡されるlocation情報などでトラッカーを更新するコードです。

from datetime import datetime
import json
import os
import boto3

TRACKER_NAME = "WorkshopAssets"

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

from datetime import datetime

import json

import os

import boto3

TRACKER_NAME = "WorkshopAssets"

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)

}

AWS IoT Coreルールの作成

IoT Coreにアクセスして、[メッセージのルーティング]-[ルール]でルールの作成をしました。

SQLステートメントは手順通りSELECT * FROM ‘devices/Vehicle-1’にしました。

作成したLambda関数を指定しました。

テスト

AWS Iot Coreコンソールの[MQTT テストクライアント]-[トピックに公開する]で、トピック名devices/Vehicle-1として、次を設定しました。
timestampは過去30日以内が必要なので、ターミナルでdate +%sで求めました。

{
  "payload": {
    "deviceid": "Vehicle-1",
    "timestamp": 1675584473,
    "location": { "lat": 34.652523, "long": 135.506286 },
    "accuracy": { "Horizontal": 20.5 },
    "positionProperties": { "DriverId": "321", "VehicleSpeed": "28 km/h" }
  }
}