mqttserver

Stellt die MQTT Uebertragung fuer IoT-Zwecke bereit.

Global Attributes

__author__

__copyright__

__license__

Classes

MqttServer

Server fuer die Uebertragung des Prozessabbilds per MQTT.

Functions

None

MqttServer

Server fuer die Uebertragung des Prozessabbilds per MQTT.

Derived from

Thread

Class Attributes

None

Class Methods

None

Methods

MqttServer	Init MqttServer class.
_evt_io	Sendet Daten aus Events.
_loadrevpimodio	Instantiiert das RevPiModIO Modul.
_on_connect	Verbindung zu MQTT Broker.
_on_disconnect	Wertet Verbindungsabbruch aus.
_on_message	Sendet piCtory Konfiguration.
_send_pictory_conf	Sendet piCtory Konfiguration per MQTT.
newlogfile	Konfiguriert die FileHandler auf neue Logdatei.
reload_revpimodio	Fuehrt im naechsten Zyklus zum Reload.
run	Startet die Uebertragung per MQTT.
stop	Stoppt die Uebertragung per MQTT.

Static Methods

None

MqttServer (Constructor)

MqttServer(basetopic, sendinterval, broker_address, port=1883, tls_set=False, username="", password=None, client_id="", send_events=False, write_outputs=False)

Init MqttServer class.

basetopic: Basis-Topic fuer Datenaustausch
sendinterval: Prozessabbild alle n Sekunden senden / 0 = aus
broker_address: Adresse des MQTT-Servers
port: Portnummer des MQTT-Servers
tls_set: TLS fuer Verbindung zum MQTT-Server verwenden
username: Optional Benutzername fuer MQTT-Server
password: Optional Password fuer MQTT-Server
client_id: MQTT ClientID, wenn leer automatisch random erzeugung
send_events: Sendet Werte bei IO Wertaenderung
write_outputs: Per MQTT auch Outputs schreiben

MqttServer._evt_io

_evt_io(name, value, requested=False)

Sendet Daten aus Events.

name: IO-Name
value: IO-Value
requested: Wenn True, wird 'got' Topic verwendet

MqttServer._loadrevpimodio

_loadrevpimodio()

Instantiiert das RevPiModIO Modul.

Returns:: None or Exception

MqttServer._on_connect

_on_connect(client, userdata, flags, rc)

Verbindung zu MQTT Broker.

MqttServer._on_disconnect

_on_disconnect(client, userdata, rc)

Wertet Verbindungsabbruch aus.

MqttServer._on_message

_on_message(client, userdata, msg)

Sendet piCtory Konfiguration.

MqttServer._send_pictory_conf

_send_pictory_conf()

Sendet piCtory Konfiguration per MQTT.

MqttServer.newlogfile

newlogfile()

Konfiguriert die FileHandler auf neue Logdatei.

MqttServer.reload_revpimodio

reload_revpimodio()

Fuehrt im naechsten Zyklus zum Reload.

MqttServer.run

run()

Startet die Uebertragung per MQTT.

MqttServer.stop

stop()

Stoppt die Uebertragung per MQTT.