Python SysLogHandler over TCP：接続損失の処理

Question

logging.SyslogHandlerを使用してTCP経由でsyslogサーバにログを送信するプロセスがあります。 残念ながら、何らかの理由でSyslogサーバが再起動した場合、プロセスはログの送信を停止し、接続を再確立できません。

誰かがこの動作を克服し、logging.SyslogHandlerに強制的に接続を再確立させる方法を知っているのだろうかと思っていました。

コードハンドラを使用するためには、のようになります。

import logging 
import logging.handlers 
import logging.config 

logging.config.fileConfig('logging.cfg') 
logging.debug("debug log message") 

logging.cfg：

[loggers] 
keys=root,remote 

[handlers] 
keys=local,remote 

[logger_remote] 
qualname=remote 
level=INFO 
handlers=remote 

[logger_root] 
qualname=root 
level=DEBUG 
handlers=local 

[handler_local] 
class=handlers.StreamHandler 
level=DEBUG 
formatter=local 
args=(sys.stdout,) 

[handler_remote] 
class=handlers.SysLogHandler 
level=DEBUG 
formatter=remote 
args=(('localhost', 514), handlers.SysLogHandler.LOG_USER, 1) 

[formatters] 
keys=local,remote 

[formatter_local] 
format=%(module)s %(levelname)s %(message)s 

[formatter_remote] 
format=%(asctime)s %(message)s 

私はsyslogサーバの再起動後に取得しておくエラーは、次のとおりです。

Traceback (most recent call last): 
    File "/usr/local/lib/python2.7/logging/handlers.py", line 866, in emit 
    self.socket.sendall(msg) 
    File "/usr/local/lib/python2.7/socket.py", line 228, in meth 
    return getattr(self._sock,name)(*args) 
error: [Errno 32] Broken pipe 

私はどんな洞察にも感謝します。 ありがとう！

Answer 1

エラーがないかどうかを確認して、接続が正常に表示されたら再確立する必要があるようです。以下を試してください：

try: 
    logging.debug("debug log message") 
except IOError, e: 
    if e.errno == 32: 
     logging.config.fileConfig('logging.cfg') 
     logging.debug("debug log message") 

Answer 2

私はこの同じ問題に遭遇しました。私は壊れたパイプの例外を処理し、ソケットを再作成するカスタムハンドラを書く必要がありました。 「514個のポートを使用することができ、あなたに告げこんにちは私のルート友人どのように？ですか？（ターゲットのみではなく、ソースとして使用することができます）」

class ReconnectingSysLogHandler(logging.handlers.SysLogHandler):     
    """Syslog handler that reconnects if the socket closes      

    If we're writing to syslog with TCP and syslog restarts, the old TCP socket 
    will no longer be writeable and we'll get a socket.error of type 32. When 
    than happens, use the default error handling, but also try to reconnect to 
    the same host/port used before. Also make 1 attempt to re-send the   
    message.                  
    """                   
    def __init__(self, *args, **kwargs):           
     super(ReconnectingSysLogHandler, self).__init__(*args, **kwargs)   
     self._is_retry = False             

    def _reconnect(self):              
     """Make a new socket that is the same as the old one"""     
     # close the existing socket before getting a new one to the same host/port 
     if self.socket:               
      self.socket.close()             

     # cut/pasted from logging.handlers.SysLogHandler       
     if self.unixsocket:              
      self._connect_unixsocket(self.address)        
     else:                 
      self.socket = socket.socket(socket.AF_INET, self.socktype)   
      if self.socktype == socket.SOCK_STREAM:        
       self.socket.connect(self.address)        

    def handleError(self, record):            
     # use the default error handling (writes an error message to stderr)  
     super(ReconnectingSysLogHandler, self).handleError(record)    

     # If we get an error within a retry, just return. We don't want an  
     # infinite, recursive loop telling us something is broken.    
     # This leaves the socket broken.           
     if self._is_retry:              
      return                

     # Set the retry flag and begin deciding if this is a closed socket, and 
     # trying to reconnect.             
     self._is_retry = True             
     try:                  
      __, exception, __ = sys.exc_info()         
      # If the error is a broken pipe exception (32), get a new socket. 
      if isinstance(exception, socket.error) and exception.errno == 32: 
       try:                
        self._reconnect()           
       except:               
        # If reconnecting fails, give up.       
        pass               
       else:               
        # Make an effort to rescue the recod.      
        self.emit(record)           
     finally:                 
      self._is_retry = False