openhabforum.de

Code: Alles auswählen

udo1toni@calibre:~$ cat /etc/systemd/system/mqttclient.service
[Install]
WantedBy=multi-user.target
Type=simple

[Service]
ExecStart=/usr/bin/python3 /usr/local/sbin/mqttclient.py
User=root
Restart=always
RestartSec=10
udo1toni@calibre:~$

Code: Alles auswählen

sudo systemctl daemon-reload
sudo systemctl enable mqttclient.service
sudo systemctl start mqttclient.service

Code: Alles auswählen

udo1toni@calibre:~$ cat /usr/local/sbin/mqttclient.py
#!/usr/bin/python

# define imports
import configparser
import logging
from paho.mqtt import client as mqtt
import time
from sysdmanager import SystemdManager

# define config reader
config = configparser.ConfigParser()
# read config from /etc/default/mqttclient
config.read('/etc/default/mqttclient') 

# set config and default value if not set
# for logger
log_file = (config['logging']).get('filename','/var/log/pymqtt.log')
log_level = int((config['logging']).get('level','30'))
logging.basicConfig(filename=log_file,format='%(asctime)s %(levelname)s:%(message)s', datefmt='%Y/%m/%d/ %H:%M:%S', level=log_level)

# for mqtt connection
MQTT_SERVER = (config['mqtt']).get('url','localhost')
MQTT_PORT = int((config['mqtt']).get('port','1883'))
MQTT_RECONNECT = int((config['mqtt']).get('reconnect','60'))
MQTT_PATH = (config['mqtt']).get('path','/')
MQTT_COMMAND = (config['mqtt']).get('command','cmnd')
MQTT_STATE = (config['mqtt']).get('state','state')
MY_COMMAND = MQTT_PATH+MQTT_COMMAND
MY_STATE = MQTT_PATH+MQTT_STATE

# define functions
# The callback for when the client receives a CONNACK response from the server.
def on_connect(client, userdata, flags, rc):
    client.publish(MQTT_PATH+"LWT", payload="Online", qos=0, retain=True)
    logging.info("Connected with result code "+str(rc))
    if rc: logging.warning("Connecting resulted with" +str(rc))
    # Subscribing in on_connect() means that if we lose the connection and
    # reconnect then subscriptions will be renewed.
    client.subscribe(MY_COMMAND)
    logging.info("Subscribed to "+str(MY_COMMAND))

# The callback for when a PUBLISH message is received from the server.
def on_message(client, userdata, msg):
    manager = SystemdManager()
    logging.debug("got message!")
    payload=format(msg.payload.decode("utf-8"))
    logging.info(msg.topic+" : "+payload)
    startunit=""
    stopunit1=""
    stopunit2=""
    if payload == "1":
        logging.debug("Payload is 1 -> CS")
        stopunit1="cps.service"
        startunit="calibre-server.service"
    elif payload == "2":
        logging.debug("Payload is 2 -> CPS")
        startunit="cps.service"
        stopunit1="calibre-server.service"
    elif payload == "0":
        logging.debug("Payload is 0 -> OFF")
        stopunit2="cps.service"
        stopunit1="calibre-server.service"
    else:
        logging.info("Payload is "+payload+" -> only send state")
    if stopunit1 != "":
        logging.debug("stop service "+stopunit1+"!")
        manager.stop_unit(stopunit1)
    if stopunit2 != "":
        logging.debug("stop service "+stopunit2+"!")
        manager.stop_unit(stopunit2)
    client.publish(MY_STATE, payload="0", qos=0, retain=False)
    logging.debug("published state 0 to "+MY_STATE)
    if startunit != "":
        logging.debug("wait until starting service!")
        time.sleep(10)
        logging.debug("starting service "+startunit+"!")
        manager.start_unit(startunit)
    logging.debug("publishing state")
    if manager.is_active("cps.service"):
        cpsstate="ON"
        client.publish(MY_STATE, payload="2", qos=0, retain=False)
        logging.debug("published state 2 to "+MY_STATE)
    else:
        cpsstate="OFF"
    if manager.is_active("calibre-server.service"):
        csstate="ON"
        client.publish(MY_STATE, payload="1", qos=0, retain=False)
        logging.debug("published state 1 to "+MY_STATE)
    else:
        csstate="OFF"
    client.publish(MQTT_PATH+"cs/state", payload=csstate, qos=0, retain=False)
    client.publish(MQTT_PATH+"cps/state", payload=cpsstate, qos=0, retain=False)
    logging.debug("published state "+csstate+" to "+MQTT_PATH+"cs/state")
    logging.debug("published state "+cpsstate+" to "+MQTT_PATH+"cps/state")


# main program
# set a new client and create hooks to functions
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.will_set(MQTT_PATH+"LWT", payload="Offline", qos=0, retain=True)

# connect
client.connect(MQTT_SERVER, MQTT_PORT, MQTT_RECONNECT)

# Blocking call that processes network traffic, dispatches callbacks and
# handles reconnecting.
# Other loop*() functions are available that give a threaded interface and a
# manual interface.
client.loop_forever()
udo1toni@calibre:~$

Code: Alles auswählen

udo1toni@calibre:~$ cat /etc/default/mqttclient
[mqtt]
url = 192.168.178.55
port = 1883
reconnect = 60
path = calibre/
command = cmnd
state = state
lwt = LWT

[logging]
filename = /var/log/pymqtt.log
# CRITICAL=50 ERROR=40 WARNING=30 INFO=20 DEBUG=10 NOTSET=0
level = 30
udo1toni@calibre:~$

Code: Alles auswählen

sudo apt install python3 pip

Code: Alles auswählen

sudo pip install configparser paho-mqtt sysdmanager