IoTのためのクラウドシステム構築②

こんにちは！園部です。

「IoTのためのクラウドシステム構築」の続きです。今回はセンサデータのクラウドストレージへの保存をやっていきます！

※ 前提としてAWSアカウントは持っているものとします

S3バケットの作成

IoTCoreモノの証明書ダウンロード

※ 証明書、鍵関連のファイルはクラウドとデバイスを繋ぐ際に重要なファイルなので必ずダウンロードしてください。

IoTCoreの画面、左メニューの”メッセージのルーティング”→”ルール”を選択し、ルールを作成ボタンを選択する
ルール名を入力し次へ
SQL ステートメントを設定画面で”SQLステートメント”に「SELECT * FROM ’任意のトピック’」を記入する。今回はトピック名を’SENDtoS3’にし次へ
作成ボタンを押しルール作成完了

IoTCoreのルールを設定する

※ IAMロールはとりあえずS3フルアクセスがついていれば良いです

■ AWS接続用のClientConfigファイルを作成する

clientConfig.py

※ 今回Pythonファイルは全てDocumentsフォルダに置いています

■ 実行プログラムの作成

bme280toS3.py

#coding: utf-8
from bme280_get_data import BME280
from smbus2 import SMBus
import time
from datetime import datetime
import json
import clientConfig as client
#AWS SDKsのインポート
from AWSIoTPythonSDK.MQTTLib import AWSIoTMQTTClient
sensor = BME280()
clientName = client.clientName
endpoint_path = client.endpoint_path
amazonroot_path = client.amazonroot_path
privatekey_path = client.privatekey_path
certificate_path = client.certificate_path
#クライアント情報を設定する
def set_mqttclient(name=clientName,endpoint=endpoint_path,root=amazonroot_path,key=privatekey_path,certificate=certificate_path):
MQTTClient = AWSIoTMQTTClient(name)
MQTTClient.configureEndpoint(endpoint, 8883)
MQTTClient.configureCredentials(root, key, certificate)
MQTTClient.configureOfflinePublishQueueing(-1) # Infinite offline Pubblish queueing
MQTTClient.configureDrainingFrequency(2) # Draining: 2 Hz
MQTTClient.configureConnectDisconnectTimeout(10) # 10 sec
MQTTClient.configureMQTTOperationTimeout(5) # 5 sec
return MQTTClient
if __name__ == ‘__main__’:
myMQTTClient = set_mqttclient()
try:
myMQTTClient.connect()
messageJson = sensor.getMessage()
myMQTTClient.publish(‘your topic’, messageJson, 1)#publish関数の第一引数をマネコンで設定したトピックに置き換える
except KeyboardInterrupt:
pass

S3サービスの作成したバケットにテキストファイルが作成されていれば成功です！

ダウンロードして確認するとセンサーのデータが入っています。

以上、RaspberryPiを使ったセンサデータのS3への保存をやっていきました。
次はAWSのOpensearchを使ってセンサデータの可視化をやっていきます！

Contact