change calling
This commit is contained in:
parent
0103569345
commit
f769139ed4
@ -38,22 +38,37 @@ topic_car_soc = "openWB/vehicle/4/get/soc"
|
|||||||
topic_charge_point_power = "openWB/internal_chargepoint/0/get/powers"
|
topic_charge_point_power = "openWB/internal_chargepoint/0/get/powers"
|
||||||
|
|
||||||
|
|
||||||
try:
|
def connect_mqtt():
|
||||||
# create the MQTT client
|
def on_connect(client, userdata, flags, rc):
|
||||||
client = mqtt_client.Client(client_id, protocol=mqtt_client.MQTTv31) # * set a random string (max 23 chars)
|
if rc == 0:
|
||||||
|
logging.info("Connected to MQTT Broker!")
|
||||||
|
else:
|
||||||
|
logging.info("Failed to connect, return code %d\n", rc)
|
||||||
|
|
||||||
# client connection
|
client = mqtt_client.Client(client_id)
|
||||||
# client.username_pw_set(mqtt_username, mqtt_password) # MQTT server credentials
|
# client.username_pw_set(username, password)
|
||||||
client.connect(mqtt_broker, 1883, 60) # MQTT server address
|
client.on_connect = on_connect
|
||||||
|
client.connect(broker, port)
|
||||||
|
return client
|
||||||
|
|
||||||
house_battery_soc = client.subscribe(topic_house_battery_soc)
|
|
||||||
house_battery_power = client.subscribe(topic_house_battery_power)
|
|
||||||
power_import_export = client.subscribe(topic_power_import_export)
|
|
||||||
pv_power = client.subscribe(topic_pv_power)
|
|
||||||
house_power = client.subscribe(topic_house_power)
|
|
||||||
car_soc = client.subscribe(topic_car_soc)
|
|
||||||
charge_point_power = client.subscribe(topic_charge_point_power)
|
|
||||||
|
|
||||||
|
def subscribe(client: mqtt_client, topic):
|
||||||
|
def on_message(client, userdata, msg):
|
||||||
|
print(f"Received `{msg.payload.decode()}` from `{msg.topic}` topic")
|
||||||
|
|
||||||
|
client.subscribe(topic)
|
||||||
|
client.on_message = on_message
|
||||||
|
|
||||||
|
|
||||||
|
def run():
|
||||||
|
client = connect_mqtt()
|
||||||
|
house_battery_soc = subscribe(topic_house_battery_soc)
|
||||||
|
house_battery_power = subscribe(topic_house_battery_power)
|
||||||
|
power_import_export = subscribe(topic_power_import_export)
|
||||||
|
pv_power = subscribe(topic_pv_power)
|
||||||
|
house_power = subscribe(topic_house_power)
|
||||||
|
car_soc = subscribe(topic_car_soc)
|
||||||
|
charge_point_power = subscribe(topic_charge_point_power)
|
||||||
|
|
||||||
logging.info("epd2in13b_V3 Demo")
|
logging.info("epd2in13b_V3 Demo")
|
||||||
|
|
||||||
@ -89,11 +104,18 @@ try:
|
|||||||
|
|
||||||
logging.info("Goto Sleep...")
|
logging.info("Goto Sleep...")
|
||||||
epd.sleep()
|
epd.sleep()
|
||||||
|
|
||||||
|
client.loop_forever()
|
||||||
|
|
||||||
|
|
||||||
|
if __name__ == '__main__':
|
||||||
|
run()
|
||||||
|
|
||||||
|
|
||||||
except IOError as e:
|
#except IOError as e:
|
||||||
logging.info(e)
|
# logging.info(e)
|
||||||
|
|
||||||
except KeyboardInterrupt:
|
#except KeyboardInterrupt:
|
||||||
logging.info("ctrl + c:")
|
# logging.info("ctrl + c:")
|
||||||
epd2in13b_V3.epdconfig.module_exit()
|
# epd2in13b_V3.epdconfig.module_exit()
|
||||||
exit()
|
# exit()
|
||||||
|
Loading…
Reference in New Issue
Block a user