rom AWSIoTPythonSDK.MQTTLib import AWSIoTMQTTClient
import time
import json

host =  "a2c7vpgkmq05d0-ats.iot.us-west-2.amazonaws.com"
clientId = "c-sdk-client-id"
port = "443"
rootCAPath = "MIIDQTCCAimgAwIBAgITBmyfz5m/jAo54vB4ikPmljZbyjANBgkqhkiG9w0BAQsFADA5MQswCQYDVQQGEwJVUzEPMA0GA1UEChMGQW1hem9uMRkwFwYDVQQDExBBbWF6b24gUm9vdCBDQSA$
privateKeyPath = "2a5c7ce20d-private.pem.key"
certificatePaht = "2a5c7ce20d-certificate.pem.key"
topic = "Raspberry/1"
message = "ABC WE'RE DONE WITH THIS"

#Custom MQTT message callback
def customCallback(client, userdata, message):
    print("Received a new message: ")
    print(message.payload)
    print("from topic: ")
    print(message.topic)
    print("--------------\n\n")

#initialize
myAWSIoTMQTTClient = AWSIoTMQTTClient(clientId) #clientId can be anything
myAWSIoTMQTTClient.configureEndpoint(host, port) #host is your Pi’s AWS IoT Endpoint, port is 8883
myAWSIoTMQTTClient.configureCredentials(rootCAPath, privateKeyPath, certificatePath)

#AWSIoTMQTTClient connection configuration
myAWSIoTMQTTClient.configureAutoReconnectBackoffTime(1, 32, 20)
myAWSIoTMQTTClient.configureOfflinePublishQueueing(-1)  # Infinite offline Publish queueing
myAWSIoTMQTTClient.configureDrainingFrequency(2)  # Draining: 2 Hz
myAWSIoTMQTTClient.configureConnectDisconnectTimeout(10)  # 10 sec
myAWSIoTMQTTClient.configureMQTTOperationTimeout(5)  # 5 sec