MQTT connection

mqtt.py

from umqtt.simple import MQTTClient
import json

client_id = 'esp8266'
mqtt_topic = 'tempReading/bedroom'
mqtt_port = 8883
mqtt_host = 'a2XXXXXXXX.iot.us-west-2.amazonaws.com'

private_key = open("/private_key.der").read()
certificate = open("/cert.der").read()

mqtt_client = MQTTClient(
    client_id=client_id,
    server=mqtt_host,
    port=mqtt_port,
    keepalive=10000,
    ssl=True,
    ssl_params={
        'cert': certificate,
        'key': private_key}
)

mqtt_client.connect()

mqtt_client.publish(mqtt_topic, json.dumps({'temp': 62.5}))