Code: Select all
CERT_FILE = "/flash/cert.der"
KEY_FILE = "/flash/private.der"
MQTT_CLIENT_ID = "nodething"
MQTT_PORT = 8883
MQTT_TOPIC = "sdk/test/Python"
MQTT_HOST = "**********.iot.******.amazonaws.com "
WIFI_SSID = "*****"
WIFI_PW = "*******"
mqtt_client = None
def pub_msg(msg):
global mqtt_client
try:
mqtt_client.publish(MQTT_TOPIC, msg)
print("Sent: " + msg)
except Exception as e:
print("Exception publish: " + str(e))
raise
def connect_mqtt():
global mqtt_client
try:
with open(KEY_FILE, "r") as f:
key = f.read()
print("Got Key")
with open(CERT_FILE, "r") as f:
cert = f.read()
print("Got Cert")
mqtt_client = MQTTClient(client_id=MQTT_CLIENT_ID, server=MQTT_HOST, port=MQTT_PORT, keepalive=5000, ssl=True, ssl_params={"cert":cert, "key":key, "server_side":False})
mqtt_client.connect()
print('MQTT Connected')
except Exception as e:
print('Cannot connect MQTT: ' + str(e))
raise
"""Connecting WIFI
connected: ('192.168.0.2', '255.255.255.0', '192.168.0.1', '103.199.160.80')
Connecting MQTT
Got Key
Got Cert
Cannot connect MQTT: -2
-2"""
How to solve this error and make the mqtt connection successful...