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):