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 settings13    device_cert = os.path.join(certs_dir, "{}-certificate.pem.crt".format(device_id))
14    device_private_key = os.path.join(certs_dir, "{}-private.pem.key".format(device_id))
15    assert os.path.exists(root_ca_cert), "Root CA Certificate not found"

42    thingName = args.get("thingName")
43    clientId = args.get("clientId")
44    
45    if not clientId: # Use thingName as clientId if not provided separately46        clientId = thingName
47
48    if useWebsocket and certificatePath and privateKeyPath: