From d8e87485c68cdfb461bde36e9d5eb95317a528a5 Mon Sep 17 00:00:00 2001 From: Simon Date: Fri, 22 Apr 2022 00:28:15 +0100 Subject: [PATCH] all --- report_sql.py | 22 ++++++++++------------ 1 file changed, 10 insertions(+), 12 deletions(-) diff --git a/report_sql.py b/report_sql.py index 743b9b5..08bf1a0 100644 --- a/report_sql.py +++ b/report_sql.py @@ -73,18 +73,16 @@ class reportClient(NetstringReceiver): if len(datalist) > 9: event['duration'] = datalist[9] - if event['event'] == 'END' and event['trx'] == 'RX': - - while not self.db.is_connected(): - self.db.reconnect() - print("{} {} {} {} {} {} {} {} {}".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration'])) - _cursor = self.db.cursor() - try: - _cursor.execute("insert into feed values (NULL,'{}','{}','{}','{}','{}','{}','{}','{}','{}','{}')".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration'])) - self.db.commit() - except mysql.connector.Error as err: - _cursor.close() - print('(MYSQL) error, problem with cursor execute: {}'.format(err)) + while not self.db.is_connected(): + self.db.reconnect() + print("{} {} {} {} {} {} {} {} {}".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration'])) + _cursor = self.db.cursor() + try: + _cursor.execute("insert into feed values (NULL,'{}','{}','{}','{}','{}','{}','{}','{}','{}','{}')".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration'])) + self.db.commit() + except mysql.connector.Error as err: + _cursor.close() + print('(MYSQL) error, problem with cursor execute: {}'.format(err)) def bridgeSend(self,data):