Skip to content
Snippets Groups Projects
Commit 0c3966d1 authored by yangsen2's avatar yangsen2
Browse files

f

parent 0ff08b69
No related branches found
No related tags found
No related merge requests found
import os
root_folder = "./certificates"
for i in range(5):
folder_name = f"device_{i}"
folder_path = os.path.join(root_folder, folder_name)
os.makedirs(folder_path, exist_ok=True)
\ No newline at end of file
import json
import logging
import sys
import platform
from threading import Timer
import greengrasssdk
# Logging
logger = logging.getLogger(__name__)
logging.basicConfig(stream=sys.stdout, level=logging.DEBUG)
# SDK Client
client = greengrasssdk.client("iot-data")
# Counter
max_co2_vals = [0] * 5
def lambda_handler(event, context):
global max_co2_vals
# Get your data
co2_val, time_stamp, vehicle = event['message'], event['time_stamp'], event['vehicle']
# Update max CO2 value
vehicle_index = int(vehicle)
max_co2_vals[vehicle_index] = max(co2_val, max_co2_vals[vehicle_index])
# Publish result
client.publish(
topic="iot/vehicle",
queueFullPolicy="AllOrException",
payload=json.dumps({
"co2": co2_val,
"max_co2": max_co2_vals[vehicle_index],
"time_stamp": time_stamp,
"vehicle": vehicle
}),
)
return
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment