Update SQL loader

4 years ago · b072f89bdb
parent b14fa1fb61
commit b072f89bdb
1 changed files with 6 additions and 4 deletions
--- a/report_sql.py
+++ b/report_sql.py
@ -68,10 +68,12 @@ class reportClient(NetstringReceiver):
            'subid'     : datalist[6],
            'slot'      : datalist[7],
            'dstid'     : datalist[8],
-            'duration'  : 0
+            'duration'  : 0,
+            'source_server': 0,
+            'source_rptr': 0
             }

-        if len(datalist) > 9:
+        if len(datalist) > 11:
            event['duration'] = datalist[9]
        
        
@ -86,10 +88,10 @@ 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']))
+        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']))
+            _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']))
            self.db.commit()
        except mysql.connector.Error as err:
            _cursor.close()