py.lib

     1.1 --- a/log/slog_syslogger.py	Tue Nov 12 21:28:23 2019 +0300
     1.2 +++ b/log/slog_syslogger.py	Fri Jul 24 14:40:37 2020 +0300
     1.3 @@ -1,99 +1,145 @@
     1.4 -# coding: utf-8
     1.5 -"""
     1.6 -Тривиальная реализация сислоггера без блэк-джека и поэтесс
     1.7 -
     1.8 -Метки в журнале о уровне сообщения:
     1.9 -  "`": Debug
    1.10 -  ".": Info
    1.11 -  "*": Warning
    1.12 -  "!": Error
    1.13 -  "#": Alert
    1.14 -
    1.15 -"""
    1.16 -from time import time
    1.17 -from datetime import timedelta
    1.18 -
    1.19 -import syslog
    1.20 -from traceback import extract_tb, extract_stack
    1.21 -from sys import exc_info
    1.22 -
    1.23 -
    1.24 -class Timing(object):
    1.25 -    def __init__(self, name=None):
    1.26 -        if name is None:
    1.27 -            self.prefix = ''
    1.28 -        else:
    1.29 -            self.prefix = '%s :: ' % name
    1.30 -        self.tsAll = time()
    1.31 -        self.ts = self.tsAll
    1.32 -
    1.33 -    def getTime(self):
    1.34 -        return time() - self.ts
    1.35 -
    1.36 -    def reset(self):
    1.37 -        self.ts = time()
    1.38 -        self.tsAll = self.ts
    1.39 -
    1.40 -    def __str__(self):
    1.41 -        ts = time()
    1.42 -        return self.prefix + '%s(%.4f)' % (timedelta(seconds=(ts - self.tsAll)), ts - self.ts)
    1.43 -
    1.44 -    def __call__(self, msg):
    1.45 -        _buf = '%s | %s' % (self, msg)
    1.46 -        self.ts = time()
    1.47 -        return _buf
    1.48 -
    1.49 -
    1.50 -class SimpleSysLogger(object):
    1.51 -    @staticmethod
    1.52 -    def initSyslog(ident):
    1.53 -        syslog.openlog(ident, syslog.LOG_PID)
    1.54 -
    1.55 -    @staticmethod
    1.56 -    def getTiming(name=None):
    1.57 -        return Timing(name)
    1.58 -
    1.59 -    def __init__(self, prefix, facility=syslog.LOG_USER):
    1.60 -        self.prefix = str(prefix)
    1.61 -        self.facility = facility
    1.62 -
    1.63 -    def _write(self, flag, mark, msg):
    1.64 -        for l in str(msg).splitlines():
    1.65 -            syslog.syslog(self.facility | flag, '%s: %s %s' % (self.prefix, mark, l))
    1.66 -
    1.67 -    def __call__(self, msg):
    1.68 -        self._write(syslog.LOG_INFO, '.', msg)
    1.69 -    
    1.70 -    def err(self, msg):
    1.71 -        self._write(syslog.LOG_ERR, '!', msg)
    1.72 -    
    1.73 -    def warn(self, msg):
    1.74 -        self._write(syslog.LOG_WARNING, '*', msg)
    1.75 -    
    1.76 -    def debug(self, msg):
    1.77 -        self._write(syslog.LOG_DEBUG, '`', msg)
    1.78 -
    1.79 -    def alert(self, msg):
    1.80 -        self._write(syslog.LOG_ALERT, '#', msg)
    1.81 -
    1.82 -    def sublog(self, prefix):
    1.83 -        return self.__class__('%s/%s' % (self.prefix, prefix), self.facility)
    1.84 -
    1.85 -    def excpt(self, msg, eClass=None, eObj=None, eTb=None, stack_skip=0):
    1.86 -        if eClass is None:
    1.87 -            eClass, eObj, eTb = exc_info()
    1.88 -        
    1.89 -        tbData_tb = list(extract_tb(eTb))[::-1]
    1.90 -        tbData_stack = list(extract_stack())[::-1][(2 + stack_skip):]
    1.91 -        self.err(msg)
    1.92 -        self.err('--- EXCEPTION ---')
    1.93 -        self.err(' %s (%s)' % (eClass.__name__, eObj))
    1.94 -        self.err('--- TRACEBACK ---')
    1.95 -        for _tbFile, _tbLine, _tbFunc, _tbText in tbData_tb:
    1.96 -            self.err('File: %s, line %s in %s' % (_tbFile, _tbLine, _tbFunc))
    1.97 -            self.err('   %s' % _tbText)
    1.98 -        self.err('>>> Exception Handler <<<')
    1.99 -        for _tbFile, _tbLine, _tbFunc, _tbText in tbData_stack:
   1.100 -            self.err('File: %s, line %s in %s' % (_tbFile, _tbLine, _tbFunc))
   1.101 -            self.err('   %s' % _tbText)
   1.102 -        self.err('--- END EXCEPTION ---')
   1.103 +# coding: utf-8
   1.104 +
   1.105 +"""\
   1.106 +Логирование в системный журнал Unix
   1.107 +
   1.108 +Метки в журнале о уровне сообщения:
   1.109 +  "`": Debug
   1.110 +  ".": Info
   1.111 +  "*": Warning
   1.112 +  "!": Error
   1.113 +  "#": Alert
   1.114 +"""
   1.115 +
   1.116 +import syslog
   1.117 +from sys import exc_info
   1.118 +from time import time
   1.119 +from traceback import extract_tb, extract_stack
   1.120 +from datetime import timedelta
   1.121 +
   1.122 +LOG_FACILITY = {
   1.123 +    'auth': syslog.LOG_AUTH,
   1.124 +    'authpriv': syslog.LOG_AUTH,
   1.125 +    'cron': syslog.LOG_CRON,
   1.126 +    'daemon': syslog.LOG_DAEMON,
   1.127 +    'ftp': syslog.LOG_DAEMON,
   1.128 +    'kern': syslog.LOG_KERN,
   1.129 +    'lpr': syslog.LOG_LPR,
   1.130 +    'mail': syslog.LOG_MAIL,
   1.131 +    'news': syslog.LOG_NEWS,
   1.132 +    'syslog': syslog.LOG_SYSLOG,
   1.133 +    'user': syslog.LOG_USER,
   1.134 +    'uucp': syslog.LOG_UUCP,
   1.135 +    'local0': syslog.LOG_LOCAL0,
   1.136 +    'local1': syslog.LOG_LOCAL1,
   1.137 +    'local2': syslog.LOG_LOCAL2,
   1.138 +    'local3': syslog.LOG_LOCAL3,
   1.139 +    'local4': syslog.LOG_LOCAL4,
   1.140 +    'local5': syslog.LOG_LOCAL5,
   1.141 +    'local6': syslog.LOG_LOCAL6,
   1.142 +    'local7': syslog.LOG_LOCAL7
   1.143 +}
   1.144 +
   1.145 +class LoggerError(Exception): pass
   1.146 +
   1.147 +
   1.148 +# --- INTERFACE --- #
   1.149 +FACILITY = LOG_FACILITY['user']
   1.150 +
   1.151 +
   1.152 +def log_prep(ident, facility='user'):
   1.153 +    global FACILITY
   1.154 +    if not facility.lower() in LOG_FACILITY:
   1.155 +        raise LoggerError('Unknown facility')
   1.156 +
   1.157 +    syslog.openlog(ident, syslog.LOG_PID)
   1.158 +
   1.159 +    FACILITY = LOG_FACILITY[facility]
   1.160 +
   1.161 +
   1.162 +class Timing(object):
   1.163 +    def __init__(self, name=None):
   1.164 +        if name is None:
   1.165 +            self.prefix = ''
   1.166 +        else:
   1.167 +            self.prefix = '%s :: ' % name
   1.168 +        self.tsAll = time()
   1.169 +        self.ts = self.tsAll
   1.170 +
   1.171 +    def getTime(self):
   1.172 +        return time() - self.ts
   1.173 +
   1.174 +    def reset(self):
   1.175 +        self.ts = time()
   1.176 +        self.tsAll = self.ts
   1.177 +
   1.178 +    def __str__(self):
   1.179 +        ts = time()
   1.180 +        return self.prefix + '%s(%.4f)' % (timedelta(seconds=(ts - self.tsAll)), ts - self.ts)
   1.181 +
   1.182 +    def __call__(self, msg):
   1.183 +        _buf = '%s | %s' % (self, msg)
   1.184 +        self.ts = time()
   1.185 +        return _buf
   1.186 +
   1.187 +
   1.188 +class SysLogger(object):
   1.189 +    init_log = log_prep
   1.190 +
   1.191 +    @staticmethod
   1.192 +    def get_timing(name=None):
   1.193 +        return Timing(name)
   1.194 +
   1.195 +    def __init__(self, prefix, facility=FACILITY):
   1.196 +        self.prefix = str(prefix)
   1.197 +        self.facility = facility
   1.198 +
   1.199 +    def _write(self, flag, mark, msg):
   1.200 +        for l in str(msg).splitlines():
   1.201 +            syslog.syslog(self.facility | flag, '%s: %s %s' % (self.prefix, mark, l))
   1.202 +
   1.203 +    def __call__(self, msg):
   1.204 +        self._write(syslog.LOG_INFO, '.', msg)
   1.205 +
   1.206 +    def err(self, msg):
   1.207 +        self._write(syslog.LOG_ERR, '!', msg)
   1.208 +
   1.209 +    def warn(self, msg):
   1.210 +        self._write(syslog.LOG_WARNING, '*', msg)
   1.211 +
   1.212 +    def debug(self, msg):
   1.213 +        self._write(syslog.LOG_DEBUG, '`', msg)
   1.214 +
   1.215 +    def alert(self, msg):
   1.216 +        self._write(syslog.LOG_ALERT, '#', msg)
   1.217 +
   1.218 +    def sublog(self, prefix):
   1.219 +        return self.__class__('%s/%s' % (self.prefix, prefix), self.facility)
   1.220 +
   1.221 +    def excpt(self, msg, eClass=None, eObj=None, eTb=None, stack_skip=0):
   1.222 +        if eClass is None:
   1.223 +            eClass, eObj, eTb = exc_info()
   1.224 +
   1.225 +        if eClass is None:
   1.226 +            # Если вдруг вызываем без произошедшего исключения
   1.227 +            self.err(msg)
   1.228 +        else:
   1.229 +            tbData_tb = list(extract_tb(eTb))[::-1]
   1.230 +            tbData_stack = list(extract_stack())[::-1][(2 + stack_skip):]
   1.231 +
   1.232 +            self.err(msg)
   1.233 +
   1.234 +            self.err('--- EXCEPTION ---')
   1.235 +            self.err(' %s (%s)' % (eClass.__name__, eObj))
   1.236 +
   1.237 +            self.err('--- TRACEBACK ---')
   1.238 +            for _tbFile, _tbLine, _tbFunc, _tbText in tbData_tb:
   1.239 +                self.err('File: %s, line %s in %s' % (_tbFile, _tbLine, _tbFunc))
   1.240 +                self.err('   %s' % _tbText)
   1.241 +
   1.242 +            self.err('>>> Exception Handler <<<')
   1.243 +            for _tbFile, _tbLine, _tbFunc, _tbText in tbData_stack:
   1.244 +                self.err('File: %s, line %s in %s' % (_tbFile, _tbLine, _tbFunc))
   1.245 +                self.err('   %s' % _tbText)
   1.246 +
   1.247 +            self.err('--- END EXCEPTION ---')