2024.8.27追記
2024年8月現在、MQTTclientの認証方法が更新されいる。最新のMQTTClientの動きに合わせてコードや記事の一部を更新した。

はじめに

2023年5月現在、日本でも購入できるようになり、在庫も潤沢になり比較的手軽に入手しやすくなったRaspberry Pi Pico W。Wi-Fi機能付きであるため、Pico Wから得られたセンサデータをAWSへ送信して、なんちゃってホームIoT構築することができる！と夢が広がるが、Pico W + AWS Iot Core環境をセットアップを構築するにあたって、まとまった日本語記事が見つからなかった。データを送って保存するまでの手順を簡単に紹介する。

この記事で紹介すること

Raspberry Pi Pico W本体でアナログ電圧値を取得する方法
MicroPythonを使ってMQTTでIoTCoreへのデータ送信する方法
IoT Coreに送信されたデータをDynamoDBへデータを保存する方法

この記事で紹介しないこと

MicroPythonの詳細な説明
AWS IoT Coreの詳細な説明
MQTTの詳細な説明

モチベーション

IoT Coreを一度使ってみたい！・・・でも、Raspberry Piが入手できず出来なかった。
Pico Wは良いチャンス。
洗面所など、ビルトインのため自動消灯式の電球へ変えられない照明がある。
照度センサーを付けて、付け忘れ時にLINEなどへ通知させたい。

Step1 Raspberry Pi Pico W本体でアナログ電圧値を取得する

準備するもの

Raspberry Pi Pico W …今回は3台用意
フォトレジスタ
https://www.amazon.co.jp/gp/product/B082X6XGMQ
金属皮膜抵抗 5.6KΩ
はんだ工具セット一式

1.1 回路セットアップ

フォトレジスタ（周辺の照度変化に応じて抵抗値が変わる）と金属皮膜抵抗で、VCC電圧を分圧して、フォトレジストの抵抗値変化をアナログ電圧値変化として読み取る。GL5528は、暗所で抵抗値が大、明るいと抵抗値が小になる。この回路のAD値としては、暗所で電圧小、明るいと電圧大が観測される。抵抗の5.6KΩという値は、実際の部屋で抵抗値を変えながら値をモニターし、我が家に合う最適なものを選んだ。

回路

引用元：https://www.raspberrypi.com/documentation/microcontrollers/raspberry-pi-pico.html
実際の回路

他の2台も同じ回路とした。

1.2 MicroPython開発環境の準備

先人がすでにLチカまでの環境構築をされている。
https://qiita.com/relu/items/945bcb45120c30837745

手順としては、.uf2形式のファームウェアをPico Wへ焼き、MicroPython環境であるThonnyとCOM接続する。Thonnyでは、Pico Wのファイルシステムにアクセスできるので、あとは任意のソフトを書いて焼けば、Pico WでPythonが走る・・・という流れ。MicroPythonは、ESP32でもよく利用されている様子。筆者は今回初めて利用した。

システムルートには2つのpythonファイルが置ける。

boot.py 最初にこちらが実行される。
main.py boot.pyの後に実行される。

参考：https://micropython-docs-ja.readthedocs.io/ja/latest/pyboard/tutorial/script.html

boot.pyナシ、main.pyだけでも動作することは確認した。
ADC2ポートに接続されているため、achine.ADC(2)のようにsensorを定義する。うまくいけばThonnyの標準出力にセンサー電圧値が出力される。

main.py

import machine
import time

def read_sensor():
    sensor = machine.ADC(2)
    factor = 3.3 / 65535
    sensor_volt = sensor.read_u16() * factor
    return sensor_volt

while True:
    print(read_sensor())
    time.sleep_ms(1000)

Step2 MicroPythonからMQTTでIoT Coreへのデータ送信する

受信するAWS側の準備と、データを送信するPico W側の準備に分けて解説する。

2.1 AWS側の準備

IoT Coreとエッジ端末でできることは色々あるが、やりたいことが増えれば増えるほど、SDKを必要とする。現在、IoTCoreのSDKは、Pythonの実行環境があれば動作するようで、Raspbery Pi4*/Zeroには対応しているようだが、残念ながらPico Wには非対応である。今回は単に、エッジデータをAWSに対して送信する環境を構築する。

