Building an MQTT Python Broker with Mbed Client¶

This tutorial will guide you through creating an MQTT Python Broker with Mbed Client using the Mbed Connect Cloud board. We first will cover creating the embedded client for the board.

To learn about the specifics of MQTT and how it works, check out this slideshow.

Prerequisites¶

• An Mbed account - sign up here
• Install the Mbed serial driver (for Windows PCs)
• Python 2.7 - download here
• Pip - installation instructions here

Required Hardware¶

• Mbed Connect Cloud board
• An active WiFi network

Setup¶

1. Connect the board to your computer via the micro USB port.
2. The board mounts as a mass-storage device (like a USB drive). Verify that you can see it (the drive name will be DAPLINK).
3. Add the u-blox EVK-ODIN-W2 board to your online Mbed Compiler here

Making the Mbed application¶

Import the example program. DO NOT CHECK the checkbox next to "Update all libraries to the latest revision".

Printing to the screen¶

Open main.cpp

Instantiate a C12832 variable to write to the LCD screen on the board. Under 'GLOBAL VARIABLES HERE' add the following code:

C12832  lcd(PE_14, PE_12, PD_12, PD_11, PE_9);

Create a function to print to the LCD screen. Under 'FUNCTION DEFINITIONS HERE' add the following code:

void lcd_print(const char* message) {
    lcd.cls();
    lcd.locate(0, 3);
    lcd.printf(message);
}

Setting up WiFi¶

We will add some code to initialize the Mbed Connect Cloud board's WiFi module and connect to your local WPA/WPA2 WiFi network.

Open mbed_app.json

We need to tell Mbed the name of our WiFi network's SSID and password.

Under wifi-ssid change the "value" from SSID to your WiFi's name (for example: "\"iotlab\"") and do not remove the quotes.

Under wifi-password change the "value" from PASSWORD to your WiFi's password (for example: "\"abcd1234\"") and do not remove the quotes.

Open main.cpp

The Mbed Connect Cloud board uses the u-blox EVK-ODIN-W2 WiFi module. So to initialize our WiFi connection we need to instantiate a OdinWifiInterface variable. Under 'GLOBAL VARIABLES HERE' add the following code:

OdinWiFiInterface wifi;

Add some code to tell the WiFi module to connect to your wifi network. We will also print to the LCD the status of the WiFi connection. Under 'MAIN CODE HERE' add the following code:

lcd_print("Connecting...");
int ret = wifi.connect(MBED_CONF_APP_WIFI_SSID, MBED_CONF_APP_WIFI_PASSWORD, NSAPI_SECURITY_WPA_WPA2);
if (ret != 0) {
    lcd_print("Connection error.");
    return -1;
}
lcd_print("Successfully connected!");

The MBED_CONF_APP_WIFI_SSID and MBED_CONF_APP_WIFI_PASSWORD are variables defined by the mbed_app.json file we edited previously. NSAPI_SECURITY_WPA_WPA2 tells Mbed OS that our WiFi network has WPA or WPA2 security (so it requires an SSID and password).

Connecting to the MQTT broker¶

Now that we have set up the board's WiFi connection, we need to tell the board to connect to the MQTT network. Under 'MAIN CODE HERE' add the following code:

NetworkInterface* net = &wifi;
MQTTNetwork mqttNetwork(net);
MQTT::Client<MQTTNetwork, Countdown> client(mqttNetwork);

const char* host = "IP_ADDRESS_HERE";
const char* topic = "Mbed";
lcd_print("Connecting to MQTT network...");
int rc = mqttNetwork.connect(host, 1883);
if (rc != 0) {
    char rc[140];
    sprintf(rc, "rc from TCP connect is %d", rc);
    lcd_print(rc);
}
lcd_print("Successfully connected!");

Next, we need to initialize our client's connect data and the received messages from the broker when we subscribe to the "Mbed" topic. Under 'MAIN CODE HERE' add the following code:

MQTTPacket_connectData data = MQTTPacket_connectData_initializer;
data.MQTTVersion = 3;
data.clientID.cstring = "connect-cloud-board";
if ((rc = client.connect(data)) != 0) {
    char rcd[300];
    sprintf(rcd, "rc from MQTT connect is %d\r\n", rc);
    lcd_print(rcd);
}
if ((rc = client.subscribe(topic, MQTT::QOS0, messageArrived)) != 0) {
    char rcd[300];
    sprintf(rcd, "rc from MQTT subscribe is %d\r\n", rc);
    lcd_print(rcd);
}

We also want to keep track of the number of messages we publish from the board. Under 'GLOBAL VARIABLES HERE' add the following code:

volatile int message_num = 0;

Adding a button interrupt¶

