identtg
Simon 4 years ago
parent 0739aecf58
commit 8f71710e57

@ -79,8 +79,12 @@ class reportClient(NetstringReceiver):
def send_mysql(self,event): def send_mysql(self,event):
while not self.db.is_connected(): while not self.db.is_connected():
self.db.reconnect() 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'])) 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() _cursor = self.db.cursor()
try: try:

Loading…
Cancel
Save

Powered by TurnKey Linux.