Path: csiph.com!weretis.net!feeder8.news.weretis.net!news.szaf.org!fu-berlin.de!uni-berlin.de!not-for-mail
From: =?iso-8859-15?Q?Stefan_Clau=DF?= <st_clauss@gmx.de>
Newsgroups: de.comp.lang.python
Subject: =?utf-8?q?=5BPython-de=5D_Re=3A_paho-mqtt_und_vorgegebene_Callback-Funktionen_in_einer_Klasse=2E?=
Date: Wed, 21 Jun 2023 14:01:52 +0200
Lines: 82
Message-ID: <op.16v01ec0q0n66g@desktop-ekoajh9>
References: <u64v9c$2041$1@news1.tnib.de>
Mime-Version: 1.0
Content-Type: text/plain; charset=iso-8859-15; format=flowed; delsp=yes
Content-Transfer-Encoding: Quoted-Printable
User-Agent: Opera Mail/1.0 (Win32)
Message-ID-Hash: 5SRVEXLQZGT4L6J7JKOJQ67SKIKKNJBE
Precedence: list
Archived-At: <https://mail.python.org/archives/list/python-de@python.org/message/5SRVEXLQZGT4L6J7JKOJQ67SKIKKNJBE/>
Xref: csiph.com de.comp.lang.python:5991

Hallo,

versuche es mit self.on_connect und self.on_message jeweils auf der rech=
ten
Seite der Zuweisung.

VG
Stefan

Am .06.2023, 19:12 Uhr, schrieb Marc Haber  =

<mh+usenetspam1118@zugschl.us>:

> Hallo,
>
> ich habe hier das abgespeckte, nicht lauff=E4hige Teilprogramm:
>
> |#!/usr/bin/python
> |
> |import paho.mqtt.client as mqtt
> |
> |class ApplianceMonitor:
> |    """the main ApplianceMonitor object"""
> |
> |    def __init__(self):
> |        # do something intelligent
> |
> |    def on_connect(self, client, userdata, flags, rcode):
> |        client.subscribe('tele/wama/SENSOR')
> |
> |    def on_message(self, client, userdata, msg):
> |        # do something intelligent with msg
> |
> |    def main(self):
> |        client =3D mqtt.Client()
> |        client.on_connect =3D on_connect
> |        client.on_message =3D on_message
> |
> |        client.connect('mqtt.local', 1883, 60)
> |
> |        client.loop_start()
> |
> |        while True:
> |            time.sleep(30)
> |            # do something intelligent with the accumulated data
> |
> |
> |if __name__ =3D=3D "__main__":
> |    amon =3D ApplianceMonitor(args)
> |    amon.main()
> |
> |# end of file
>
> Ich habe die ganze Applikation in eine Klasse ApplianceMonitor
> ausgelagert als Ergebnis der Diskussion von vor einem halben Jahr,
> weil ich so ohne globale Statusvariablen auskomme und die in der
> Klasse verstecken kann (hier nicht sichtbar weil sie der Minimierung
> des Codes zum Opfer gefallen sind).
>
> Leider haben die beiden Callbackfunktionen von paho eine vorgegebene
> Signatur und k=F6nnen deswegen keine Methoden des ApplianceMonitor sei=
n.
> Wenn ich die Initialisierung des MQTT-Moduls ins Hauptprogramm
> verlagere, bin ich auf ein einziges Applikationsobjekt limitiert (was
> in der Tat bl=F6d ist weil ich vielleicht sp=E4ter das Monitoring mehr=
erer
> MQTT-Topics mit mehreren Objekten des Applikationstyps machen m=F6chte=
.
> Oder geht das sowieso nicht weil ich nur eine client.loop pro Programm=

> haben kann?
>
> Ist das paho-Modul bl=F6d oder ich? Oder geht das halt nicht anders?
>
> Gr=FC=DFe
> Marc


-- =

Erstellt mit Operas E-Mail-Modul: http://www.opera.com/mail/