Ollo/FanLedCtrl
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: Ollo:master
Branches Tags
Ollo:master
Ollo:mqttControl
..
compare: Ollo:mqttControl
Branches Tags
Ollo:master
Ollo:mqttControl

No commits in common. "master" and "mqttControl" have entirely different histories.
master ... mqttContro

3 changed files with 20 additions and 94 deletions
Show Stats Expand all files Collapse all files

26
ReadMe.md
View File

@ -38,29 +38,3 @@ Set the following parameter:
```docker run -t -i --device=/dev/ttyUSB0 -e SERIAL_DEVICE="/dev/ttyUSB0" -e MQTT_SERVER="192.168.x.y" -e MQTT_TOPIC="testtopic/" sha256:```
Additional logging can be activated with the variable **PY_LOGGING** possible values are:
* DEBUG
* INFO
* WARNING
* ERROR
* CRITICAL
#### Execution via Docker Compose
```
# template docker-compose.yml
services:
python_app:
attach: false
build:
context: .
dockerfile: Dockerfile
environment:
- SERIAL_DEVICE=/dev/ttyUSB0
- MQTT_SERVER=192.168.x.y
- MQTT_TOPIC=testtopic/
devices:
- "/dev/ttyUSB0:/dev/ttyUSB0"
```
build image: **docker-compose up --build**
start with **docker-compose up --detach**

1
mqttclient/.gitignore vendored
View File

@ -1 +0,0 @@
docker-compose.yml

87
mqttclient/fanATserial2mqtt.py
View File

