Python-Paho/MQTT : die Erkennung Connect error

Kurzum, ich habe ein Paho/MQTT Probe eingestellt, das funktioniert gut, aber ich habe Probleme beim erkennen von Fehlern. Speziell, ich bin nicht immer ein on_connect Rückruf, und wenn eine ungültige user-id/Kennwort-Kombination ist gegeben, es schlägt im hintergrund fehl.
In der Tat, durch jedes Anzeichen, es hat alles geklappt!

Was mache ich falsch?

(snip)

def on_connect(client, userdata, flags, rc):
    print("Connected with flags [%s] rtn code [%d]"% (flags, rc) )

def on_disconnect(client, userdata, rc):
    print("disconnected with rtn code [%d]"% (rc) )

def on_publish(client, userdata, msgID):
    print("Published with MsgID [%d]"% (msgID) )


mqttc = mqtt.Client()
mqttc.on_connect = on_connect
mqttc.on_disconnect = on_disconnect
mqttc.on_publish = on_publish

mqttc.username_pw_set(Q_USER, Q_PSWD)

rc=mqttc.connect(Q_BROKER, Q_PORT)
print "Return="+str(rc)

mqttc.loop_start()
rc=mqttc.publish(Q_TOPIC, "Hello, World!")
print "Return="+str(rc)

mqttc.disconnect()
mqttc.loop_stop()

Ausgabe, wenn die Benutzer-id oder Kennwort ist absichtlich falsch:

Return=0
Published with MsgID [1]
Return=(0, 1)
disconnected with rtn code [0]
Um die Verwirrung hinzuzufügen... Wenn ich den loop_start() VOR dem connect () - Aufruf, wird die Nachricht nicht posten, richtig. Noch keine Fehlermeldungen
Welchen broker benutzt du und wie hast du Sie konfiguriert die Authentifizierung? z.B. wenn mosquitto ist allow_anonymous wahr?
Beachten Sie, dass eine loop_start() vor dem connect () - Aufruf bekannt zu undefinierten Ergebnissen führen.

InformationsquelleAutor Jeppedy | 2017-02-25

  1. 2

    Stellt sich heraus, dass es ein paar verschiedene Probleme.

    • Stellen Sie zuerst eine Verbindung gibt, ohne wirklich angeschlossen sind. Hinzufügen einer Warteschleife mit einer Schlafen, bis die Connect-callback empfangen wird, ist entscheidend. Nur die callback-sagt, dass Sie die Verbindung erfolgreich oder fehlgeschlagen ist.
    • Zweite, einmal sah ich den return-code, die ich sah, mir war das Versagen Protocol Version Mismatch. Der Mosquitto-version mein Pi war nach unten ziehen war WIRKLICH alt. Gefunden einen post hingewiesen, dass mein system auf eine neuere version. Gelöst wird die version mismatch-problem.
    • Dritten, indem die "loop_start ()", bevor die Verbindung funktioniert nicht. Die intuitive Ort ist nicht der richtige Ort.
    • Vierte, so muss Sleep() aufrufen, bevor Sie die Verbindung Trennen, oder Sie werden nicht sehen, all die Rückrufe.

    Unteren Linie, während die Dokumente zeigen, wie die APIs, zeigen Sie nicht, wie Sie schreiben, ein robustes Programm für die Produktion verwenden.

    Ich bin noch immer auf der Suche nach Möglichkeiten, zu wissen, Wann all in-Flug veröffentlichen Anrufe gelöscht haben, anstatt mit einem blinden Schlafen nennen, aber mein ursprüngliches Problem ist gelöst.

    Hatte, Sie konnten Produzent einer funktionierenden code, um den status-code?

    InformationsquelleAutor Jeppedy

  2. 0

    Beim senden mqtt-CONNECT-Paket, die Sie erhalten, sollte CONNACK Antwort. Diese Antwort enthält die folgenden codes

    0 - Erfolg, der die Verbindung akzeptiert

    1 - connection refused, bad-Protokoll

    2 - sich weigerte, client-id-Fehler

    3 - sich weigerte, Dienst nicht verfügbar
    4 - weigerte sich, die ungültigen Benutzernamen oder Passwort

    5 - verweigert wird, nicht berechtigt

    Wie Sie sehen können, wird Ihre Antwort sein sollte 4. Aber es ist null. Es könnte sein, dass Sie broker nicht, überprüfen Sie die Anmeldeinformationen, so dass Sie Ihre verbinden Nachricht akzeptiert wird. Client sieht gut aus.

    Hinweis 1) ich war nicht zu sehen, eine schließen-Antwort an alle-und 2) war ich mit QOS '0', So die connect hatte es noch nie gelungen, und da schickte ich als fire-and-forget, der RC wird immer '0'. Sobald ich steigerte das QOS-Niveau, ich bekam Nachricht senden Fehler. Auch, wenn ich verarbeitete die Rückrufe erfolgreich, ich sah, ich war immer ein Connect Fehler von '1' (alt Mosquitto-version nicht unterstützt 3.11-client-Protokoll-version)

    InformationsquelleAutor Mihailo Stupar

  3. -1

    Versuchen, die publish in eine while - Schleife wie diese 

    while True:
    mqttc.loop()
    rc=mqttc.publish(Q_TOPIC, "Hello, World!")
    print("Return=" + str(rc))
    if sth:
        break
mqttc.disconnect()

    In dieser Weise, wird die callback-Funktion kann ausgeführt werden, bevor das Programm endet.

    Ich bin neu in MQTT, aber für mich, dies immer wieder veröffentlichen der gleichen Nachricht. Und was ist "sth"? Die Antwort scheint auf der Suche nach dem on_publish zu machen, durch.
    Hier meine ich, wenn Sie nicht setzen den publish in eine while Schleife, das Programm wird beendet bevor die callback-Funktion ist triggerred. sth hier bedeutet, dass jede Bedingung, die helfen können, um die Schleife Steuern. Tatsächlich erinnerte ich mich, dass ich begegnete der gleichen situation, kann aber nicht klar denken, die Lösung. Ich schlage vor, Sie versuchen.
    Vereinbart. Siehe den vierten Punkt in meiner Antwort. Derzeit nutze ich einen Schlaf, aber würde gerne eine robuste und präzise Art und Weise zu wissen, Wann alle Veröffentlichten Nachrichten wurden behoben.

    InformationsquelleAutor Hou Lu

Schreibe einen Kommentar