7import sysmon
 8import aws_shadow_updater as aws_iot
 9
10def get_aws_iot_certs(device_id):11    certs_dir = os.getenv('CERTS_DIR')
12    root_ca_cert = os.path.join(certs_dir, "AmazonRootCA1.pem") # Adjust per your Root CA settings
13    device_cert = os.path.join(certs_dir, "{}-certificate.pem.crt".format(device_id))

13# }
14
15# Custom Shadow callback
16def shadow_update_callback(payload, responseStatus, token):17    if responseStatus == "timeout":
18        print("Update request " + token + " time out!")
19    if responseStatus == "accepted":

22    if responseStatus == "rejected":
23        print("Update request " + token + " rejected!")
24
25def shadow_delete_callback(payload, responseStatus, token):26    if responseStatus == "timeout":
27        print("Delete request " + token + " time out!")
28    if responseStatus == "accepted":

32    if responseStatus == "rejected":
33        print("Delete request " + token + " rejected!")
34
35def init_device_shadow_handler(args):36    host = args.get("host")
37    rootCAPath = args.get("rootCAPath")
38    certificatePath = args.get("certificatePath")

86
87    return deviceShadowHandler
88
89def update_device_shadow(handler, payload):90    json_payload = json.dumps({
91        "state": {
92            "reported": payload