aws_publish_raspberry_script.py

# Import SDK packages
import json

from AWSIoTPythonSDK.MQTTLib import AWSIoTMQTTClient

import log_util

topic_readings = "smartgarden/readings"

host = "arkau3u0cw2s4-ats.iot.eu-west-1.amazonaws.com"
rootCAPath = "certs/rootca.pem"
certificatePath = "certs/certificate.pem.crt"
privateKeyPath = "certs/private.pem.key"

# Stablishing MQTT Connection
my_rpi = AWSIoTMQTTClient("Raspberry_Readings")
my_rpi.configureEndpoint(host, 8883)
my_rpi.configureCredentials(rootCAPath, privateKeyPath, certificatePath)

# mosquitto_sub -h arkau3u0cw2s4-ats.iot.eu-west-1.amazonaws.com -p 8883 -k 60 -i Raspberry_Core --cafile rootca.pem --cert certificate.pem.crt  --key private.pem.key -t 'smartgarden/readings' -d

my_rpi.configureOfflinePublishQueueing(-1)  # Infinite offline Publish queueing
my_rpi.configureDrainingFrequency(2)  # Draining: 2 Hz
my_rpi.configureConnectDisconnectTimeout(10)  # 10 sec
my_rpi.configureMQTTOperationTimeout(5)  # 5 sec

# Connect and subscribe to AWS IoT
my_rpi.connect()


# Publish to the Reading topic
def publish_readings(data):
    log_util.log_info(__name__, 'Publishing a message to {}: {}'.format(topic_readings, data))
    my_rpi.publish(topic_readings, json.dumps(data), 1)