参考：IoT Coreを使ってエッジ端末でできること

MQTTでエッジ端末とデータを送受信する
　- AWSのIoT Coreエンドポイントに対してセンサーデータを送信する
　- MQTTメッセージをエッジ側で受信して、あらかじめ決まったアクション（あらかじめ予約されたアプリケーション）を実行する
IoT GreengrassでLambdaライクにエッジへアプリケーションデプロイ、実行する（OTA）

2.1.1 IoT Coreコンソール画面からモノを登録する

必要に応じてモノのタイプなども登録する。IoTのThingsのモノである。

2.1.2 証明書を生成させるオプションを選択する

2.1.3 ポリシーをアタッチする。

必要に応じたポリシーを事前に生成しておき、証明書にアタッチする。

IoT Coreの資格情報の管理は、IAMではなくて、IoT Core内の独自のポリシーによって資格管理がなされる。例えば、IoT Coreエンドポイントにエッジ端末から接続するiot:Connect、MQTTトピックを発行するためのiot:Publishと言った要領。

証明書に結び付く形でポリシーを選び、資格管理をすることができる。

モノ
├─証明書
│  ├─ポリシーA
│  │   ├─iot:Connect
│  │   └─iot:Publish
│  └─ポリシーB
│      └─iot:Publish
├─証明書
│  └─ポリシーB
│      └─iot:Publish

2.1.4 証明書のダウンロードと変換

デバイスの一意性を証明するデバイス証明書と、通信用のprivate keyをダウンロードしておく。デバイス証明書、プライベートキー、ルートCA証明書の3点が必要である。

後述するMQTTライブラリumqtt.simpleでは、.DER形式の証明書が必要なため、.PEM形式のファイルをOpenSSLにて変換する。今回はWindows用のOpenSLL 1.1.1を利用した。

openssl

# デバイス証明書
>openssl x509 -in 87b0f66d**"省略"**84a3543-certificate.pem.crt -inform PEM -out certificate.der -outform DER

# private key
>openssl rsa -in 87b0f66d**"省略"**84a3543-private.pem.key -inform PEM -out private.der -outform DER

# routeCA key
>openssl x509 -in AmazonRootCA1.pem -out routeca.der -inform PEM -outform DER

2.2 Pico Wの準備

MQTTの設計と、Iot Coreへデータを送信する

2.2.1　MQTT準備

IoT Coreのエンドポイントに対してMQTTでデータを送信する。
MQTTでは、3点事前に準備が必要である。

エンドポイントの準備
MQTTトピックの設計
メッセージの準備

1つ目は前の章ですでに実施済み。2つ目トピックは、ベストプライスがAWSに示されているので参考にする。3つ目は、今回は照度情報だけ送りたいのでそれに応じたメッセージとする。

参考：MQTTトピック設計のガイドライン
https://d1.awsstatic.com/whitepapers/ja_JP/Designing_MQTT_Topics_for_AWS_IoT_Core.pdf?did=wp_card&trk=wp_card

MQTTトピック

# AWS例
dt/<application>/<context>/<thing-name>/<dt-type>  

♯ 今回
dt/homeCtrl/tokyo/pico_***

メッセージ（アナログ値をそのまま送る）

{"illuminance": 1.23456}

2.2.2　main.py準備

MicroPythonでは、普通のPythonと同様に書ける。
AWS Iot Coreをデータに送るPythonスクリプトにおいて気を付けたポイントは以下。

MQTTのライブラリumqtt.simpleを活用する
https://mpython.readthedocs.io/en/master/library/mPython/umqtt.simple.html
.DERファイルはbinary形式で読み込む
Pico Wが複数端末あるため、デバイス名はpicoW_{MACアドレス} 形式で管理する
MQTTでは、クライアントIDが重複すると接続が解除される。一意なもの（デイバス名）とする。
MQTTメッセージは、dict型データをjson.dumpsし、binary形式とする。
Wi-Fi接続にはリトライ処理を入れておく

フォルダ構成、コード

root
├─certs
│  ├─routeca.der
│  ├─private.der
│  └─certificate.der
├─lib/umqtt
│  └─simple.py
└─main.py

コードはこちらにあります。