Raspberry PI Pico W brings connectivity to your projects. Mosquitto is one of the most reliable, simple and fast communications for IoT projects. For this reason, MQTT and Raspberry PI Pico W will surely give you great flexibility for your Smart Things projects
This tutorial will show you how to use Mosquitto (MQTT) with Raspebbry PI Pico W with MicroPython.
What is Mosquitto
MQTT is a messaging protocol for the Internet of Things (IoT). It is designed to use minimal network bandwidth and a reduced code for transporting messages from/to IoT devices.
MQTT is used in a wide variety of industries, such as automotive, manufacturing, telecommunications, oil and gas, etc.
The Mosquitto architecture includes 3 main actors.
- The MQTT Publisher Client publishes data, usually collected from sensors. It is the device(s) where row data are generated. You can think of these devices as social media stars who continuously publish their data stream to whoever wants to read.
- The MQTT Subscriber Client is where data are visualized. In the new generation wording, they are something like social followers who “subscribe” to a specific topic in order to get notified of every new data on that topic
- The MQTT Broker is an intermediate service that makes it possible for subscribers to get data and for publishers to send their ones. The IoT publisher devices are usually not so much “smart”: they usually have a very simple logic in order to make their hardware as low cost as possible. So, collecting and presenting data is demanded to the MQTT Broker, which also manages the subscriber’s access and permissions (where required).
The following picture gives a visual example of MQTT Publish / Subscribe Architecture:
Mosquitto (MQTT) uses standard ports: TCP/IP port 1883 is reserved with IANA for use with MQTT. TCP/IP port 8883 is also registered, for using MQTT over SSL.
In order to test MQTT, we’ll need to create an MQTT Broker and a subscriber, besides the Raspberry PI Pico W (that will work as MQTT publisher client). In this tutorial, I will use a Raspberry PI computer board (Raspberry PI 3 Model B) and I will show also how to arrange a very basic configuration for the broker and the subscriber.
What We Need
As usual, I suggest adding from now to your favourite e-commerce shopping cart all needed hardware, so that at the end you will be able to evaluate overall costs and decide if continue with the project or remove them from the shopping cart. So, hardware will be only:
- A common computer (maybe with Windows, Linux or Mac). It can also be a Raspberry PI Computer board
- Raspberry PI Pico W microcontroller (with a common micro USB cable)
Check hardware prices with the following links:
For this tutorial, the Raspberry PI computer board (RPI 3 model B) will work both as MQTT broker and subscriber, while the Raspberry PI Pico W will work as MQTT publisher. Of course, the MQTT broker/subscriber can be any device capable of this.
Prepare MQTT broker/subscriber with Raspberry PI Computer
Please start installing the OS on your Raspberry PI computer board.
I’ll use Raspberry PI OS Lite, in order to have a fast and headless OS.
If not already done, please make your OS up to date. From terminal, use the following command:
sudo apt update -y && sudo apt upgrade -y
You can now install Mosquitto with the command:
sudo apt install mosquitto mosquitto-clients -y
Check that Mosquitto is correctly running:
pi@raspberrypi:~ $ sudo systemctl status mosquitto.service ● mosquitto.service - Mosquitto MQTT Broker Loaded: loaded (/lib/systemd/system/mosquitto.service; enabled; vendor preset: enabled) Active: active (running) since Wed 2022-07-27 17:17:06 CEST; 1 day 4h ago Docs: man:mosquitto.conf(5) man:mosquitto(8) Process: 474 ExecStartPre=/bin/mkdir -m 740 -p /var/log/mosquitto (code=exited, status=0/SUCCESS) Process: 483 ExecStartPre=/bin/chown mosquitto /var/log/mosquitto (code=exited, status=0/SUCCESS) Process: 486 ExecStartPre=/bin/mkdir -m 740 -p /run/mosquitto (code=exited, status=0/SUCCESS) Process: 487 ExecStartPre=/bin/chown mosquitto /run/mosquitto (code=exited, status=0/SUCCESS) Main PID: 489 (mosquitto) Tasks: 1 (limit: 780) CPU: 1min 15.183s CGroup: /system.slice/mosquitto.service └─489 /usr/sbin/mosquitto -c /etc/mosquitto/mosquitto.conf Jul 27 17:17:06 raspberrypi systemd: Starting Mosquitto MQTT Broker... Jul 27 17:17:06 raspberrypi systemd: Started Mosquitto MQTT Broker.
In order to get safer communication, we can set the user and password to use to add a bit of security. For this example, I will set a user “pico” with the password “picopassword”, but change it with your favourite one. Issue the following command (change “pico” with your user name):
sudo mosquitto_passwd -c /etc/mosquitto/credentials pico
The process will automatically request a password (“picopassword” for my example, but use your one). The “/etc/mosquitto/credentials” file will be generated, including you password encrypted.
At this moment, a password has been generated, but it is still not used from our MQTT broker. You need to set it in your mosquitto configuration. Open it to edit:
sudo nano /etc/mosquitto/mosquitto.conf
An append the following lines at the end:
allow_anonymous false password_file /etc/mosquitto/credentials listener 1883
Finally, please restart Mosquitto service:
sudo systemctl restart mosquitto.service
Prepare MQTT Publisher with Raspberry PI Pico W
From MQTT broker side, the job has been done. We can now move to Raspberry PI Pico W.
Start preparing your Raspberry PI Pico W firmware. Please note that the official MicroPython firmware could still not support the RPI Pico W connection. For this reason, please refer to my Getting Started with WiFi on Raspberry PI Pico W and MicroPython tutorial.
Once the WiFi connection works, you must save in your Raspberry PI Pico W storage the 2 following external modules:
The first one has already been used in the previously cited Getting Started with WiFi on Raspberry PI Pico W and MicroPython tutorial and manages the WiFi connection.
The umqttsimple.py has already been used with the WIZnet ethernet HAT and works also with the RPI Pico W, making simpler the MQTT communication process. My Smart Farm with Raspberry PI, RPI Pico and WIZnet Ethernet Hat tutorial is another use case for this module.
Finally, please get and save in your Raspberry PI Pico W also the following MicroPython script:
Here is the code that you can edit to adapt it to your projects. The following will give you a brief code explanation.
Firstly, we import the required modules:
import netman import time from umqttsimple import MQTTClient from machine import Pin
We set the WiFi country, SSID and password (change them with your home ones) and we start the WiFi connection:
country = 'IT' ssid = 'yourWiFiSSID' password = 'yourWiFiPassword' wifi_connection = netman.connectWiFi(ssid,password,country)
The following variables will set the connection with your MQTT broker. In my case, my Raspberry PI 3 Model B has 192.168.1.91 as IP address, change it with your MQTT server one. The client_id can be set at your choice, some MQTT services (like ThingsBoard) allow you to use it to better define your IoT sensors. The user_t and password_t must be the same as that set in the previous chapter when securing the MQTT broker communication in Raspberry PI 3 Model B. The topic_pub is the topic on which we’ll publish our MQTT messages:
mqtt_server = '192.168.1.91' client_id = 'PicoW' user_t = 'pico' password_t = 'picopassword' topic_pub = 'hello'
The following part just manages the MQTT connection with the broker:
last_message = 0 message_interval = 5 counter = 0 def mqtt_connect(): client = MQTTClient(client_id, mqtt_server, user=user_t, password=password_t, keepalive=60) client.connect() print('Connected to %s MQTT Broker'%(mqtt_server)) return client def reconnect(): print('Failed to connected to MQTT Broker. Reconnecting...') time.sleep(5) machine.reset()
Finally, the main loop.
The first part manages the MQTT connection with the broker:
while True: try: client = mqtt_connect() except OSError as e: reconnect()
Once the MQTT connection is established, publishing an MQTT message on a specific topic is really simple with the use of client.publish() statement. The remaining code just manages exceptions and disconnects the client (for sure, I can make the while loops better…):
while True: try: client.publish(topic_pub, msg='Hello from Pico!') print('published') time.sleep(3) except: reconnect() pass client.disconnect()
Run the MQTT test
The MQTT broker is always running on Raspberry PI 3 Model B as it is a daemonized service. We have only to start the Mosquitto subscriber, in order to check if messages are delivered, with the following terminal command from our RPI computer board (please use your Mosquitto user/password instead of the example ones):
pi@raspberrypi:~ $ mosquitto_sub -d -t hello -u pico -P picopassword
Now you can also run (on Raspberry PI Pico W side) the mttq_picow.py code from Thonny. It will start trying to establish the WiFi connection, the MQTT connection and then sending the moquitto messages (in case of errors, please double check user/password and IP):
>>> %Run -c $EDITOR_CONTENT waiting for connection... waiting for connection... waiting for connection... waiting for connection... connected ip = 192.168.1.42 Connected to 192.168.1.91 MQTT Broker published published published
At the same time, on the Raspberry PI computer board, you will have something like the following, which states that the messages are correctly delivered:
pi@raspberrypi:~ $ mosquitto_sub -d -t hello -u pico -P picopassword Client (null) sending CONNECT Client (null) received CONNACK (0) Client (null) sending SUBSCRIBE (Mid: 1, Topic: hello, QoS: 0, Options: 0x00) Client (null) received SUBACK Subscribed (mid: 1): 0 Client (null) received PUBLISH (d0, q0, r0, m0, 'hello', ... (16 bytes)) Hello from Pico! Client (null) received PUBLISH (d0, q0, r0, m0, 'hello', ... (16 bytes)) Hello from Pico! Client (null) received PUBLISH (d0, q0, r0, m0, 'hello', ... (16 bytes)) Hello from Pico!
Interested in more cool Raspberry PI Pico guides? Take a look at my Raspberry PI Pico tutorials for useful and funny projects!
We are sorry that this post was not useful for you!
Let us improve this post!
Tell us how we can improve this post?