@ -4,7 +4,6 @@ import sys
from paho.mqtt import client as mqtt_client
import os
import serial
import logging
MAXIMUM_COMMUNICATION_FAILURE=1000
@ -12,73 +11,35 @@ TEMPERATUR_MIN_DIFFERENCE = 2
TARGET_MIN_DIFFERENCE = 1
RPM_MIN_DIFFERENCE = 50
COMMAND_PREFIX = "ollpe"
# MQTT Settings
mqtt_server=os.environ['MQTT_SERVER']
mqtt_topic=os.environ['MQTT_TOPIC']
# SERIAL Port
serial_device=os.environ['SERIAL_DEVICE']
# Logging
try:
if (os.environ['PY_LOGGING']):
customLevel = os.environ['PY_LOGGING'].upper()
except (KeyError):
customLevel = 'WARNING'
logging.basicConfig(
level=customLevel,
filename="/var/log/app.log",
filemode="w",
format="%(asctime)s - %(levelname)s - %(message)s"
)
logging.debug("Start Serial connect")
# Start Serial communication
ser = serial.Serial(serial_device, 115200, timeout=1) # open serial port
if (ser is None):
logging.error("Cannot open device" + str(serial_device))
sys.exit()
# The callback for when a PUBLISH message is received from the server.
def on_message(client, userdata, msg):
payload = msg.payload.decode("utf-8")
if ((mqtt_topic + "cmd/rpm") == msg.topic):
if (ser.is_open):
command = COMMAND_PREFIX+"f{:02x}".format(int(payload))
command = "ollpef{:02x}".format(int(payload))
ser.write(command.encode('utf-8'))
else:
client.publish(mqtt_topic + "cmd/exception", "Serial Connection closed") # clear exception
elif ((mqtt_topic + "cmd/led") == msg.topic):
# OpenHAB r,g,b payload: 20,0,250
try:
if (',' in payload):
red, green, blue = str(payload).split(',')
logging.debug("Red=" + str(red) + " Green=" + str(green) + " Blue=" + str(blue))
redB= int((int(red)*255)/250)
logging.debug("Byte Red=" + str(redB))
greenB= int((int(green)*255)/250)
logging.debug("Byte Green =" + str(greenB))
blueB= int((int(blue)*255)/250)
logging.debug("Byte Blue =" + str(blueB))
command = COMMAND_PREFIX+"l{:02x}{:02x}{:02x}".format(redB, greenB, blueB)
else:
command = COMMAND_PREFIX+"l" + payload
ser.write(command.encode('utf-8'))
except (ValueError):
logging.error("Wrong MQTT Command: '" + str(payload) + "'")
command = "ollpel" + payload
ser.write(command.encode('utf-8'))
else:
logging.warning(msg.topic+" "+str(msg.payload))
print(msg.topic+" "+str(msg.payload))
# Handle MQTT Commands
def on_connect(client, obj, flags, reason_code, properties):
client.subscribe(mqtt_topic + "cmd/led")
client.subscribe(mqtt_topic + "cmd/rpm")
client.publish(mqtt_topic + "online", payload="true", qos=1, retain=True)
logging.debug("Connected: " + str(reason_code))
print("Connected: " + str(reason_code))
# Start mqtt
client_id = f'python-fan-ctrl'
@ -87,13 +48,12 @@ client.on_message = on_message
client.on_connect = on_connect
if (not (mqtt_server)):
logging.error("MQTT_SERVER is not set")
print("MQTT_SERVER is not set")
if (not (mqtt_topic)):
logging.error("MQTT_TOPIC is not set")
print("MQTT_TOPIC is not set")
# Start MQTT Client
client.will_set(mqtt_topic + "online", payload="false", qos=1, retain=True)
client.connect(mqtt_server, 1883)
client.loop_start()
@ -110,15 +70,14 @@ lastTarget = -1
# Endless Loop
try:
while ((mqtt_topic is not None) and (mqtt_server is not None)):
while True:
try:
if (not (ser.is_open)):
ser.open()
continue
except (serial.SerialException):
logging.error("Could not open serial connection")
client.publish(mqtt_topic + "exception", "serial reopen") # check which port was really used
time.sleep(3.0)
time.sleep(1.0)
try:
line = ser.readline() # read a '\n' terminated line
@ -129,32 +88,26 @@ try:
if (SerialCommunicationFailureCounter > MAXIMUM_COMMUNICATION_FAILURE):
raise serial.SerialException("device reports readiness / device disconnected " + str(MAXIMUM_COMMUNICATION_FAILURE) + " times")
if (line) :
if (line):
client.publish(mqtt_topic + "exception", "") # clear exception
# activate debug code, by default
temperatur = None
percent = None
rpm = None
# convert byte array to string
l = line.decode("utf-8")
if (COMMAND_PREFIX in l):
logging.debug("Skip '" + str(l) + "', found " + str(COMMAND_PREFIX))
continue
try:
# Parse the controller information
# e.g. : 22.00;0%;0RPM
temperatur, percent, rpm = l.split(";")
except (ValueError):
logging.debug("Unparsable '" + str(l) + "'")
# activate debug code
temperatur = None
percent = None
rpm = None
if ((temperatur) and (percent) and (rpm)):
parseError=False
try:
currentTemperatur = float(temperatur)
except (ValueError):
logging.error("Temperatur Error: could not convert string to float:" + temperatur)
print("Temperatur Error: could not convert string to float:" + temperatur)
currentTemperatur = lastTemperatur
if (abs(currentTemperatur - lastTemperatur) > TEMPERATUR_MIN_DIFFERENCE):
client.publish(mqtt_topic + "temperatur", str(currentTemperatur))
@ -164,7 +117,7 @@ try:
try:
currentTarget = int(percent[:-4])
except (ValueError):
logging.error("Percent Error: could not convert string to int:" + (percent[:-4]))
print("Percent Error: could not convert string to int:" + (percent[:-4]))
currentTarget = lastTarget
if (abs(lastTarget - currentTarget) > TARGET_MIN_DIFFERENCE):
@ -180,7 +133,7 @@ try:
try:
currentRPM = int(rpm[:-3])
except (ValueError):
logging.error("RPM Error: could not convert string to int:" + (rpm[:-3]))
print("RPM Error: could not convert string to int:" + (rpm[:-3]))
currentRPM = lastRPM
if (abs(currentRPM-lastRPM) > RPM_MIN_DIFFERENCE):
@ -196,12 +149,12 @@ try:
else:
client.publish(mqtt_topic + "debug", line) # line was invalid and could not be parsed
else:
time.sleep(0.5)
time.sleep(0.2)
except (KeyboardInterrupt, SystemExit):
logging.error("User aborted service ...")
print("User aborted service ...")
client.publish(mqtt_topic + "debug", "User aborted service")
time.sleep(0.5)
logging.debug("service Dead")
print("service Dead")
client.loop_stop()