linspector/uplink
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

added error handling when database connection fails

Browse source
This commit is contained in:
Johannes Findeisen 2020-10-05 01:24:01 +02:00
commit 1db29f56d2
1 changed files with 10 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

15
uplink
View file

@ -107,10 +107,15 @@ def get_data(config, inc):
#conn = sqlite3.connect(config["database"]) #conn = sqlite3.connect(config["database"])
#c = conn.cursor() #c = conn.cursor()
con = pymysql.connect(config["database_host"], try:
config["database_user"], con = pymysql.connect(config["database_host"],
config["database_password"], config["database_user"],
config["database"]) config["database_password"],
config["database"])
except Exception as err:
logger.error("ERROR: Database connection failed!" + str(err))
#thread.interrupt_main()
os._exit(1)
#for i in range(len(config["uplinks"])): #for i in range(len(config["uplinks"])):
timestamp = calendar.timegm(time.gmtime()) timestamp = calendar.timegm(time.gmtime())
@ -132,7 +137,7 @@ def get_data(config, inc):
with con.cursor() as cur: with con.cursor() as cur:
cur.execute(sql) cur.execute(sql)
con.commit() con.commit()
exit() exit(1)
if fc.is_connected: if fc.is_connected:
status = "UP" status = "UP"