diff --git a/ajaxmonit.py b/ajaxmonit.py index 04aaec7..243a990 100755 --- a/ajaxmonit.py +++ b/ajaxmonit.py @@ -77,12 +77,12 @@ if __name__ == "__main__": COOKIES = login() while True: START1 = datetime.now() - print(datetime.now(), "Request page") + #print(datetime.now(), "Request page") REQ = page_cable_settings(COOKIES) - print(datetime.now(), "Got page") + #print(datetime.now(), "Got page") START2 = datetime.now() - print(datetime.now(), "Started parsing") + #print(datetime.now(), "Started parsing") UTS = (datetime.strptime(REQ.headers['Date'], '%a, %d %b %Y %H:%M:%S %Z') + timedelta(hours=1) ).strftime('%Y-%m-%d %H:%M:%S') @@ -105,36 +105,36 @@ if __name__ == "__main__": if MATCHES: CHANNEL[FIELD] = MATCHES.group(3).replace(' dBmV', '').replace(' MHz', '') UP.append(CHANNEL) - print(datetime.now(), "Ended parsing") + #print(datetime.now(), "Ended parsing") START3 = datetime.now() CNX = dbconnect() CURSOR = CNX.cursor() - print(datetime.now(), "Connected to DB") + #print(datetime.now(), "Connected to DB") for ITEM in DOWN: - #try: - CURSOR.execute(INSERT, (UTS, 0, - ITEM['rx_id_val_dn'], - ITEM['freq_val_dn'], - ITEM['power_val_dn'], - ITEM['snr_val_dn'])) - #except mysql.connector.IntegrityError as err: - # pass + try: + CURSOR.execute(INSERT, (UTS, 0, + ITEM['rx_id_val_dn'], + ITEM['freq_val_dn'], + ITEM['power_val_dn'], + ITEM['snr_val_dn'])) + except KeyError as err: + pass for ITEM in UP: - #try: - CURSOR.execute(INSERT, (UTS, 1, - ITEM['cannel_id_val_up'], - ITEM['freq_val_up'], - ITEM['power_val_up'], None)) - #except mysql.connector.IntegrityError, KeyError as err: - # pass + try: + CURSOR.execute(INSERT, (UTS, 1, + ITEM['cannel_id_val_up'], + ITEM['freq_val_up'], + ITEM['power_val_up'], None)) + except KeyError as err: + pass CNX.commit() CURSOR.close() CNX.close() - print(datetime.now(), "DB connection closed") + #print(datetime.now(), "DB connection closed") END = datetime.now() DELTA1 = START2 - START1 @@ -145,5 +145,5 @@ if __name__ == "__main__": DELTA1.total_seconds() * 1000, DELTA2.total_seconds() * 1000, DELTA3.total_seconds() * 1000)) - print(datetime.now(), "Sleeping\n") + #print(datetime.now(), "Sleeping\n") time.sleep(30)