diff --git a/report_sql.py b/report_sql.py index 794ebc2..1c5c330 100644 --- a/report_sql.py +++ b/report_sql.py @@ -79,8 +79,12 @@ class reportClient(NetstringReceiver): def send_mysql(self,event): - while not self.db.is_connected(): - self.db.reconnect() + while not self.db.is_connected(): + try: + self.db.reconnect() + except mysql.connector.Error as err: + print('(MYSQL) error on reconnect: {}'.format(err)) + 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: