Wie zu verwenden paho mqtt-client in django?

Schreibe ich eine django-Anwendung, die handeln sollte, wie MQTT Verleger und als Abonnent.

Wo sollte ich anfangen die paho-client und führen Sie loop_forever () - Funktion.

Sollte es sein wsgi.py ?

  • loop_forever() wird immer blockieren, so sollte es wohl auch gestartet werden, in einem eigenen thread
InformationsquelleAutor Raja Sudhan | 2016-12-07
  1. 11

    Update:

    Wenn Sie brauchen, Django läuft in mehreren threads dann zu veröffentlichen, die Nachrichten von Ihrem Django-app, die Sie verwenden können, helper-Funktionen aus dem Modul Veröffentlichen der Paho - https://eclipse.org/paho/clients/python/docs/#id17
    Sie nicht brauchen, um erstellen Sie eine Instanz der mqtt-client und starten Sie eine Schleife, in diesem Fall. Und abonnieren Sie einige Thema überlege, ob mqtt-client als standalone-Skript und importieren es notwendig Module Ihre Django-app (und vergessen Sie nicht, um den setup-Django-Umgebung im Skript).

    Die Antwort unten ist nur gut, wenn Sie Django in einem einzigen thread, das ist nicht üblich in der Produktion.

    Erstellen mqtt.py in Ihrer Anwendung Ordner und legen Sie alle zugehörigen code. Zum Beispiel:

    import paho.mqtt.client as mqtt

def on_connect(client, userdata, rc):
    client.subscribe("$SYS/#")

def on_message(client, userdata, msg):
    # Do something
    pass

client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

client.connect("iot.eclipse.org", 1883, 60)

    Nicht nennen loop_forever() hier!

    Dann in Ihrer Anwendung __init__.py nennen loop_start():

    from . import mqtt

mqtt.client.loop_start()

    Mit loop_start() statt loop_forever() geben Sie nicht blockieren, hintergrund-thread.

    • Danke Max, funktioniert einwandfrei !! Ich habe einen anderen Zweifel, was passiert, wenn ich die Skala der web-Prozess macht das erstellen mehrerer mqtt-clients ? Wenn ja wie kann ich das stoppen ?
    • was meinst du mit "Skala der web-Prozess"?
    • Während der Ausführung der django-Anwendung in der Produktion ich bin in der Bereitstellung von multiple-server mit load-balancer, damit ich nicht wollen, zu hören, um Nachrichten in allen hosts.
    • ok, jetzt verstehe ich dein Anliegen. Sie haben Recht, wenn Sie ausführen, Django in mehreren threads (als es geschieht in der Regel in der Produktion), dann sollten Sie nicht beginnen, ein Teilnehmer in jeden thread, weil on_message in diesem Fall wird Feuer in jeden thread für eine einzelne Nachricht, aber Sie wollen, dass es Feuer nur einmal. Überlege, ob mqtt-client als standalone-Skript und importieren es notwendig Module Ihre Django-app (vergessen Sie nicht, setup Django Umgebung, in diesem Skript).
    • mein vorheriger Kommentar war über die Anmeldung. Und für die Veröffentlichung von Django-die Sie verwenden können, die helper-Funktionen aus dem Modul Veröffentlichen der Paho, finden Sie unter updates auf meine Antwort.
    • diese arbeiten sehr gut mit ./manage.py runserver und nicht mit: /usr/local/bin/uwsgi --sockel :7011 --Modul myproject.wsgi-Warum?
    • können Sie uns mehr details? Sehen Sie irgendwelche Ausnahmen? Kannst du den code von deinem Projekt? Bedenken Sie auch, dass der code in meiner Antwort nur angemessen, wenn Sie Django in einem einzigen thread, finden Sie in den aktualisierten Teil der Antwort.
    • Wenn ich das Tue, habe ich tatsächlich 3 mal das Skript in der Produktion, hat jemand irgendwelche answers_
    • was Skript führen Sie 3-mal? Könntest du mehr details?
    • Ich bin usin gunicorn, in den Einstellungen habe ich 3 arbeitet, so läuft das script 3 mal... wie um dies zu vermeiden?(wenn ich auf 1 gesetzt, Arbeiter, funktioniert alles einwandfrei)
    • Sie brauchen ein eigenständiges Skript, das nicht importiert Ihre Django-app. Sie haben ausgeführt, dass script mit systemd oder was auch immer Sie verwenden (nicht von Django gestartet wird 3-mal durch die Arbeitnehmer).
    • und ich wäre in der Lage zu schreiben, in der Django-db mit der django-Funktionen?
    • Ja, Sie werden in der Lage sein zu verwenden, Django ORM und alle Ihre Modelle in einem eigenständigen Skript. Aber vergessen Sie nicht, setup Django-Umgebung im Skript (siehe stackoverflow.com/a/41266715/6408646).

    InformationsquelleAutor Max Polezhaev
Schreibe einen Kommentar