Welcome to another tutorial of the “how to MQTT” series. In this tutorial, we will learn how to use the MQTT in python. Also, we will learn how to make MQTT dashboard in Python. That is really going to help in IoT-based projects.
The data which we will be showing on MQTT dashboard will be coming from ESP8266, DHT11 sensor which we programmed in our last tutorials.
To start this tutorial, i will recommend some pre-requisites, which i have covered in my previous tutorials. You should know what is mqtt protocol, how publish/subscribe model works, how to select topic names and how to usq MQTT protocol in ESP8266, MATLAB , Raspberry pi and how to make your own MQTT broker.
Talking about broker, i am using RYC1001 IoT cloud by REYAX technologies and they are the sponser of this tutorial.
The reason for choosing python is that python is easy to learn and use, and the community of python is very strong and there are hundreds of libraries and frameworks that you can use in python for free. Another reason is that when I made the last video MQTT in MATLAB, people complained that MATLAB is not free, so they can use python and they can do anything with data on python that they can do on MATLAB as well.
Buying guide
| Development board | Amazon (US) | Ali express |
|---|---|---|
| ESP32 |  |  |
| Raspberry pi zero | | |
Raspberry pi 4 | | |
| ESP8266 | | |
| DHT11 | | |
MQTT in Python
The first step is to install the library, which you can do that by typing the following pip command in terminal,
pip3 install paho-mqtt
the following is the code which will help you do the publish or subscribe the message,
from paho.mqtt import client as mqtt_client
import json
broker = 'iot.reyax.com'
port = 1883
topic = "api/request"
topic_sub = "api/notification/37/#"
# generate client ID with pub prefix randomly
client_id = 'your client id'
username = 'your username'
password = 'your password'
deviceId = "your deviceId"
def connect_mqtt():
def on_connect(client, userdata, flags, rc):
if rc==0:
print("Successfully connected to MQTT broker")
else:
print("Failed to connect, return code %d", rc)
client = mqtt_client.Client(client_id)
client.username_pw_set(username, password)
client.on_connect = on_connect
client.connect(broker, port)
return client
def publish(client, status):
msg = "{\"action\":\"command/insert\",\"deviceId\":\""+deviceId+"\",\"command\":{\"command\":\"LED_control\",\"parameters\":{\"led\":\""+status+"\"}}}"
result = client.publish(msg,topic)
msg_status = result[0]
if msg_status ==0:
print(f"message : {msg} sent to topic {topic}")
else:
print(f"Failed to send message to topic {topic}")
def subscribe(client: mqtt_client):
def on_message(client, userdata, msg):
#print(f"Recieved '{msg.payload.decode()}' from '{msg.topic}' topic")
y = json.loads(msg.payload.decode())
temp = y["notification"]["parameters"]["temp"]
hum = y["notification"]["parameters"]["humi"]
print("temperature: ",temp,", humidity:",hum)
client.subscribe(topic_sub)
client.on_message = on_message
def main():
client = connect_mqtt()
subscribe(client)
client.loop_forever()
if __name__ == '__main__':
main()
MQTT dashboard
from tkinter import *
from paho.mqtt import client as mqtt_client
import json
broker = 'iot.reyax.com'
port = 1883
topic = "api/request"
topic_sub = "api/notification/37/#"
# generate client ID with pub prefix randomly
client_id = 'your client id'
username = 'your username'
password = 'your password'
deviceId = "your deviceId"
def connect_mqtt():
def on_connect(client, userdata, flags, rc):
if rc==0:
print("Successfully connected to MQTT broker")
else:
print("Failed to connect, return code %d", rc)
client = mqtt_client.Client(client_id)
client.username_pw_set(username, password)
client.on_connect = on_connect
client.connect(broker, port)
return client
def publish(client,status):
# msg = f"messages: {msg_count}"
msg = "{\"action\":\"command/insert\",\"deviceId\":\""+deviceId+"\",\"command\":{\"command\":\"LED_control\",\"parameters\":{\"led\":\""+status+"\"}}}"
# msg = '{"action":"command/insert","command":{"id":432436060,"command":"LED_control","timestamp":"2021-03-24T00:19:44.418","lastUpdated":"2021-03-24T00:19:44.418","userId":37,"deviceId":"s3s9TFhT9WbDsA0CxlWeAKuZykjcmO6PoxK6","networkId":37,"deviceTypeId":5,"parameters":{"led":"on"},"lifetime":null,"status":null,"result":null},"subscriptionId":1616544981034531}'
result = client.publish(topic, msg)
# result: [0, 1]
status = result[0]
if status == 0:
print(f"Send `{msg}` to topic `{topic}`")
else:
print(f"Failed to send message to topic {topic}")
def subscribe(client: mqtt_client):
def on_message(client, userdata, msg):
#print(f"Recieved '{msg.payload.decode()}' from '{msg.topic}' topic")
y = json.loads(msg.payload.decode())
temp = str(y["notification"]["parameters"]["temp"])
hum = str(y["notification"]["parameters"]["humi"])
print("temperature: ",temp,", humidity:",hum)
temp_label.config(text=temp+" °C",
fg="black")
hum_label.config(text=hum + " %",
fg="black")
client.subscribe(topic_sub)
client.on_message = on_message
window = Tk()
window.title("MQTT Dashboard")
window.geometry('395x675')
window.resizable(False,False)
window.configure(bg="white")
canvas = Canvas(window, bg="white", width=395,height=135)
canvas.place(x=0,y=0)
img = PhotoImage(file="logo.png")
canvas.create_image(0,0,anchor=NW,image=img)
canvas2 = Canvas(window,width=100,height=100)
canvas2.place(x=50,y=165)
img2 = PhotoImage(file="temp2.png")
canvas2.create_image(0,0,anchor=NW,image=img2)
canvas3 = Canvas(window,width=100,height=100)
canvas3.place(x=50,y=295)
img3 = PhotoImage(file="hum.png")
canvas3.create_image(0,0,anchor=NW,image=img3)
is_on = False
# Create Label
my_label = Label(window,
text="OFF!",
bg="white",
fg="grey",
font=("Helvetica", 32))
my_label.place(x=180,y=430)
def switch():
global is_on
if is_on:
on_button.config(image=off)
my_label.config(text="OFF!",
fg="grey")
print("LED is off now")
publish(client,"0")
is_on=False
else:
on_button.config(image=on)
my_label.config(text="ON!",
fg="red")
print("LED is On now")
publish(client,"1")
is_on=True
# Define Our Images
on = PhotoImage(file="on1.png")
off = PhotoImage(file="off1.png")
# Create A Button
on_button = Button(window, image=off, bd=0,
command=switch)
on_button.place(x=50,y=420)
canvas4 = Canvas(window, bg="white", width = 395, height = 135)
canvas4.place(x=0,y=545)
img4 = PhotoImage(file="hv.png")
canvas4.create_image(0,0, anchor=NW, image=img4)
# Create Label
temp_label = Label(window,
text=" °C",
bg="white",
fg="black",
font=("Helvetica", 32))
temp_label.place(x=180,y=190)
# Create Label
hum_label = Label(window,
text=" %",
bg="white",
fg="black",
font=("Helvetica", 32))
hum_label.place(x=180,y=325)
client = connect_mqtt()
subscribe(client)
client.loop_start()
window.mainloop()
client.loop_stop()
I loved your first video using Raspberry pi a local server but in the video you have changed to China I am using ewelink and wanted to get away from China so I will not be following your channel thanks
I appreciate for liking my content. I used chinease cloud because they sponsored me and i believe this is necessary because i invest time in making videos, but i also suggested some free clouds aswell.
Pingback: How to make MQTT android application using MIT app inventor - High Voltages