CONEXIOBlackBearでAWS IoT Greengrass V2を使ってみる(2)　Lambda関数コンポーネントの作成、デプロイ、動作確認

2021-11-05 07:45Hテックブログ

CONEXIOBlackBear やってみたシリーズ

▼前回の記事はこちら
「CONEXIOBlackBearでAWS IoT Greengrass V2を使ってみる(1)」

目次[非表示]

・はじめに
・実施環境
・1. Lambda関数コンポーネントを作成

・1.1 Lambda関数を作成
・1.2 Lambda関数コンポーネントを作成

・2. デプロイする

・2.1 AWS IoT Device SDK v2 for Pythonのインストール
・2.2 デプロイの編集

・3. 動作確認する
・まとめ

はじめに

こんにちは。コネクシオIoTブログ技術記事担当のHです。

前回、AWS IoT Greengrass Coreソフトウェア V2のセットアップができました。今回は、プログラムをLambda関数コンポーネントとして作成、デバイスへデプロイし、動作確認までの手順を整理したいと思います。

実施環境

前回に準拠します。

1. Lambda関数コンポーネントを作成

1.1 Lambda関数を作成

まず、デバイス上で実行したいプログラムを作成していきます。内容は、

5秒ごとにIoT Coreに向けて "hello,world" とメッセージをパブリッシュする

簡単なサンプルです。

LambdaのコンソールでLambda関数を作成する手順は、通常のLambda関数と同様なので詳細は省きますが、設定は以下通りです。ランタイムはPythonです。

ソースコードは、以下のリンクを参考にしました。

https://docs.aws.amazon.com/greengrass/v2/developerguide/ipc-iot-core-mqtt.html

import json
import logging
import sys
from threading import Timer

import awsiot.greengrasscoreipc
import awsiot.greengrasscoreipc.client as client
from awsiot.greengrasscoreipc.model import (
    QOS,
    PublishToIoTCoreRequest
)

logger = logging.getLogger(__name__)
logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)

TIMEOUT = 10

topic = "hello/world"
message = {"message": "Hello, World"}
qos = QOS.AT_LEAST_ONCE

ipc_client = awsiot.greengrasscoreipc.connect()


def greengrass_hello_world_run():
    try:
        request = PublishToIoTCoreRequest()
        request.topic_name = topic
        request.payload = bytes(json.dumps(message), "utf-8")
        request.qos = qos
        operation = ipc_client.new_publish_to_iot_core()
        operation.activate(request)
        future = operation.get_response()
        future.result(TIMEOUT)
    except Exception as e:
        logger.error("Failed to publish message: " + repr(e))

    Timer(5, greengrass_hello_world_run).start()


greengrass_hello_world_run()


def lambda_handler(event, context):
    return

ソースコードができたら、デプロイしてバージョンを作成しておきます。後述のLambda関数コンポーネントの作成のときにバージョン名で参照する必要があるからです。

1.2 Lambda関数コンポーネントを作成

次に、AWS IoT Greengrassのコンソール上で、コンポーネントを作成していきます。

以下のように、先ほど作成したLambda関数およびバージョンを指定してインポートします。この関数は、ずっと動き続ける必要があるため、関数の設定で固定済みの項目はTrueとしています。

2. デプロイする

2.1 AWS IoT Device SDK v2 for Pythonのインストール

今回のサンプルプログラムは、Pythonランタイムで動作し、AWS IoT Device SDKを使用してIoT Coreへパブリッシュするため、CONEXIOBlackBear上へAWS IoT Device SDK v2 for Pythonをインストールする必要があります。

https://github.com/aws/aws-iot-device-sdk-python-v2

上記リンクを参考に以下のコマンドをCONEXIOBlackBear上で実行してインストールします。

apt-get update
apt-get install python3-dev
apt-get install cmake

python3.7 -m pip install awsiotsdk

なお、本コマンドでawscrtというpipパッケージも同時にインストールされますが、.whlファイルが提供されていないためCONEXIOBlackBearでセルフビルドが走ります。そのため、20-30分程度の時間を要すことにご注意ください。(今後も使用する予定がある場合は、予め.whlファイルを作成しておくとよいと思います。)