From f6a0b57a071a57a0853899e1191e18fad690b1d0 Mon Sep 17 00:00:00 2001 From: Simon Date: Sat, 21 May 2022 23:43:51 +0100 Subject: [PATCH] reporty --- report_sql.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/report_sql.py b/report_sql.py index 4c055a5..6fe3435 100644 --- a/report_sql.py +++ b/report_sql.py @@ -69,8 +69,8 @@ class reportClient(NetstringReceiver): 'slot' : datalist[7], 'dstid' : datalist[8], 'duration' : 0, - 'source_server': 0, - 'source_rptr': 0 + 'source_server': datalist[-2], + 'source_rptr': datalist[-1] } if len(datalist) > 11: @@ -88,7 +88,7 @@ class reportClient(NetstringReceiver): 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'], event['source_server'],event['source_rptr'])) + print("{} {} {} {} {} {} {} {} {} {} {} {}".format(event['type'],event['event'], event['trx'],event['system'],event['streamid'],event['peerid'],event['subid'],event['slot'],event['dstid'],event['duration'], event['source_server'],event['source_rptr'])) _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'],event['source_server'],event['source_rptr']))