Mit etwas Verz\u00f6gerung nun ein weiteres Update zu unserem Projektstatus:<\/p>\n
Dieses Update befasst sich mit der Einrichtung eines MQTT-Clients auf dem Raspberry PI.<\/p>\n
Der MQTT Broker l\u00e4uft schon eine Weile und der Client auf dem Raspberry PI jetzt auch.<\/p>\n
Dazu haben wir auf dem PI Python mit dem Python-paho-mqtt Package aktiviert und ein Script f\u00fcr die Bearbeitung der anfallenden Messages geschrieben.<\/p>\n
Was sich einfach anh\u00f6rt hat uns eine Menge Zeit und Nerven gekostet.<\/p>\n
Zum einen hatten wir keine richtigen Vorkenntnisse auf diesem Bereich, zum anderen entstanden unerwartete Probleme. Daher ergab sich folgende Vorgehensweise: zuerst einmal haben wir uns \u00fcber die verschiedenen Realisierungsm\u00f6glichkeiten eines MQTT Clients auf dem Raspberry PI informiert. Die Realisierung mittels Python stellte sich dabei als die passende Variante f\u00fcr unsere Zwecke da.<\/p>\n
Darauf folgte das eigentliche Problem: Unter Buildroot mussten wir f\u00fcr diese Realisierung sowohl Python (Aktivierung ging problemlos) als auch das (python-)paho-mqtt Package aktivieren. Dieses gab es allerdings unter dem Men\u00fc-Punkt Networking an dem wir es vermuteten nicht. Es folgte eine l\u00e4ngere Suche bei der vor allem L\u00f6sungsm\u00f6glichkeiten f\u00fcr andere Systeme wie beispielsweise der Einrichtung unter Rasbian gefunden wurden. Nachdem die ersten \u00dcberlegungen zur Verwendung anderer Realisierungsm\u00f6glichkeiten im Raum standen, haben wir das Package dann doch gefunden. Das Paket befindet sich im Python Package unter dem zus\u00e4tzlichen Men\u00fc-Punkt External python modules<\/em>. Eine genauere Betrachtung des Pakets bzw. die richtige Verwendung von Google h\u00e4tte uns hier einige Zeit erspart.<\/p>\n Nachdem das Package in Buildroot aktiviert war konnten wir auch das erforderliche Script zur Verwendung des MQTT Clients schreiben. Trotz fehlender Python Kenntnisse war die erste funktionierende Version innerhalb weniger Minuten angefertigt.<\/p>\n Dabei stellten sich bei der Verwendung allerdings noch 2 Probleme dar:<\/p>\n client.subscribe(„Mac-Adresse<\/em>\/#“)<\/p><\/blockquote>\n Das erstgenannte Problem hing mit der loop_forever() Funktion zusammen. bei einem Abbruch des Scripts wurde kein Disconnect() aufgerufen und somit die Verbindung nicht getrennt.<\/p>\n Das zweite Problem befindet sich derzeit noch in Bearbeitung.<\/p>\n Folgend das momentan eingesetzte Script:<\/p>\n #!\/usr\/bin\/python import paho.mqtt.client as mqtt def exit_handler(): def on_disconnect(client, userdata, rc): <\/p>\n # Read MAC from file # The callback for when a PUBLISH message is received from the server. <\/p>\n if __name__ == „__main__“: atexit.register(exit_handler)<\/p>\n print(„Now trying to connect…“) die wichtigen Teile des Scriptes:<\/p>\n client.connect(„broker.mqttdashboard.com“, 1883)<\/p><\/blockquote>\n gibt den Zielserver, also den Broker an. Dieser muss noch auf unseren eigenen eingestellt werden.<\/p>\n <\/p>\n Das war auch schon alles zum momentanen Stand, im n\u00e4chsten Schritt werden die GPIO Pins des Raspberry PI aktiviert und per Script angesteuert. In Verbindung mit MQTT sollen die ausgetauschten Nachrichten dann sowohl das Klingeln der T\u00fcr als auch das \u00d6ffnen der T\u00fcr repr\u00e4sentieren bzw. steuern.<\/p>\n <\/p>\n","protected":false},"excerpt":{"rendered":" Mit etwas Verz\u00f6gerung nun ein weiteres Update zu unserem Projektstatus: Dieses Update befasst sich mit der Einrichtung eines MQTT-Clients auf dem Raspberry PI. Der MQTT Broker l\u00e4uft schon eine Weile und der Client auf dem Raspberry PI jetzt auch. Dazu<\/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,9],"_links":{"self":[{"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/posts\/401"}],"collection":[{"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/users\/3"}],"replies":[{"embeddable":true,"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/comments?post=401"}],"version-history":[{"count":1,"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/posts\/401\/revisions"}],"predecessor-version":[{"id":568,"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/posts\/401\/revisions\/568"}],"wp:attachment":[{"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/media?parent=401"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/categories?post=401"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/www.iot-embedded.de\/iot-2017\/wp-json\/wp\/v2\/tags?post=401"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}\n
\n# -*- coding: utf-8 -*-<\/p>\n
\nimport atexit<\/p>\n
\nclient.disconnect()
\nexit()<\/p>\n
\nprint(„Disconnect with result code “ + str(rc))<\/p>\n
\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
\ndef on_message(client, userdata, msg):
\nprint(„Topic: „, msg.topic + „\\nMessage: “ + str(msg.payload))<\/p>\n
\nclient = mqtt.Client(clean_session=True)
\nclient.on_connect = on_connect
\nclient.on_message = on_message
\nclient.on_disconnect = on_disconnect<\/p>\n
\nclient.connect(„broker.mqttdashboard.com“, 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>\n\n