identtg
Simon 4 years ago
parent 04b38c92c1
commit f23dcb3f3c
No known key found for this signature in database
GPG Key ID: 6ACF11630B5D8F82

@ -77,12 +77,11 @@ class reportClient(NetstringReceiver):
while not self.db.is_connected(): while not self.db.is_connected():
self.db.reconnect() 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() _cursor = self.db.cursor()
try: 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'])) _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() self.db.commit()
#print("{} {} {} {} {} {} {} {} {}".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration']))
except mysql.connector.Error as err: except mysql.connector.Error as err:
_cursor.close() _cursor.close()
print('(MYSQL) error, problem with cursor execute: {}'.format(err)) print('(MYSQL) error, problem with cursor execute: {}'.format(err))

Loading…
Cancel
Save

Powered by TurnKey Linux.