Nachdem der MQTT -Client auf dem Raspberry PI funktionsbereit ist, sollen durch die Ansprache der GPIO-Pins Messages ausgel\u00f6st werden.<\/p>\n
F\u00fcr die Aktivierung der GPIO-Pins wurden von uns 2 Wege als praktikabel identifiziert:<\/p>\n
cd \/sys\/class\/gpio
\necho 4 > export
\necho out > gpio4\/direction
\n#aktivieren:
\necho 1 > gpio4\/value
\n#deaktivieren:
\necho 0 > gpio4\/value<\/p><\/blockquote>\n<\/li>\n<\/ul>\nDa wir bereits Python in Buildroot aktiviert hatten und dar\u00fcber in Verbindung mit dem Package python-rpi-gpio alle gew\u00fcnschten Funktionen (zb. ein Listener f\u00fcr die Aktivierung eines bestimmt GPIO-Pins) relativ einfach realisierbar sind, fiel die Entscheidung f\u00fcr eine Verwendung der Python Variante.<\/p>\n
Dabei wurde das gew\u00fcnschte Package in ein Python Script importiert und die Pins initialisiert.<\/p>\n
import RPi.GPIO as GPIO<\/p>\n
#Modus setzen (BOARD\/BCM), regelt Ansprache (Nr.) der Pins<\/p>\n
GPIO.setmode(GPIO.BCM)<\/p>\n
#Speziellen Pin als Eingang oder Ausgang initialisieren
\nPIN_B = 23
\nGPIO.setup(PIN_B, GPIO.OUT)
\nPIN_A = 24
\nGPIO.setup(PIN_A, GPIO.IN, pull_up_down=GPIO.PUD_DOWN)<\/p><\/blockquote>\nDabei aktiviert pull_up_down=GPIO.PUD_DOWN den internen Wiederstand des Pi f\u00fcr diesen Port (hier gpio24) (k\u00f6nnte auch extern gel\u00f6st werden).<\/p>\n
Mit der Initialisierung der Pins k\u00f6nnen diese anschlie\u00dfend verwendet werden. Folgend die Aktivierung des Pins gpio23 f\u00fcr 5 Sekunden:<\/p>\n
GPIO.output(PIN_B, GPIO.HIGH)
\ntime.sleep(5)
\nGPIO.output(PIN_B, GPIO.LOW)<\/p><\/blockquote>\nF\u00fcr den Input Pin gpio24 soll zudem eine st\u00e4ndige Pr\u00fcfung auf Aktivit\u00e4t erfolgen. Dieser Pin wird bei einem Klingeln an der T\u00fcr aktiviert. Zur Realisierung wurde ein Listener geschrieben und dem Pin zugeordnet.<\/p>\n
#listener fuer pin initialisieren:
\nbounce_time = 10000
\nGPIO.add_event_detect(PIN_A, GPIO.FALLING, callback=inputLow, bouncetime=bounce_time)<\/p><\/blockquote>\nDie bouncetime regelt dabei die Zeit, die zwischen einer erneuten Aktivierung des Pins liegt. callback gibt die Funktion an, die bei Aktivierung des Pins aufgerufen wird.<\/p>\n
Zus\u00e4tzlich zu den Pins wurde das Script um die MQTT Publish Funktionalit\u00e4t erweitert.<\/p>\n
client.publish(„b8:27:eb:37:eb:80“, „isRinged“)<\/p><\/blockquote>\n
Damit sieht das aktuelle Script, mit vollem Funktionsumfang, momentan wie folgt aus:<\/p>\n
#!\/usr\/bin\/python
\n# -*- coding: utf-8 -*-<\/p>\nimport RPi.GPIO as GPIO
\nimport paho.mqtt.client as mqtt
\nimport atexit
\nimport time<\/p>\ndef exit_handler():
\nclient.disconnect()
\nGPIO.cleanup()
\nexit()<\/p>\ndef on_disconnect(client, userdata, rc):
\nprint(„Disconnect with result code “ + str(rc))<\/p>\n<\/p>\n
# Read MAC from file
\nmyMAC = open(‚\/sys\/class\/net\/wlan0\/address‘).read()
\nprint(myMAC)
\n# The callback for when the client receives a CONNACK response from the server.
\ndef on_connect(client, userdata, rc):
\nprint(„Connected with result code “ + str(rc))
\n# Subscribing in on_connect() means that if we lose the connection and reconnect then subscriptions will be renewed.
\n#client.subscribe(str(myMAC)+“\/#“)
\nclient.subscribe(„b8:27:eb:37:eb:80\/#“)<\/p>\n# The callback for when a PUBLISH message is received from the server.
\ndef on_message(client, userdata, msg):
\nprint(„Topic: „, msg.topic + „\\nMessage: “ + str(msg.payload))
\nprint(str(msg.payload))
\nif str(msg.payload)==“b’openDoor'“:
\nGPIO.output(PIN_B, GPIO.HIGH)
\nclient.publish(„b8:27:eb:37:eb:80“, „isOpen“)
\ntime.sleep(5)
\nGPIO.output(PIN_B, GPIO.LOW)<\/p>\ndef inputLow(channel):
\nif channel == PIN_A:
\nmsg_info = client.publish(„b8:27:eb:37:eb:80“, „isRinged“)
\nprint(„es klingelt“)
\n# if msg_info.is_published() == False:
\n# print(„Message is not yet published.“)
\n# This call will block until the message is published.
\n# msg_info.wait_for_publish()<\/p>\nif __name__ == „__main__“:
\n#GPIO initialisieren:
\nGPIO.setmode(GPIO.BCM)
\nPIN_B = 23
\nGPIO.setup(PIN_B, GPIO.OUT)
\nPIN_A = 24
\nGPIO.setup(PIN_A, GPIO.IN, pull_up_down=GPIO.PUD_DOWN)
\n#listener fuer pin initialisieren:
\nbounce_time = 10000
\nGPIO.add_event_detect(PIN_A, GPIO.FALLING, callback=inputLow, bouncetime=bounce_time)<\/p>\n#client = paho.Client()
\nclient = mqtt.Client(clean_session=True)
\nclient.on_connect = on_connect
\nclient.on_message = on_message
\nclient.on_disconnect = on_disconnect
\n#client.on_publish = on_publish<\/p>\natexit.register(exit_handler)<\/p>\n
print(„Now trying to connect…“)
\nclient.username_pw_set(„iot“,“iot123″)
\nclient.connect(„62.75.166.253“, 1883)
\nprint(„conn“)
\n# Blocking call that processes network traffic, dispatches callbacks and handles reconnecting.
\n# Other loop*() functions are available that give a threaded interface and a manual interface.
\nclient.loop_forever()<\/p><\/blockquote>\nSoviel zum aktuellen Stand des Projekts T\u00fcrsteuerung, weitere Updates folgen.<\/p>\n","protected":false},"excerpt":{"rendered":"
Nachdem der MQTT -Client auf dem Raspberry PI funktionsbereit ist, sollen durch die Ansprache der GPIO-Pins Messages ausgel\u00f6st werden. F\u00fcr die Aktivierung der GPIO-Pins wurden von uns 2 Wege als praktikabel identifiziert: \u00dcber ein Python Script unter Verwendung des Packages<\/p>\n","protected":false},"author":3,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":[],"categories":[5],"tags":[7,8],"_links":{"self":[{"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/posts\/442"}],"collection":[{"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/comments?post=442"}],"version-history":[{"count":1,"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/posts\/442\/revisions"}],"predecessor-version":[{"id":561,"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/posts\/442\/revisions\/561"}],"wp:attachment":[{"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/media?parent=442"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/categories?post=442"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/tags?post=442"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}