Greengrass コネクタの開始方法 (CLI)

まず、シークレットを作成します。

aws secretsmanager create-secret --name greengrass-TwilioAuthToken --secret-string twilio-auth-token

出力からシークレットの ARN をコピーします。この情報は、シークレットリソースの作成時と Twilio 通知コネクタの設定時に使用します。

初期バージョンを含むリソース定義を作成します。

出力からリソース定義の LatestVersionArn をコピーします。この値を使用して、Core にデプロイするグループバージョンに、リソース定義バージョンを追加します。

コネクタの定義と初期バージョンを作成します。

出力からコネクタ定義の LatestVersionArn をコピーします。この値を使用して、Core にデプロイするグループバージョンに、コネクタ定義バージョンを追加します。

AWS IoT Greengrass Core SDK のダウンロードページから、AWS IoT Greengrass Core SDK for Python をお使いのコンピュータにダウンロードします。

ダウンロードしたパッケージを解凍し、SDK を取得します。SDK は greengrasssdk フォルダです。

以下の Python コード関数を temp_monitor.py というローカルファイルに保存します。

import greengrasssdk
import json
import random

client = greengrasssdk.client('iot-data')

# publish to the Twilio Notifications connector through the twilio/txt topic
def function_handler(event, context):
    temp = event['temperature']
    
    # check the temperature
    # if greater than 30C, send a notification
    if temp > 30:
        data = build_request(event)
        client.publish(topic='twilio/txt', payload=json.dumps(data))
        print('published:' + str(data))
        
    print('temperature:' + str(temp))
    return

# build the Twilio request from the input data
def build_request(event):
    to_name = event['to_name']
    to_number = event['to_number']
    temp_report = 'temperature:' + str(event['temperature'])

    return {
        "request": {
            "recipient": {
                "name": to_name,
                "phone_number": to_number,
                "message": temp_report
            }
        },
        "id": "request_" + str(random.randint(1,101))
    }

以下の項目を temp_monitor_python.zip という名前のファイルに圧縮します。ZIP ファイルを作成するときは、コードおよび依存関係のみを含め、フォルダは含めません。

これが Lambda 関数デプロイパッケージです。

関数の作成時に ARN を渡せるように、IAM ロールを作成します。

出力から Arn をコピーします。

AWS Lambda API を使用して TempMonitor 関数を作成します。以下のコマンドでは、zip ファイルが現在のディレクトリにあるとします。

aws lambda create-function \
--function-name TempMonitor \
--zip-file fileb://temp_monitor_python.zip \
--role role-arn \
--handler temp_monitor.function_handler \
--runtime python3.7

関数のバージョンを発行します。

aws lambda publish-version --function-name TempMonitor --description 'First version'

発行されるバージョンのエイリアスを作成します。

Greengrass グループは、Lambda 関数をエイリアス別 (推奨) またはバージョン別に参照できます。エイリアスを使用すると、関数コードを更新する時にサブスクリプションテーブルやグループ定義を変更する必要がないため、コード更新を簡単に管理できます。その代わりに、新しい関数バージョンにエイリアスを指定するだけで済みます。

aws lambda create-alias --function-name TempMonitor --name GG_TempMonitor --function-version 1

出力から AliasArn をコピーします。この値は、AWS IoT Greengrass の関数を設定するとき、およびサブスクリプションを作成するときに使用します。

初期バージョンを含む関数定義を作成します。

出力から LatestVersionArn をコピーします。この値を使用して、Core にデプロイするグループバージョンに、関数定義バージョンを追加します。

出力から Id をコピーします。この値は、後でその関数を更新するときに使用します。

サブスクリプションを含む初期バージョンでサブスクリプション定義を作成します。

出力から LatestVersionArn をコピーします。この値を使用して、Core にデプロイするグループバージョンに、サブスクリプション定義バージョンを追加します。

グループ ID と最新のグループバージョンを取得します。

1. ターゲットの Greengrass グループとグループのバージョンの ID を取得します。この手順では、これが最新のグループおよびグループのバージョンであると仮定します。次のクエリは、最後に作成されたグループを返します。

   aws greengrass list-groups --query "reverse(sort_by(Groups, &CreationTimestamp))[0]"

   または、名前でクエリを実行することもできます。グループ名は一意である必要はないため、複数のグループが返されることがあります。

   aws greengrass list-groups --query "Groups[?Name=='MyGroup']"

   注記

   これらの値は AWS IoT コンソールにもあります。グループ ID は、グループの [Settings (設定)] ページに表示されます。グループバージョン ID は、グループの [Deployments] (デプロイ) タブに表示されます。

2. 出力からターゲットグループの Id をコピーします。この情報は、Core 定義バージョンの取得時とグループのデプロイ時に使用します。

3. 出力から LatestVersion をコピーします。これは、グループに追加された最後のバージョンの ID です。この情報は、Core 定義バージョンの取得時に使用します。

Core 定義バージョンの ARN を取得します。

1. グループバージョンを取得します。このステップでは、最新のグループバージョンに Core 定義バージョンが含まれているものとします。

   • group-id を、グループのコピー済み Id に置き換えます。

   • group-version-id を、グループのコピー済み LatestVersion に置き換えます。

   aws greengrass get-group-version \
   --group-id group-id \
   --group-version-id group-version-id

2. 出力から CoreDefinitionVersionArn をコピーします。

グループバージョンを作成します。

aws greengrass create-group-version \
--group-id group-id \
--core-definition-version-arn core-definition-version-arn \
--resource-definition-version-arn resource-definition-version-arn \
--connector-definition-version-arn connector-definition-version-arn \
--function-definition-version-arn function-definition-version-arn \
--subscription-definition-version-arn subscription-definition-version-arn

出力から Version の値をコピーします。これはグループバージョンの ID です。この値を使用して、グループバージョンをデプロイします。

Core デバイスのターミナルで、AWS IoT Greengrass デーモンが実行されていることを確認します。

1. デーモンが実行中であるかどうかを確認するには

   ps aux | grep -E 'greengrass.*daemon'

   出力に root の /greengrass/ggc/packages/1.11.6/bin/daemon エントリが含まれる場合、デーモンは実行されています。

2. 次のようにしてデーモンを開始します。

   cd /greengrass/ggc/core/
   sudo ./greengrassd start

デプロイメントを作成する。

aws greengrass create-deployment \
--deployment-type NewDeployment \
--group-id group-id \
--group-version-id group-version-id

出力から DeploymentId をコピーします。

デプロイのステータスを取得します。

aws greengrass get-deployment-status \
--group-id group-id \
--deployment-id deployment-id

ステータスが Success の場合、デプロイは成功しています。トラブルシューティングヘルプについては、AWS IoT Greengrass のトラブルシューティング を参照してください。

AWS IoT コンソールのホームページで、[Test] (テスト) を選択します。

[Subscribe to topic] (トピックへのサブスクライブ) で、以下の値を使用し、[Subscribe] (サブスクリプション) を選択します。Twilio 通知コネクタはこのトピックにステータス情報を発行します。

[Publish to topic] (トピックに発行) で、以下の値を使用し、[Publish] (発行) を選択して関数を呼び出します。

{
   "to_name": "recipient-name",
   "to_number": "recipient-phone-number",
   "temperature": 31
}

正しく実行できていれば、受信者にテキストメッセージが届き、コンソールの出力データに success のステータスが表示されます。

ここでは、入力メッセージの temperature を 29 に変更して発行します。これは 30 未満であるため、TempMonitor 関数は Twilio メッセージをトリガーしません。