71 lines
2.6 KiB
Python
Executable file
71 lines
2.6 KiB
Python
Executable file
#!/usr/bin/python3 -d
|
|
|
|
import calendar
|
|
import datetime
|
|
# import daemon
|
|
import json
|
|
import logging
|
|
import logging.handlers
|
|
import os
|
|
import os.path as path
|
|
import sqlite3
|
|
import time
|
|
|
|
from fritzconnection.lib.fritzstatus import FritzStatus
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
def get_data(config):
|
|
conn = sqlite3.connect(config["database"])
|
|
c = conn.cursor()
|
|
for i in range(len(config["uplinks"])):
|
|
timestamp = calendar.timegm(time.gmtime())
|
|
fc = FritzStatus(address=config["uplinks"][i]["ip"], password=config["uplinks"][i]["password"])
|
|
if fc.is_connected:
|
|
status = "UP"
|
|
else:
|
|
status = "DOWN"
|
|
|
|
logger.info(config["uplinks"][i]["provider"] + ": " + status)
|
|
sql = 'INSERT INTO log (datetime, uptime, external_ip, external_ipv6,is_linked,is_connected, ' \
|
|
'str_transmission_rate_up, str_transmission_rate_down, str_max_bit_rate_up, str_max_bit_rate_down, ' \
|
|
'str_max_linked_bit_rate_up, str_max_linked_bit_rate_down, modelname, system_version) VALUES (\"' + \
|
|
str(timestamp) + '\",\"' + str(fc.uptime) + '\",\"' + str(fc.external_ip) + '\",\"' + \
|
|
str(fc.external_ipv6) + '\",\"' + str(int(fc.is_linked)) + '\",\"' + \
|
|
str(int(fc.is_connected)) + '\",\"' + str(fc.str_transmission_rate[0]) + '\",\"' + \
|
|
str(fc.str_transmission_rate[1]) + '\",\"' + str(fc.str_max_bit_rate[0]) + '\",\"' + \
|
|
str(fc.str_max_bit_rate[1]) + '\",\"' + str(fc.str_max_linked_bit_rate[0]) + '\",\"' + \
|
|
str(fc.str_max_linked_bit_rate[1]) + '\",\"' + str(fc.modelname) + '\",\"' + \
|
|
str(fc.fc.system_version) + '\")'
|
|
logging.debug(sql)
|
|
c.execute(sql)
|
|
conn.commit()
|
|
conn.close()
|
|
|
|
|
|
def run(config):
|
|
# with daemon.DaemonContext():
|
|
while True:
|
|
get_data(config)
|
|
time.sleep(config["interval"])
|
|
|
|
|
|
if __name__ == "__main__":
|
|
with open('config.json', 'r') as configfile:
|
|
config_data = configfile.read()
|
|
_config = json.loads(config_data)
|
|
|
|
logfile = path.expanduser(_config["logdir"])
|
|
if not path.exists(path.dirname(logfile)):
|
|
os.makedirs(path.dirname(logfile))
|
|
|
|
root_logger = logging.getLogger()
|
|
formatter = logging.Formatter("%(asctime)s:%(levelname)s:%(name)s:%(message)s")
|
|
handler = logging.handlers.RotatingFileHandler(logfile, maxBytes=_config["logsize"],
|
|
backupCount=_config["logcount"])
|
|
handler.setFormatter(formatter)
|
|
root_logger.addHandler(handler)
|
|
root_logger.setLevel(_config["loglevel"])
|
|
|
|
run(_config)
|