feat(micorpython): add support for disabling SSL verification in MQTT connection

Author: zibuyu1995

mqtt-client-Micropython/v1.23_and_above/pub.py

@@ -6,8 +6,10 @@
 $ micropython pub_sub_tls.py
 """
 import time
+
 from umqtt.simple import MQTTClient
 
+
 # Define the connection information for the pub client
 server = "broker.emqx.io"
 ClientID = f'raspberry-pub-{time.time_ns()}'
@@ -16,19 +18,22 @@
 topic = "raspberry/mqtt"
 msg = b'{"msg":"hello"}'
 
+
 # Create a connection, parameters are client ID, broker address, broker port number, authentication information
 def connect():
     print('Connected to MQTT Broker "%s"' % (server))
     client = MQTTClient(ClientID, server, 1883, user, password)
     client.connect()
     return client
 
+
 def reconnect():
     # If unable to connect to the broker, print a message to notify that the connection failed and wait 5 seconds to reconnect
     print('Failed to connect to MQTT broker, Reconnecting...' % (server))
     time.sleep(5)
     client.reconnect()
 
+
 # If able to connect to the broker, call connect(), otherwise call reconnect()
 try:
     client = connect()

mqtt-client-Micropython/v1.23_and_above/pub_sub_tcp.py

@@ -8,31 +8,37 @@
 import json
 import random
 import time
-import wifi
 
 from umqtt.simple import MQTTClient
 
+import wifi
+
+
 SERVER = "broker.emqx.io"
 PORT = 1883
-CLIENT_ID = 'micropython-client-{id}'.format(id = random.getrandbits(8))
+CLIENT_ID = 'micropython-client-{id}'.format(id=random.getrandbits(8))
 USERNAME = 'emqx'
 PASSWORD = 'public'
 TOPIC = "raspberry/mqtt"
 
+
 def on_message(topic, msg):
     print("Received '{payload}' from topic '{topic}'\n".format(
-        payload = msg.decode(), topic = topic.decode()))
+        payload=msg.decode(), topic=topic.decode()))
+
 
 def connect():
     client = MQTTClient(CLIENT_ID, SERVER, PORT, USERNAME, PASSWORD)
     client.connect()
-    print('Connected to MQTT Broker "{server}"'.format(server = SERVER))
+    print('Connected to MQTT Broker "{server}"'.format(server=SERVER))
     return client
 
+
 def subscribe(client):
     client.set_callback(on_message)
     client.subscribe(TOPIC)
 
+
 def loop_publish(client):
     msg_count = 0
     while True:
@@ -41,16 +47,18 @@ def loop_publish(client):
         }
         msg = json.dumps(msg_dict)
         result = client.publish(TOPIC, msg)
-        print("Send '{msg}' to topic '{topic}'".format(msg = msg, topic = TOPIC))
+        print("Send '{msg}' to topic '{topic}'".format(msg=msg, topic=TOPIC))
         client.wait_msg()
         msg_count += 1
         time.sleep(1)
 
+
 def run():
     wifi.connect()
     client = connect()
     subscribe(client)
     loop_publish(client)
 
+
 if __name__ == "__main__":
     run()

mqtt-client-Micropython/v1.23_and_above/pub_sub_tls.py

@@ -17,41 +17,47 @@
 import random
 import ssl
 import time
-import wifi
 
 from umqtt.simple import MQTTClient
 
+import wifi
+
 
 SERVER = "broker.emqx.io"
 PORT = 8883
-CLIENT_ID = 'micropython-client-{id}'.format(id = random.getrandbits(8))
+CLIENT_ID = 'micropython-client-{id}'.format(id=random.getrandbits(8))
 USERNAME = 'emqx'
 PASSWORD = 'public'
 TOPIC = "raspberry/mqtt"
-CA_CERTS_PATH = "./certs/broker.emqx.io-ca.der" # use the public broker CA
+CA_CERTS_PATH = "./certs/broker.emqx.io-ca.der"  # use the public broker CA
+
 
 def on_message(topic, msg):
     print("Received '{payload}' from topic '{topic}'\n".format(
-        payload = msg.decode(), topic = topic.decode()))
+        payload=msg.decode(), topic=topic.decode()))
+
 
 def create_ssl_context():
     # Create an SSL context
     ssl_context = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT)
     ssl_context.load_verify_locations(CA_CERTS_PATH)
     return ssl_context
 
+
 def connect():
     ssl_context = create_ssl_context()
 
-    client = MQTTClient(CLIENT_ID, SERVER, PORT, USERNAME, PASSWORD, ssl = ssl_context)
+    client = MQTTClient(CLIENT_ID, SERVER, PORT, USERNAME, PASSWORD, ssl=ssl_context)
     client.connect()
-    print('Connected to MQTT Broker "{server}"'.format(server = SERVER))
+    print('Connected to MQTT Broker "{server}"'.format(server=SERVER))
     return client
 
+
 def subscribe(client):
     client.set_callback(on_message)
     client.subscribe(TOPIC)
 
+
 def loop_publish(client):
     msg_count = 0
     while True:
@@ -60,16 +66,18 @@ def loop_publish(client):
         }
         msg = json.dumps(msg_dict)
         result = client.publish(TOPIC, msg)
-        print("Send '{msg}' to topic '{topic}'".format(msg = msg, topic = TOPIC))
+        print("Send '{msg}' to topic '{topic}'".format(msg=msg, topic=TOPIC))
         client.wait_msg()
         msg_count += 1
         time.sleep(1)
 
+
 def run():
     wifi.connect()
     client = connect()
     subscribe(client)
     loop_publish(client)
 
+
 if __name__ == "__main__":
     run()

mqtt-client-Micropython/v1.23_and_above/pub_sub_tls_no_secure.py

@@ -0,0 +1,79 @@
+"""
+This script code is only available for MicroPython version 1.23 and above.
+
+Install umqtt.simple library:
+$ micropython -m mip install umqtt.simple
+
+This script demonstrates how to publish and subscribe to an MQTT broker using no secure connection, don't use this in production.
+
+To run this script:
+$ micropython pub_sub_tls.py
+"""
+
+import json
+import random
+import ssl
+import time
+
+from umqtt.simple import MQTTClient
+
+import wifi
+
+
+SERVER = "broker.emqx.io"
+PORT = 8883
+CLIENT_ID = 'micropython-client-{id}'.format(id=random.getrandbits(8))
+USERNAME = 'emqx'
+PASSWORD = 'public'
+TOPIC = "raspberry/mqtt"
+
+
+def on_message(topic, msg):
+    print("Received '{payload}' from topic '{topic}'\n".format(
+        payload=msg.decode(), topic=topic.decode()))
+
+
+def create_ssl_context():
+    # Create an SSL context
+    ssl_context = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT)
+    ssl_context.verify_mode = ssl.CERT_NONE
+    return ssl_context
+
+
+def connect():
+    ssl_context = create_ssl_context()
+
+    client = MQTTClient(CLIENT_ID, SERVER, PORT, USERNAME, PASSWORD, ssl=ssl_context)
+    client.connect()
+    print('Connected to MQTT Broker "{server}"'.format(server=SERVER))
+    return client
+
+
+def subscribe(client):
+    client.set_callback(on_message)
+    client.subscribe(TOPIC)
+
+
+def loop_publish(client):
+    msg_count = 0
+    while True:
+        msg_dict = {
+            'msg': msg_count
+        }
+        msg = json.dumps(msg_dict)
+        result = client.publish(TOPIC, msg)
+        print("Send '{msg}' to topic '{topic}'".format(msg=msg, topic=TOPIC))
+        client.wait_msg()
+        msg_count += 1
+        time.sleep(1)
+
+
+def run():
+    wifi.connect()
+    client = connect()
+    subscribe(client)
+    loop_publish(client)
+
+
+if __name__ == "__main__":
+    run()

mqtt-client-Micropython/v1.23_and_above/sub.py

@@ -6,8 +6,10 @@
 $ micropython sub.py
 """
 import time
+
 from umqtt.simple import MQTTClient
 
+
 # Define the connection information for the sub client
 SERVER = "broker.emqx.io"
 ClientID = f'raspberry-sub-{time.time_ns()}'
@@ -16,10 +18,12 @@
 topic = "raspberry/mqtt"
 msg = b'{"msg":"hello"}'
 
+
 def sub(topic, msg):
     # Print the topic and message in the callback function
     print('received message %s on topic %s' % (msg, topic))
 
+
 def main(server=SERVER):
     # Create a connection, parameters are client ID, broker address, broker port number, authentication information
     client = MQTTClient(ClientID, server, 1883, user, password)
@@ -35,5 +39,6 @@ def main(server=SERVER):
             client.check_msg()
             time.sleep(1)
 
+
 if __name__ == "__main__":
     main()