Initial Python client examples

Author: sandeepmistry

mqtt/python/arduino.cc.crt

@@ -0,0 +1,30 @@
+-----BEGIN CERTIFICATE-----
+MIIFHzCCBAegAwIBAgIJALWCaK9i4aK5MA0GCSqGSIb3DQEBCwUAMIG0MQswCQYD
+VQQGEwJVUzEQMA4GA1UECBMHQXJpem9uYTETMBEGA1UEBxMKU2NvdHRzZGFsZTEa
+MBgGA1UEChMRR29EYWRkeS5jb20sIEluYy4xLTArBgNVBAsTJGh0dHA6Ly9jZXJ0
+cy5nb2RhZGR5LmNvbS9yZXBvc2l0b3J5LzEzMDEGA1UEAxMqR28gRGFkZHkgU2Vj
+dXJlIENlcnRpZmljYXRlIEF1dGhvcml0eSAtIEcyMB4XDTE0MTIyNDExMjMzOFoX
+DTE2MTIyNDExMjMzOFowOjEhMB8GA1UECxMYRG9tYWluIENvbnRyb2wgVmFsaWRh
+dGVkMRUwEwYDVQQDDAwqLmFyZHVpbm8uY2MwggEiMA0GCSqGSIb3DQEBAQUAA4IB
+DwAwggEKAoIBAQCkvRVavhHiexjqfWbFm+2oGJdYQ/RJidJmL5x5p6xE7KWm5/Q7
+thuBEjAKgtweyO+sFuLHqqvP0y8OTDbuc1QeMhWFdrwfZwCeZvmLCf0+PbchJNPx
+P4Qp7N28vGs7iIZxgmDzrYXTyYl9n+QrGk8tN27ioAQpx5IrqSCWg9T5RFEkCy4I
+krlwuvZmRLLwDA+p7LADzII7XpzlFRyP9pfCTCziIxKMHEoX9IyzEJBQHAvwdHuN
+H+/CHDBcjhdapPMgBtgsbNaSg9bqxDlsxfoYak5BonlbbqCdB3KZAl57Gmu0NgMW
+MDwzVKBBSrIXWCtx0iKzWNIcRAA/veJPY+2rAgMBAAGjggGrMIIBpzAMBgNVHRMB
+Af8EAjAAMB0GA1UdJQQWMBQGCCsGAQUFBwMBBggrBgEFBQcDAjAOBgNVHQ8BAf8E
+BAMCBaAwNgYDVR0fBC8wLTAroCmgJ4YlaHR0cDovL2NybC5nb2RhZGR5LmNvbS9n
+ZGlnMnMxLTg3LmNybDBTBgNVHSAETDBKMEgGC2CGSAGG/W0BBxcBMDkwNwYIKwYB
+BQUHAgEWK2h0dHA6Ly9jZXJ0aWZpY2F0ZXMuZ29kYWRkeS5jb20vcmVwb3NpdG9y
+eS8wdgYIKwYBBQUHAQEEajBoMCQGCCsGAQUFBzABhhhodHRwOi8vb2NzcC5nb2Rh
+ZGR5LmNvbS8wQAYIKwYBBQUHMAKGNGh0dHA6Ly9jZXJ0aWZpY2F0ZXMuZ29kYWRk
+eS5jb20vcmVwb3NpdG9yeS9nZGlnMi5jcnQwHwYDVR0jBBgwFoAUQMK9J47MNIMw
+ojPX+2yz8LQsgM4wIwYDVR0RBBwwGoIMKi5hcmR1aW5vLmNjggphcmR1aW5vLmNj
+MB0GA1UdDgQWBBTYoo2mh/KLTL/sO5p4iAYjZQUaaDANBgkqhkiG9w0BAQsFAAOC
+AQEAlWOMRZEp67/qAg9bIjZDuMTZeunnynR3b4eaCAYpcFVbvZSDD1wL1mYtEJVl
+A3V2qHO2Ypeo5spV9ecF5lgyJ+QExR/JQ3rAlkGB89izGVXGQLtXp4fTaNeXbo5s
+NRU3J3//Tx3jx359LvRvIFwNFk5myZrhMyg1R4uYmucFMjLJdWrNWmAv4GKhIo2A
+P4Gl/Rai/2qder6zzWhfMrV2sUzLR8/zyUpyRcP3gYVB3WEdJKQldW3nh0iDEedr
+hH1Aol7Zz+zlAv3kQXUuT1e8zMJL4SPOvRF4EwuZT1fHPzQoAkm9rU4wyGap743Q
+7+HBiUsnbZ+YWleCzdoZ7cbl+g==
+-----END CERTIFICATE-----

