Commit 51189a09 authored by ajil.k's avatar ajil.k

updated

parent 4f3b07a2
...@@ -5,3 +5,4 @@ port_no = 8000 ...@@ -5,3 +5,4 @@ port_no = 8000
broker = 192.168.0.220 broker = 192.168.0.220
port = 1883 port = 1883
time_out = 60 time_out = 60
topic = Website/data
\ No newline at end of file
...@@ -10,6 +10,7 @@ try: ...@@ -10,6 +10,7 @@ try:
broker = config.get("MQTT_Connection", "broker") broker = config.get("MQTT_Connection", "broker")
mqtt_port = config.get("MQTT_Connection", "port") mqtt_port = config.get("MQTT_Connection", "port")
time_out = config.get("MQTT_Connection", "time_out") time_out = config.get("MQTT_Connection", "time_out")
topic = config.get("MQTT_Connection", "topic")
except Exception as e: except Exception as e:
logger.error(e) logger.error(e)
import json import json
import time import time
from scripts.constants.application_config import topic
from scripts.constants.mqtt_connection import mqtt_client_connection from scripts.constants.mqtt_connection import mqtt_client_connection
from scripts.logging.logger import logger from scripts.logging.logger import logger
...@@ -20,8 +22,6 @@ class Publishing: ...@@ -20,8 +22,6 @@ class Publishing:
"site_id": site_id, "site_id": site_id,
"data_quality": data_quality "data_quality": data_quality
} }
self.mqtt_client.connect("192.168.0.220", 1883, 60)
topic = "Website/data"
self.mqtt_client.publish(topic, json.dumps(message)) self.mqtt_client.publish(topic, json.dumps(message))
time.sleep(10) time.sleep(10)
return "Data Published" return "Data Published"
......
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