Single board computer projects

Pitoucon: Raspi touch panel with Kivy and MQTT

last updated: 11/03/18


My Mechanical Ventilation Heat Recovery (MVHR) system from Paul was updated with a Teensy and a Raspberry Pi (see Piventi and is now sending MQTT messages:

piventi mqtt message

To see this messages and manipulate the air flow I needed a touch panel. I bought a 3.5" PiTFT from Adafruit and use it with a Raspberry Pi 3. The Pi is connected over Wifi an is also getting data from a weather station.

To draw the graphical screen and use the touch function of the screen I use Kivy on the console (without X).


For MQTT I use the Paho library:

    sudo pip3 install paho-mqtt

Install Kivy

After some trial and error this link helped to install kivy on a raspi3 (raspbian nov/17):

    sudo apt-get update
    sudo apt-get install libsdl2-dev libsdl2-image-dev libsdl2-mixer-dev libsdl2-ttf-dev \
       pkg-config libgl1-mesa-dev libgles2-mesa-dev \
       python-setuptools libgstreamer1.0-dev git-core \
       gstreamer1.0-plugins-{bad,base,good,ugly} \
       gstreamer1.0-{omx,alsa} python-dev libmtdev-dev \
       xclip xsel
       sudo pip3 install -U Cython==0.27.3
       sudo pip3 install git+

Tested with a minimal python program:

    from import App

    class pitouconApp(App):

    if __name__ == '__main__':

With the following pitoucon.kv program (same folder):

        text: 'Hallo'


To understand the Kivy logic was not so easy, but finally the python software worked. A switch on gpio 3 is used to toggle the backlight. The switch is polled every half of a second in a callback function that is initiated by an event (see Another event every 10 minutes sends an alive message.

I wanted to use the Screenmanager with more screens, but finally one screen sufficed. The pitoucon.kv-file is in the download section. Here is the python code:

    #!/usr/bin/env python3
    # -*- coding: utf-8 -*-

    from import App
    from kivy.clock import Clock
    from kivy.uix.screenmanager import ScreenManager, Screen
    from kivy.uix.boxlayout import BoxLayout
    from import ObjectProperty, StringProperty
    import paho.mqtt.client as mqtt
    import RPi.GPIO as GPIO
    import json
    import time, datetime

    class ScreenManagement(ScreenManager):

    class Main(Screen):
        inoutflow = StringProperty()
        freshexh = StringProperty()
        tacho = StringProperty()
        co2 = StringProperty()
        def setVent(self,percent):
            print('button state is: ', percent)
            message = "{\"flow-rate\":\"" + str(percent) + "\"}"

    class Setup(Screen):

    class pitouconApp(App):
        def build(self):
            global SM #ScreenManager
            global s
            SM = self.root
            s = SM.get_screen('main')

        def on_start(self):
            global mqttc
            global switch_pin
            switch_pin = 3
            global switch_old
            switch_old = 1
            GPIO.setup(switch_pin, GPIO.IN)
            clientID   = "pitoucon"
            brokerIP   = ""
            brokerPort = 1883
            topic      = "mytopic"
            # Callback if CONNACK response from the server.
            def onConnect(client, userdata, flags, rc):
                print("Connected with result code " + str(rc))
                mqttc.subscribe(topic, 0)  # Subscribe (topic name, QoS)
            # Callback that is executed when we disconnect from the broker.
            def onDisconnect(client, userdata, message):
                print("Disconnected from the broker.")
            # Callback that is executed when subscribing to a topic
            def onSubscribe(client, userdata, mid, granted_qos):
                print('Subscribed on topic.')
            # Callback that is executed when unsubscribing to a topic
            def onUnsubscribe(client, userdata, mid, granted_qos):
                print('Unsubscribed on topic.')
            # Callback that is executed when a message is received.
            def onMessage(client, userdata, message):
                if (io[2:6] != "flow") and (io[2:7] != "alive"):
                        inflowTxt = ioj["inflow"]
                        outflowTxt = ioj["outflow"]
                        inOutTxt = "Temp   Hum      \n" + inflowTxt + "  IN \n\n" + outflowTxt + "  OUT"
                        s.inoutflow = inOutTxt
                        freshTxt = ioj["fresh"]
                        exhaustTxt = ioj["exhaust"]
                        freExTxt = "        Temp   Hum\nFRESH   " + freshTxt + "\n\nEXHAUST " + exhaustTxt
                        s.freshexh = freExTxt
                        tinTxt = ioj["tacho-in"]
                        if tinTxt[2]  == "%":
                            tinTxt = tinTxt[0:2]
                            tinTxt = tinTxt[0:3]
                        toutTxt = ioj["tacho-out"]
                        if toutTxt[2]  == "%":
                            toutTxt = toutTxt[0:2]
                            toutTxt = toutTxt[0:3]
                        tachoTxt = "Tacho I/O : " + tinTxt + "% " + toutTxt + "%"
                        s.tacho = tachoTxt
                        co2Txt = ioj["co2"]
                        co2Txt = "CO: " + co2Txt
                        s.co2 = co2Txt
                       print("json error")
            # Callback every 500ms to poll the backlight switch and act accordingly
            def poll_switch(dt):
                global switch_old
                switch = GPIO.input(switch_pin)
                if (switch != switch_old):
                    if switch:
                        with open("/sys/class/backlight/soc:backlight/brightness", "w") as f:
                        with open("/sys/class/backlight/soc:backlight/brightness", "w") as f:
                switch_old = switch
            def send_alive(dt):
                samessage ='%Y/%m/%d %H:%M:%S')
                samessage = "{\"alive\":\"" + samessage + "\"}"

            mqttc = mqtt.Client(client_id=clientID, clean_session=True)
            mqttc.on_connect      = onConnect   # define the callback functions
            mqttc.on_disconnect   = onDisconnect
            mqttc.on_subscribe    = onSubscribe
            mqttc.on_unsubscribe  = onUnsubscribe
            mqttc.on_message      = onMessage
            mqttc.connect(brokerIP, brokerPort, keepalive=60, bind_address="")
            mqttc.loop_start() # start loop to process callbacks! (new thread!)
            event = Clock.schedule_interval(poll_switch, 1 / 2.) # poll switch 500ms
            event = Clock.schedule_interval(send_alive, 600) # send alive 10 min.
    if __name__ == "__main__":


For the housing I searched for PiTFT on thingiverse and found the OctoPrint housing. But there exist 2 versions of the 3.5" PiTFT with different dimensions. I got Version with the PID 2097 and not the newer PID 2441. So a second search gave me the Touch Pi housing from adafruit. I changed the bottom stl, so a raspi3 could be mounted and added blocks to fix it on the wall. Fortunately there is enough space and the possibility to add a switch for the backlight was given.

pitoucon<em>housing</em>bottom pitoucon<em>housing</em>top pitoucon<em>housing</em>ext pitoucon<em>housing</em>freecad