e-paper-display/examples/mqtt.py

75 lines
2.1 KiB
Python
Raw Normal View History

2022-10-18 20:38:02 +00:00
#!/usr/bin/python
# -*- coding:utf-8 -*-
import sys
import os
picdir = os.path.join(os.path.dirname(os.path.dirname(os.path.realpath(__file__))), 'pic')
libdir = os.path.join(os.path.dirname(os.path.dirname(os.path.realpath(__file__))), 'lib')
if os.path.exists(libdir):
sys.path.append(libdir)
import logging
from waveshare_epd import epd2in13bc
import time
from PIL import Image,ImageDraw,ImageFont
import traceback
from paho.mqtt import client as mqtt_client
2022-10-19 06:40:32 +00:00
import paho.mqtt.client as paho
2022-10-18 20:38:02 +00:00
logging.basicConfig(level=logging.DEBUG)
2022-10-18 21:00:28 +00:00
Connected = False
2022-10-18 21:02:28 +00:00
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("Connected to MQTT Broker!")
2022-10-18 20:38:02 +00:00
2022-10-18 21:02:28 +00:00
global Connected #Use global variable
Connected = True #Signal connection
else:
print("Failed to connect, return code %d\n", rc)
2022-10-18 20:38:02 +00:00
2022-10-18 21:00:28 +00:00
def on_message(client, userdata, msg):
print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
Connected = False #global variable for the state of the connection
2022-10-18 20:38:02 +00:00
2022-10-18 21:04:02 +00:00
broker = "192.168.99.224"
2022-10-19 06:48:52 +00:00
port = 1883
2022-10-19 07:07:32 +00:00
topic_wHouseConsumption = "openWB/global/WHouseConsumption"
topic_pvProduction = "openWB/pv/W"
topic_energyImportExport = "openWB/evu/W"
topic_houseBatterySoC = "openWB/housebattery/%Soc"
topic_houseBatteryLoadUnload = "openWB/housebattery/W"
2022-10-18 21:00:28 +00:00
username = "mqtt-user"
2022-10-19 06:40:32 +00:00
pw = "phio6yiR9ohs1veeghu4WaeGhaiRi8he4EiWasheev4faeku8tohdiuthah7zahP"
2022-10-18 21:00:28 +00:00
client_id = "solarmonitor"
2022-10-18 20:38:02 +00:00
2022-10-19 06:40:32 +00:00
client = mqtt_client.Client(client_id, protocol=paho.MQTTv31)
client.username_pw_set(username, password=pw)
2022-10-18 21:00:28 +00:00
client.on_connect = on_connect
client.on_message = on_message
2022-10-18 20:38:02 +00:00
2022-10-19 06:40:32 +00:00
client.connect(broker, port=port)
2022-10-18 20:38:02 +00:00
2022-10-18 21:00:28 +00:00
client.loop_start() #start the loop
while Connected != True: #Wait for connection
2022-10-19 06:44:21 +00:00
time.sleep(1)
2022-10-18 20:38:02 +00:00
2022-10-19 07:07:32 +00:00
client.subscribe(topic_wHouseConsumption)
client.subscribe(topic_pvProduction)
client.subscribe(topic_energyImportExport)
client.subscribe(topic_houseBatterySoC)
client.subscribe(topic_wHouseCtopic_houseBatteryLoadUnloadonsumption)
2022-10-18 20:38:02 +00:00
2022-10-18 21:00:28 +00:00
try:
while True:
time.sleep(1)
except KeyboardInterrupt:
2022-10-18 21:01:15 +00:00
print("exiting")
2022-10-18 21:00:28 +00:00
client.disconnect()
client.loop_stop()