Paho Python-MQTT-client eine Verbindung erfolgreich aber on_connect callback wird nicht aufgerufen

Ich habe ein einfaches script auf einem Raspberry Pi veröffentlicht, die eine Beispiel-Nachricht alle 3 Sekunden. Ich habe erklärt die Rückrufe on_connect, on_publish und on_disconnect. Dieser client verbindet sich erfolgreich, aber on_connect ist nicht genannt, veröffentlicht und on_publish genannt wird, trennt und on_disconnect genannt wird.

Dies ist mein Skript

import paho.mqtt.client as mqtt
import time

def on_connect(mqttc, userdata, rc):
    print("Connected with result code "+str(rc))
    if rc!=0 :
        mqttc.reconnect()

def on_publish(mqttc, userdata, mid):
    print "Published"

def on_disconnect(mqttc, userdata, rc):
    if rc != 0:
        print("Unexpected disconnection. Reconnecting...")
        mqttc.reconnect()
    else :
        print "Disconnected successfully"

# Setup MQTT
# broker='test.mosquitto.org'
broker = 'iot.eclipse.org'
broker_port=1883

# Create a client instance
mqttc=mqtt.Client(client_id="MyClient")
mqttc.on_connect = on_connect
mqttc.on_publish = on_publish
mqttc.on_disconnect = on_disconnect

while 1:

    mqttc.connect(broker, broker_port, 60)
    # print "Connected."    # I don't want this message. 
                            # Why isn't the on_connect callback invoked?

    try:
        topic = "this/is/a/test/topic"
        payload = "test_message"
        print "Publishing " + payload + " to topic: " + topic + " ..."
        mqttc.publish(topic, payload, 0)

    except Exception as e:
        print "exception"
        log_file=open("log.txt","w")
        log_file.write(str(time.time())+" "+e.__str__())
        log_file.close()

    mqttc.disconnect()
    print ""
    time.sleep(3)

Obwohl dieser kleine "bug" nicht auf die Nachricht zu veröffentlichen, ist hauptsächlich, was ich erreichen will, warum passiert es und wie kann ich es beheben?

InformationsquelleAutor evgi9 | 2016-04-05
  1. 7

    Der Grund, warum dies nicht funktioniert ist, dass Sie nicht beim aufrufen einer der loop*() Funktionen. Dieser Prozess-Netzwerk-traffic. Wenn Sie nicht verwenden, es gibt keine Garantie für die ausgehende Nachrichten geschickt werden und absolut keine eingehenden Nachrichten verarbeitet werden.

    loop_forever() ist ein blockierender Aufruf, dass die Prozesse der Netzwerk-Schleife - wohl nicht das, was Sie wollen.

    loop_start() startet einen thread zum verarbeiten der Netzwerk-Schleife und so kehrt sofort.

    Ich würde dies tun:

    mqttc.connect(broker, broker_port, 60) # Don't forget to handle errors
mqttc.loop_start()

while 1:
    try:
        topic = "this/is/a/test/topic"
        payload = "test_message"
        print "Publishing " + payload + " to topic: " + topic + " ..."
        mqttc.publish(topic, payload, 0)

    except Exception as e:
        print "exception"
        log_file=open("log.txt","w")
        log_file.write(str(time.time())+" "+e.__str__())
        log_file.close()

    print ""
    time.sleep(3)

    Sie noch brauchen, um das on_connect Rückruf als @Kiran sagt.

    Gibt es keine Notwendigkeit, trennen Sie die einzelnen Zeit - und in der Tat gibt es keine Garantie, wird Ihre Nachricht wurde gesendet, wenn Sie die Verbindung trennen. Sollten Sie die on_publish Rückruf zu wissen, Wann die Nachricht gesendet wird.

    Wenn Sie wollen, um ein einfaches verbinden zu veröffentlichen trennen, dann vielleicht mit der paho.mqtt.publish helper module:

    import paho.mqtt.publish as publish

while 1:
    try:
        topic = "this/is/a/test/topic"
        payload = "test_message"
        print "Publishing " + payload + " to topic: " + topic + " ..."
        publish.single(topic, payload, 0, host=broker, port=broker_port)

    except Exception as e:
        print "exception"
        log_file=open("log.txt","w")
        log_file.write(str(time.time())+" "+e.__str__())
        log_file.close()

    print ""
    time.sleep(3)
    InformationsquelleAutor ralight
  2. 4

    Ihre on_connect() Methode Erklärung fehlt die flags(Eins) parameter. So ist es nicht immer aufgerufen wird. Flags-parameter enthalten die Antwort per broker. Es musste

    def on_connect(mqttc, userdata, flags, rc):

    Auch, warum Sie sich verbinden und trennen ... in-Schleife ? Versuchen Sie es mit der loop_start() und loop_stop() Methoden, die Griffe auto-verbindungen auf einer Verbindung ablegen(Beispiel).

    • Die Makler, die ich bin derzeit mit (nicht im Beispiel) kann eine maximale Anzahl von clients verbunden ist. Da gibt es mehr Kunden, die schicken die Daten in regelmäßigen Abständen, die Logik hinter den verbinden-senden-zu trennen ist, damit mehr von Ihnen verbunden mit der broker.
    • Dafür können Sie auch die Globale Hilfsfunktionen(1)
    InformationsquelleAutor Kiran
Schreibe einen Kommentar