in LocationIoT.py [0:0]
def publishlocation():
host = 'a1jizs7tiywipi-ats.iot.us-east-1.amazonaws.com'
rootCAPath='AmazonRootCA1.crt'
certificatePath='myfleetiot.cert.pem'
privateKeyPath='myfleetiot.private.key'
clientId='locationtrack'
port = 8883
topic='iot/fleet/location'
host = input("Enter IoT endpoint e.g. xxxxxxxx.iot.us-east-1.amazonaws.com. Get this from IoT console, choose settings on left-hand panel:")
myMQTTClient = None
myMQTTClient = AWSIoTMQTTClient(clientId)
myMQTTClient.configureEndpoint(host, port)
myMQTTClient.configureCredentials(rootCAPath, privateKeyPath, certificatePath)
myMQTTClient.configureAutoReconnectBackoffTime(1, 32, 20)
myMQTTClient.configureOfflinePublishQueueing(-1) # Infinite offline Publish queueing
myMQTTClient.configureDrainingFrequency(2)
myMQTTClient.configureConnectDisconnectTimeout(10)
myMQTTClient.configureMQTTOperationTimeout(15)
# Connect and subscribe to AWS IoT
message = {}
myMQTTClient.connect()
loopCount = 1
while loopCount <= 11:
message = getlocation(loopCount)
messageJson = json.dumps(message)
print(messageJson)
myMQTTClient.publish(topic, messageJson, 1)
print('Published topic %s: %s\n' % (topic, messageJson))
loopCount += 1
time.sleep(2)