mqtt/python/publisher.py

@@ -0,0 +1,57 @@
+import sys
+import paho.mqtt.client as mqtt # https://eclipse.org/paho/clients/python/
+
+server     = "mqtt.arduino.cc"
+port       = 8883
+
+# use the values shown after logging into https://cloud.arduino.cc
+username   = "username"
+password   = "password"
+base_topic = "/" + username;
+topic      = base_topic + "/001"
+
+# default message value
+message = "0"
+
+if len(sys.argv) > 1:
+	# use command line argument as message
+	message = sys.argv[1]
+
+# The callback for when the client is connected to the broker
+def on_connect(client, userdata, flags, rc):
+    print("Connected with result: " + mqtt.connack_string(rc))
+
+    # publish message to the topic
+    client.publish(topic, message)
+
+# The callback for when the client is disconnected from the broker
+def on_disconnect(client, userdata, rc):
+    if rc != 0:
+        print("Unexpected disconnection")
+
+# The callback for when the client has published a message
+def on_publish(client, userdata, mid):
+	print("Message published: " + message)
+
+	# message published, disconnect
+	client.disconnect()
+
+# create a new MQTT client
+client = mqtt.Client()
+
+# configure CA cert for SSL connection
+client.tls_set("arduino.cc.crt")
+
+# set username and password
+client.username_pw_set(username, password)
+
+# assign callbacks
+client.on_connect    = on_connect
+client.on_disconnect = on_disconnect
+client.on_publish    = on_publish
+
+# start connection
+client.connect(server, port)
+
+# let the client loop (this is a blocking call), will unblock when the client disconnects
+client.loop_forever()

mqtt/python/subscriber.py

@@ -0,0 +1,52 @@
+import paho.mqtt.client as mqtt # https://eclipse.org/paho/clients/python/
+
+server     = "mqtt.arduino.cc"
+port       = 8883
+
+# use the values shown after logging into https://cloud.arduino.cc
+username   = "username"
+password   = "password"
+base_topic = "/" + username;
+topic      = base_topic + "/001"
+
+
+# The callback for when the client is connected to the broker
+def on_connect(client, userdata, flags, rc):
+    print("Connected with result: " + mqtt.connack_string(rc))
+
+    # subscribe to the topic
+    client.subscribe(topic)
+
+# The callback for when the client is disconnected from the broker
+def on_disconnect(client, userdata, rc):
+    if rc != 0:
+        print("Unexpected disconnection")
+
+# The callback for when the client is subscribed to a topic
+def on_subscribe(client, userdata, mid, granted_qos):
+	print("Subscribed to topic: " + topic)
+
+# The callback for when a message for a subscribed topic is received from the broker
+def on_message(client, userdata, msg):
+    print("Received message: " + msg.topic + " " + str(msg.payload))
+
+# create a new MQTT client
+client = mqtt.Client()
+
+# configure CA cert for SSL connection
+client.tls_set("arduino.cc.crt")
+
+# set username and password
+client.username_pw_set(username, password)
+
+# assign callbacks
+client.on_connect    = on_connect
+client.on_disconnect = on_disconnect
+client.on_subscribe  = on_subscribe
+client.on_message    = on_message
+
+# start connection
+client.connect(server, port)
+
+# let the client loop forever (this is a blocking call)
+client.loop_forever()