Skip to content
Find file
Fetching contributors…
Cannot retrieve contributors at this time
97 lines (80 sloc) 2.79 KB
"""copied almost byte for byte from jedp/python-redis-log
There was no copyright in the original. Therefore, none here.
import zmq
import socket
import getpass
import datetime
import inspect
import logging
def levelAsString(level):
return {logging.DEBUG: 'debug',
logging.INFO: 'info',
logging.WARNING: 'warning',
logging.ERROR: 'error',
logging.CRITICAL: 'critical',
logging.FATAL: 'fatal'}.get(level, 'unknown')
def _getCallingContext():
Utility function for the ZeroMQLogRecord.
Returns the module, function, and lineno of the function
that called the logger.
We look way up in the stack. The stack at this point is:
[0] _getCallingContext (hey, that's me!)
[1] __init__
[2] makeRecord
[3] _log
[4] <logging method>
[5] caller of logging method
frames = inspect.stack()
if len(frames) > 4:
context = frames[5]
context = frames[0]
modname = context[1]
lineno = context[2]
if context[3]:
funcname = context[3]
funcname = ""
# python docs say you don't want references to
# frames lying around. Bad things can happen.
del context
del frames
return modname, funcname, lineno
class ZeroMQLogRecord(logging.LogRecord):
def __init__(self, name, lvl, fn, lno, msg, args, exc_info, func=None, extra=None):
logging.LogRecord.__init__(self, name, lvl, fn, lno, msg, args, exc_info, func)
# You can also access the following instance variables via the
# formatter as
# %(hostname)s
# %(username)s
# %(modname)s
# etc.
self.hostname = socket.gethostname()
self.username = getpass.getuser()
self.modname, self.funcname, self.lineno = _getCallingContext()
self._raw = {
'name': name,
'level': levelAsString(lvl),
'filename': fn,
'line_no': self.lineno,
'msg': str(msg),
'args': list(args),
'time': datetime.datetime.utcnow(),
'username': self.username,
'funcname': self.funcname,
'hostname': self.hostname,
'traceback': exc_info
class ZeroMQLogger(logging.getLoggerClass()):
def makeRecord(self, name, lvl, fn, lno, msg, args, exc_info, func=None, extra=None):
record = ZeroMQLogRecord(name, lvl, fn, lno, msg, args, exc_info, func=None)
if extra:
for key in extra:
if (key in ["message", "asctime"]) or (key in record.__dict__):
raise KeyError("Attempt to overwrite %r in ZeroMQLogRecord" % key)
record.__dict__[key] = extra[key]
return record
# __END__
Something went wrong with that request. Please try again.