Twisted Python의 SMTP 모듈을 사용한 리소스 정리

Question

이것은 이전에 대답 한 질문과 관련이 있습니다. Logging SMTP connections with Twisted. ConsoleMessageDelivery의 각 인스턴스에서 데이터베이스 리소스를 만들면 소켓을 닫을 때 정리해야합니다. DenyFactory라는 WrappingFactory가 있고 DenyFactory.unregisterProtocol 메서드는 소켓을 닫을 때 호출되지만 파괴되는 ConsoleMessageDelivery 인스턴스에서 생성 된 리소스에 액세스하는 방법이 없습니다. ConsoleMessageDelivery에서 del() 메서드를 시도했지만 결코 호출되지 않았습니다. 이 시나리오에서 리소스를 정리하는 가장 좋은 방법은 무엇입니까?

class ConsoleMessageDelivery: 
    implements(smtp.IMessageDelivery) 

    def receivedHeader(self, helo, origin, recipients): 
     myHostname, clientIP = helo 
     headerValue = "by %s from %s with ESMTP ; %s" % (myHostname, clientIP, smtp.rfc822date()) 
     # email.Header.Header used for automatic wrapping of long lines 
     return "Received: %s" % Header(headerValue) 

    def validateFrom(self, helo, origin): 
     # All addresses are accepted 
     return origin 

    def validateTo(self, user): 
     if user.dest.local == "console": 
      return lambda: ConsoleMessage() 
     raise smtp.SMTPBadRcpt(user) 

class ConsoleMessage: 
    implements(smtp.IMessage) 

    def __init__(self): 
     self.lines = [] 

    def lineReceived(self, line): 
     self.lines.append(line) 

    def eomReceived(self): 
     return defer.succeed(None) 

    def connectionLost(self): 
     # There was an error, throw away the stored lines 
     self.lines = None 

class ConsoleSMTPFactory(smtp.SMTPFactory): 
    protocol = smtp.ESMTP 

    def __init__(self, *a, **kw): 
     smtp.SMTPFactory.__init__(self, *a, **kw) 
     self.delivery = ConsoleMessageDelivery() 

    def buildProtocol(self, addr): 
     p = smtp.SMTPFactory.buildProtocol(self, addr) 
     p.delivery = self.delivery 
     return p 

class DenyFactory(WrappingFactory): 

    def buildProtocol(self, clientAddress): 
     if clientAddress.host == '1.3.3.7': 
      # Reject it 
      return None 
     # Accept everything else 
     return WrappingFactory.buildProtocol(self, clientAddress) 

    def unregisterProtocol(self, p): 
     print "Unregister called" 

Answer 1

특히, 정리할 리소스가있는 경우 __del__을 사용하지 마십시오. __del__은 참조주기에서 오브젝트의 가비지 콜렉션을 방지합니다. (또는 사이클의 객체 컬렉션에 임의의 순서를 지정하여 이러한 객체를 수집 할 수있는 PyPy로 전환하십시오.) 다음으로 메시지 전달 팩토리에서 데이터베이스 연결을 열거 나 연결 풀을 시작하고 모든 메시지 전달 객체간에이를 공유합니다. 이렇게하면 연결을 정리할 필요가 없습니다. 이후 메시지에 다시 사용하고 각 메시지에 대해 새 메시지를 할당하지 않으므로 누출이 없습니다.

마지막으로 트랜잭션 당 개체가 실제로 필요한 경우 IMessage 개체의 eomReceived 또는 connectionLost 구현에서 정리할 수 있습니다. SMTP 트랜잭션의 DATA 부분이 완료되면 (모든 데이터가 수신되었거나 연결이 끊어 졌기 때문에)이 메서드 중 하나가 호출됩니다. SMTP는 단일 트랜잭션에서 여러 수신자에게 메시지 배달을 지원하기 때문에 하나의 IMessageDelivery 개체 만 존재하더라도 IMessage 개체가 여러 개 참여할 수 있습니다. 따라서 메시지 개체에 대한 eomReceived/connectionLost 호출의 메시지 배달 개체에서 성공적인 validateTo 호출에 대한 호출 횟수를 카운터 매치로 유지하려고 할 수 있습니다. 각각의 동일한 전화 번호가 발생한 경우 트랜잭션이 완료됩니다.