We will add some code to instantiate an InterruptIn variable so the SW1 button on the board can interrupt the main program. We will also create a bool variable that changes state (true/false) whenever the button is clicked. This button will allow us to tell the board when to publish a message to the Python MQTT broker and subsequently broadcasted to the client (which we will create later).

Open main.cpp

To keep track of the number of times the button has been pressed, we need an integer variable and a boolean variable. Under 'GLOBAL VARIABLES HERE' add the following code:

InterruptIn button(PF_2);
volatile bool broadcast = false;

Add a function that will be called when the button interrupts the main function. When the button is clicked, the broadcast variable will be set to true. Under 'FUNCTION DEFINITIONS HERE' add the following code:

void broadcast_message() {
    broadcast = true;
}

Attach the button_clicked function to the falling edge of the InterruptIn button. We will also add a while loop so the program will run indefinitely. Under 'MAIN CODE HERE' add the following code:

button.fall(&broadcast_message);
while (true) {
    // WHILE LOOP CODE HERE

}

Inside the while loop is where we will handle constructing the messages to be published to the MQTT broker. Whenever the button is pressed, the button interrupts the main function and calls broadcast_message(). Within broadcast_message() the boolean variable broadcast is set to true. So within the while loop, we need to have an if statement that runs whenever the broadcast variable is true. Under 'WHILE LOOP CODE HERE' add the following code:

if (broadcast) {
    message_num++;
    MQTT::Message message;
    char buff[100];
    sprintf(buff, "QoS0 Hello, Python! #%d", message_num);
    message.qos = MQTT::QOS0;
    message.retained = false;
    message.dup = false;
    message.payload = (void*) buff;
    message.payloadlen = strlen(buff) + 1;
    rc = client.publish(topic, message);
    client.yield(100);
    broadcast = false;
}

The code above constructs a message to be published to the broker, which then broadcasts the message to each of this topic's subscribers. Next we will create the Python MQTT broker which processes these messages and a Python MQTT client that subscribes to the board's messages.

Creating the MQTT Python Server¶

This code is based off of the HelloMQTT example here. First, you need to have the "paho-mqtt" Python package installed on your computer in order to run an MQTT broker/client locally on your machine. To learn more about "paho-mqtt" visit their website here.

Install the "paho-mqtt" Python package by running the following command in your terminal: pip install paho-mqtt

Download broker.py from the example repository's "broker" folder here to your computer.

Open a terminal window on your computer and navigate to the directory you downloaded broker.py into. Run the following command to start the script: python broker.py

You should receive output similar to the following:

$ python broker.py
Your IP address is: 192.168.0.77
Connecting to /Mbed/#
Traceback (most recent call last):
  File "broker.py", line 35, in <module>
    mqttc.connect(host, port=1883, keepalive=60)
  File "/usr/local/lib/python2.7/site-packages/paho/mqtt/client.py", line 767, in connect
    self.connect_async(host, port, keepalive, bind_address)
  File "/usr/local/lib/python2.7/site-packages/paho/mqtt/client.py", line 822, in connect_async
    raise ValueError('Invalid host.')
ValueError: Invalid host.

We receive this error because we did not yet specify our MQTT broker's local host. Copy the IP address printed after "Your IP address is:" in your command-line window. Open broker.py in a text editor on your computer. Paste your IP address over "IP_ADDRESS_HERE" after host = on line 10 (under # Settings for connection).

Now run the python broker.py command again in your command-line window. You should now be able to successfully start your MQTT broker/client and your output should be similar to the following:

$ python broker.py
Your IP address is: 192.168.0.77
Connecting to 192.168.0.77/Mbed/#
Connected rc: 0
Subscribed OK

Do not exit/close this command-line window or your local MQTT broker/client will be terminated (and your broadcasts will not go through).

Open main.cpp

Now that we have our computer's local IP address, we need to change the host IP address we connect to in main.cpp. Find the const char* host variable in the main function. Copy your IP address from your command-line window and paste it over "IP_ADDRESS_HERE" and keep the quotes. For example, my host variable looks like the following:

const char* host = "192.168.0.77";

Compile and run¶

1. Select the u-blox EVK-ODIN-W2 target board in the upper right hand corner
2. Press "Compile"
3. Wait for a binary to be downloaded
4. Drag the binary to the DAPLINK disk
5. Press the board's reset button
6. The WiFi connection status should now be displaying on the board, once you see "Successfully connected!" you can press the button (SW1) and see the received message and payload from our local MQTT broker/client displayed on the LCD screen.

Publishing changes¶

1. Right click the project folder
2. Select "Publish"
3. Write a commit message in the "Revision Commit" menu
4. Press OK
5. Select "Fork..." in the "Publish Repository" menu
6. Write a Description
7. Press OK

You have now successfully created an MQTT Python Broker/Client with Mbed Client!