MicroPython Forum (Archive)

Code: Select all

from umqtt.simple import MQTTClient

def connect_mqtt():
  global client_id, mqtt_server
  
  with open('client.key.der', 'rb') as f:
    key_data = f.read()

  with open('client.crt.der', 'rb') as f:
    cert_data = f.read()

  client = MQTTClient(client_id, mqtt_server, keepalive=120, ssl=True, ssl_params={'key':key_data, 'cert':cert_data})
  client.connect()
  print('Connected to %s MQTT broker' % (mqtt_server))
  return client

Code: Select all

persistence true
persistence_location /mosquitto/data/
listener 8883 0.0.0.0
cafile /mosquitto/config/ca.crt
certfile /mosquitto/config/server.crt
keyfile /mosquitto/config/server.key
require_certificate false
log_dest file /mosquitto/log/mosquitto.log

Code: Select all

    config['ssl'] = True
    with open("/root/client.key.der", 'rb') as f:
        key = f.read()
    with open("/root/client.crt.der", 'rb') as f:
        cert = f.read()
    ssl_params = dict()
    ssl_params["cert"] = cert
    ssl_params["key"] = key
    config['ssl_params'] = ssl_params
    socket = ussl.wrap_socket(self._sock, key=self._ssl_params["key"], cert=self._ssl_params["cert"])

Code: Select all

       from umqtt.robust import MQTTClient
       
       ssl_enabled=True
       username = "name"
       password = "password"
        with open("/root/client.key.der", 'rb') as f:
            key = f.read()
        with open("/root/client.crt.der", 'rb') as f:
            cert = f.read()
        ssl_params = dict()
        ssl_params["cert"] = cert
        ssl_params["key"] = key
        mqtt_topic = "hello/topic"
        # Set up client
        mqtt_client = MQTTClient(client_id="helloclient", server="127.0.0.1", port=8883,
                   user=username, password=password, ssl=ssl_enabled, ssl_params=ssl_params)
        mqtt_client.connect()
        mqtt_client.publish(mqtt_topic, "Hiiiiii", False, qos=1)