28 lines
843 B
Python
28 lines
843 B
Python
#!/usr/bin/env python3
|
|
|
|
import paho.mqtt.client as mqtt
|
|
import paho.mqtt.subscribe as subscribe
|
|
from time import sleep
|
|
import requests
|
|
|
|
|
|
sdm630_host = '100.64.0.187'
|
|
mqtt_host = '{{ mqtt_internal_host }}'
|
|
|
|
|
|
client = mqtt.Client()
|
|
client.connect(mqtt_host, 1883, 60)
|
|
client.loop_start()
|
|
|
|
while True:
|
|
sleep(10)
|
|
try:
|
|
data = requests.get(f'http://{sdm630_host}/api/v1/data').json()
|
|
client.publish('bitlair/power/total_kwh', data['total_power_import_kwh'])
|
|
client.publish('bitlair/power/All/now_w', data['active_power_w'])
|
|
client.publish('bitlair/power/L1/now_w', data['active_power_l1_w'])
|
|
client.publish('bitlair/power/L2/now_w', data['active_power_l2_w'])
|
|
client.publish('bitlair/power/L3/now_w', data['active_power_l3_w'])
|
|
except Exception as err:
|
|
print(err)
|
|
continue
|