Twisted-Server abstürzt nach einem Tag

Question

Ich schrieb einen Udp Twisted Server und lief es mit dem folgenden Befehl:

nohup python Udpserver2.py & 

Es ging gut auf dem ersten, aber es brachte einen Fehler und stürzte nach dem 1. Tag. Die Fehlerinformationen in nohup.out ist:

Unhandled Error 
Traceback (most recent call last): 
    File "/usr/lib64/python2.7/site-packages/Twisted-15.4.0-py2.7-linux-x86_64.egg/twisted/python/log.py", line 84, in callWithContext 
    return context.call({ILogContext: newCtx}, func, *args, **kw) 
    File "/usr/lib64/python2.7/site-packages/Twisted-15.4.0-py2.7-linux-x86_64.egg/twisted/python/context.py", line 118, in callWithContext 
    return self.currentContext().callWithContext(ctx, func, *args, **kw) 
    File "/usr/lib64/python2.7/site-packages/Twisted-15.4.0-py2.7-linux-x86_64.egg/twisted/python/context.py", line 81, in callWithContext 
    return func(*args,**kw) 
    File "/usr/lib64/python2.7/site-packages/Twisted-15.4.0-py2.7-linux-x86_64.egg/twisted/internet/posixbase.py", line 597, in _doReadOrWrite 
    why = selectable.doRead() 
--- <exception caught here> --- 
    File "/usr/lib64/python2.7/site-packages/Twisted-15.4.0-py2.7-linux-x86_64.egg/twisted/internet/udp.py", line 248, in doRead 
    self.protocol.datagramReceived(data, addr) 
    File "UdpServer2.py", line 91, in datagramReceived 
    self.device_echo(data, str(host), int(port)) 
    File "UdpServer2.py", line 19, in device_echo 
    cur.execute(sql) 
    File "/usr/lib64/python2.7/site-packages/MySQLdb/cursors.py", line 174, in execute 
    self.errorhandler(self, exc, value) 
    File "/usr/lib64/python2.7/site-packages/MySQLdb/connections.py", line 36, in defaulterrorhandler 
    raise errorclass, errorvalue 
_mysql_exceptions.OperationalError: (2006, 'MySQL server has gone away') 

Mein Python-Code UdpServer2.py ist wie folgt strukturiert:

from twisted.internet.protocol import DatagramProtocol 
from twisted.internet import reactor 
import MySQLdb as mdb 

conn = mdb.connect(host='localhost', user='root', passwd='123456', db='kj') 

class KjEcho(DatagramProtocol): 
    def device_echo(self, msg, host, port): 
     device_no = msg[1:7] 
     sql = "select did from device where device_no='%s'" % (device_no) 

     cur = conn.cursor(mdb.cursors.DictCursor) 
     cur.execute(sql)          #line 19 here 

     if 0 == cur.rowcount: 
      ... 
     else: 
      ... 
     cur.close() 

    def startProtocol(self): 
     print 'kj_udp_server starting...' 

    def datagramReceived(self, data, (host, port)): 
     print "receive msg" 
     if(18 != len(data)): 
      print 'len err' 
      return 
     if('0x86' != hex(ord(data[0]))): 
      print '0x86 err' 
      return 
     if(0 == ord(data[15])): 
      print 'from device' 
      self.device_echo(data, str(host), int(port))  #line 91 here 
     else: 
      print 'from mobile' 
      self.mobile_echo(data, str(host), int(port)) 

reactor.listenUDP(6000, KjEcho()) 
reactor.run() 

Linie 91 und Linie 19 sind die Gründe, oben angedeutet, wie man es beheben, danke.

HINWEIS: viele Maschine Es gibt jede Maschine eine Nachricht an den Server können Sie nicht für nicht spezifizierte Zeit auf MySQL-Verbindung (oder eine Buchse für diese Angelegenheit) noch am Leben Relais alle 20 Sekunden

Answer 1

senden, vor allem, wenn keine Daten fließen. Anstatt also eine Verbindung zu verwenden, die Sie einfach zum Abrufen des Cursors verwenden, schließen Sie die Verbindung mit dem Cursor und öffnen Sie sie erneut, wenn Sie sie benötigen.

Also im Grunde wollen Sie diese Zeile

cur = conn.cursor(mdb.cursors.DictCursor) 

Mit einem Präfix, das die conn setzt und dann fügen Sie die folgende

cur.close() 

mit einem, der die conn schließt, höchstwahrscheinlich conn.close().

Answer 2

Vielen Dank, Mai und Tymoteusz Paul

class KjEcho(DatagramProtocol): 
    def device_echo(self, msg, host, port): 
     device_no = msg[1:7] 
     sql = "select did from device where device_no='%s'" % (device_no) 

     conn = mdb.connect(host='localhost', user='root', passwd='123456', db='kj') 
     cur = conn.cursor(mdb.cursors.DictCursor) 
     cur.execute(sql) 

     if 0 == cur.rowcount: 
      ... 
     else: 
      ... 
     cur.close() 
     conn.close() 

ich denke, es wird gut, aber für die Verbindung geöffnet und geschlossen häufig es, ist es besser Connection Pool zu benutzen?