Skip to content

M
MQTT
Commit 23d10848 authored by kranthi.kumar's avatar kranthi.kumar
Browse files
Options

Update mqtt_publish_subscribe.py

parent 1107a5e5
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 4 deletions
Scripts/core/mqtt_publish_subscribe.py
View file @ 23d10848
import csv import csv,logging,time
import logging
import time
class Mqtt_Publish: class Mqtt_Publish:
...@@ -33,7 +31,7 @@ class Mqtt_Publish: ...@@ -33,7 +31,7 @@ class Mqtt_Publish:
list_kva.append({"Timestamp": row["Timestamp"], "Value": row['kVA']}) list_kva.append({"Timestamp": row["Timestamp"], "Value": row['kVA']})
list_current.append({"Timestamp": row["Timestamp"], "Value": row['current']}) list_current.append({"Timestamp": row["Timestamp"], "Value": row['current']})
except Exception : except Exception :
logging.exception("Exception occurred in connection", exc_info=True) logging.exception("Exception occurred in opening of file", exc_info=True)
client.loop_start() client.loop_start()
if choice == "kwh": if choice == "kwh":
client.subscribe("Kwh") client.subscribe("Kwh")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment