Show More
Commit Description:
Merge pull request #17 from nattee/master...
Commit Description:
Merge pull request #17 from nattee/master
upgrade to current working snapshot
References:
File last commit:
Show/Diff file:
Action:
lib/assets/Lib/logging/handlers.py
| 1450 lines
| 55.7 KiB
| text/x-python
| PythonLexer
|
r584 | # Copyright 2001-2013 by Vinay Sajip. All Rights Reserved. | |||
# | ||||
# Permission to use, copy, modify, and distribute this software and its | ||||
# documentation for any purpose and without fee is hereby granted, | ||||
# provided that the above copyright notice appear in all copies and that | ||||
# both that copyright notice and this permission notice appear in | ||||
# supporting documentation, and that the name of Vinay Sajip | ||||
# not be used in advertising or publicity pertaining to distribution | ||||
# of the software without specific, written prior permission. | ||||
# VINAY SAJIP DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING | ||||
# ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL | ||||
# VINAY SAJIP BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR | ||||
# ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER | ||||
# IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT | ||||
# OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. | ||||
""" | ||||
Additional handlers for the logging package for Python. The core package is | ||||
based on PEP 282 and comments thereto in comp.lang.python. | ||||
Copyright (C) 2001-2013 Vinay Sajip. All Rights Reserved. | ||||
To use, simply 'import logging.handlers' and log away! | ||||
""" | ||||
import errno, logging, socket, os, pickle, struct, time, re | ||||
from codecs import BOM_UTF8 | ||||
from stat import ST_DEV, ST_INO, ST_MTIME | ||||
import queue | ||||
try: | ||||
import threading | ||||
except ImportError: #pragma: no cover | ||||
threading = None | ||||
# | ||||
# Some constants... | ||||
# | ||||
DEFAULT_TCP_LOGGING_PORT = 9020 | ||||
DEFAULT_UDP_LOGGING_PORT = 9021 | ||||
DEFAULT_HTTP_LOGGING_PORT = 9022 | ||||
DEFAULT_SOAP_LOGGING_PORT = 9023 | ||||
SYSLOG_UDP_PORT = 514 | ||||
SYSLOG_TCP_PORT = 514 | ||||
_MIDNIGHT = 24 * 60 * 60 # number of seconds in a day | ||||
class BaseRotatingHandler(logging.FileHandler): | ||||
""" | ||||
Base class for handlers that rotate log files at a certain point. | ||||
Not meant to be instantiated directly. Instead, use RotatingFileHandler | ||||
or TimedRotatingFileHandler. | ||||
""" | ||||
def __init__(self, filename, mode, encoding=None, delay=False): | ||||
""" | ||||
Use the specified filename for streamed logging | ||||
""" | ||||
logging.FileHandler.__init__(self, filename, mode, encoding, delay) | ||||
self.mode = mode | ||||
self.encoding = encoding | ||||
self.namer = None | ||||
self.rotator = None | ||||
def emit(self, record): | ||||
""" | ||||
Emit a record. | ||||
Output the record to the file, catering for rollover as described | ||||
in doRollover(). | ||||
""" | ||||
try: | ||||
if self.shouldRollover(record): | ||||
self.doRollover() | ||||
logging.FileHandler.emit(self, record) | ||||
except (KeyboardInterrupt, SystemExit): #pragma: no cover | ||||
raise | ||||
except: | ||||
self.handleError(record) | ||||
def rotation_filename(self, default_name): | ||||
""" | ||||
Modify the filename of a log file when rotating. | ||||
This is provided so that a custom filename can be provided. | ||||
The default implementation calls the 'namer' attribute of the | ||||
handler, if it's callable, passing the default name to | ||||
it. If the attribute isn't callable (the default is None), the name | ||||
is returned unchanged. | ||||
:param default_name: The default name for the log file. | ||||
""" | ||||
if not callable(self.namer): | ||||
result = default_name | ||||
else: | ||||
result = self.namer(default_name) | ||||
return result | ||||
def rotate(self, source, dest): | ||||
""" | ||||
When rotating, rotate the current log. | ||||
The default implementation calls the 'rotator' attribute of the | ||||
handler, if it's callable, passing the source and dest arguments to | ||||
it. If the attribute isn't callable (the default is None), the source | ||||
is simply renamed to the destination. | ||||
:param source: The source filename. This is normally the base | ||||
filename, e.g. 'test.log' | ||||
:param dest: The destination filename. This is normally | ||||
what the source is rotated to, e.g. 'test.log.1'. | ||||
""" | ||||
if not callable(self.rotator): | ||||
# Issue 18940: A file may not have been created if delay is True. | ||||
if os.path.exists(source): | ||||
os.rename(source, dest) | ||||
else: | ||||
self.rotator(source, dest) | ||||
class RotatingFileHandler(BaseRotatingHandler): | ||||
""" | ||||
Handler for logging to a set of files, which switches from one file | ||||
to the next when the current file reaches a certain size. | ||||
""" | ||||
def __init__(self, filename, mode='a', maxBytes=0, backupCount=0, encoding=None, delay=False): | ||||
""" | ||||
Open the specified file and use it as the stream for logging. | ||||
By default, the file grows indefinitely. You can specify particular | ||||
values of maxBytes and backupCount to allow the file to rollover at | ||||
a predetermined size. | ||||
Rollover occurs whenever the current log file is nearly maxBytes in | ||||
length. If backupCount is >= 1, the system will successively create | ||||
new files with the same pathname as the base file, but with extensions | ||||
".1", ".2" etc. appended to it. For example, with a backupCount of 5 | ||||
and a base file name of "app.log", you would get "app.log", | ||||
"app.log.1", "app.log.2", ... through to "app.log.5". The file being | ||||
written to is always "app.log" - when it gets filled up, it is closed | ||||
and renamed to "app.log.1", and if files "app.log.1", "app.log.2" etc. | ||||
exist, then they are renamed to "app.log.2", "app.log.3" etc. | ||||
respectively. | ||||
If maxBytes is zero, rollover never occurs. | ||||
""" | ||||
# If rotation/rollover is wanted, it doesn't make sense to use another | ||||
# mode. If for example 'w' were specified, then if there were multiple | ||||
# runs of the calling application, the logs from previous runs would be | ||||
# lost if the 'w' is respected, because the log file would be truncated | ||||
# on each run. | ||||
if maxBytes > 0: | ||||
mode = 'a' | ||||
BaseRotatingHandler.__init__(self, filename, mode, encoding, delay) | ||||
self.maxBytes = maxBytes | ||||
self.backupCount = backupCount | ||||
def doRollover(self): | ||||
""" | ||||
Do a rollover, as described in __init__(). | ||||
""" | ||||
if self.stream: | ||||
self.stream.close() | ||||
self.stream = None | ||||
if self.backupCount > 0: | ||||
for i in range(self.backupCount - 1, 0, -1): | ||||
sfn = self.rotation_filename("%s.%d" % (self.baseFilename, i)) | ||||
dfn = self.rotation_filename("%s.%d" % (self.baseFilename, | ||||
i + 1)) | ||||
if os.path.exists(sfn): | ||||
if os.path.exists(dfn): | ||||
os.remove(dfn) | ||||
os.rename(sfn, dfn) | ||||
dfn = self.rotation_filename(self.baseFilename + ".1") | ||||
if os.path.exists(dfn): | ||||
os.remove(dfn) | ||||
self.rotate(self.baseFilename, dfn) | ||||
if not self.delay: | ||||
self.stream = self._open() | ||||
def shouldRollover(self, record): | ||||
""" | ||||
Determine if rollover should occur. | ||||
Basically, see if the supplied record would cause the file to exceed | ||||
the size limit we have. | ||||
""" | ||||
if self.stream is None: # delay was set... | ||||
self.stream = self._open() | ||||
if self.maxBytes > 0: # are we rolling over? | ||||
msg = "%s\n" % self.format(record) | ||||
self.stream.seek(0, 2) #due to non-posix-compliant Windows feature | ||||
if self.stream.tell() + len(msg) >= self.maxBytes: | ||||
return 1 | ||||
return 0 | ||||
class TimedRotatingFileHandler(BaseRotatingHandler): | ||||
""" | ||||
Handler for logging to a file, rotating the log file at certain timed | ||||
intervals. | ||||
If backupCount is > 0, when rollover is done, no more than backupCount | ||||
files are kept - the oldest ones are deleted. | ||||
""" | ||||
def __init__(self, filename, when='h', interval=1, backupCount=0, encoding=None, delay=False, utc=False): | ||||
BaseRotatingHandler.__init__(self, filename, 'a', encoding, delay) | ||||
self.when = when.upper() | ||||
self.backupCount = backupCount | ||||
self.utc = utc | ||||
# Calculate the real rollover interval, which is just the number of | ||||
# seconds between rollovers. Also set the filename suffix used when | ||||
# a rollover occurs. Current 'when' events supported: | ||||
# S - Seconds | ||||
# M - Minutes | ||||
# H - Hours | ||||
# D - Days | ||||
# midnight - roll over at midnight | ||||
# W{0-6} - roll over on a certain day; 0 - Monday | ||||
# | ||||
# Case of the 'when' specifier is not important; lower or upper case | ||||
# will work. | ||||
if self.when == 'S': | ||||
self.interval = 1 # one second | ||||
self.suffix = "%Y-%m-%d_%H-%M-%S" | ||||
self.extMatch = r"^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}-\d{2}(\.\w+)?$" | ||||
elif self.when == 'M': | ||||
self.interval = 60 # one minute | ||||
self.suffix = "%Y-%m-%d_%H-%M" | ||||
self.extMatch = r"^\d{4}-\d{2}-\d{2}_\d{2}-\d{2}(\.\w+)?$" | ||||
elif self.when == 'H': | ||||
self.interval = 60 * 60 # one hour | ||||
self.suffix = "%Y-%m-%d_%H" | ||||
self.extMatch = r"^\d{4}-\d{2}-\d{2}_\d{2}(\.\w+)?$" | ||||
elif self.when == 'D' or self.when == 'MIDNIGHT': | ||||
self.interval = 60 * 60 * 24 # one day | ||||
self.suffix = "%Y-%m-%d" | ||||
self.extMatch = r"^\d{4}-\d{2}-\d{2}(\.\w+)?$" | ||||
elif self.when.startswith('W'): | ||||
self.interval = 60 * 60 * 24 * 7 # one week | ||||
if len(self.when) != 2: | ||||
raise ValueError("You must specify a day for weekly rollover from 0 to 6 (0 is Monday): %s" % self.when) | ||||
if self.when[1] < '0' or self.when[1] > '6': | ||||
raise ValueError("Invalid day specified for weekly rollover: %s" % self.when) | ||||
self.dayOfWeek = int(self.when[1]) | ||||
self.suffix = "%Y-%m-%d" | ||||
self.extMatch = r"^\d{4}-\d{2}-\d{2}(\.\w+)?$" | ||||
else: | ||||
raise ValueError("Invalid rollover interval specified: %s" % self.when) | ||||
self.extMatch = re.compile(self.extMatch, re.ASCII) | ||||
self.interval = self.interval * interval # multiply by units requested | ||||
if os.path.exists(filename): | ||||
t = os.stat(filename)[ST_MTIME] | ||||
else: | ||||
t = int(time.time()) | ||||
self.rolloverAt = self.computeRollover(t) | ||||
def computeRollover(self, currentTime): | ||||
""" | ||||
Work out the rollover time based on the specified time. | ||||
""" | ||||
result = currentTime + self.interval | ||||
# If we are rolling over at midnight or weekly, then the interval is already known. | ||||
# What we need to figure out is WHEN the next interval is. In other words, | ||||
# if you are rolling over at midnight, then your base interval is 1 day, | ||||
# but you want to start that one day clock at midnight, not now. So, we | ||||
# have to fudge the rolloverAt value in order to trigger the first rollover | ||||
# at the right time. After that, the regular interval will take care of | ||||
# the rest. Note that this code doesn't care about leap seconds. :) | ||||
if self.when == 'MIDNIGHT' or self.when.startswith('W'): | ||||
# This could be done with less code, but I wanted it to be clear | ||||
if self.utc: | ||||
t = time.gmtime(currentTime) | ||||
else: | ||||
t = time.localtime(currentTime) | ||||
currentHour = t[3] | ||||
currentMinute = t[4] | ||||
currentSecond = t[5] | ||||
# r is the number of seconds left between now and midnight | ||||
r = _MIDNIGHT - ((currentHour * 60 + currentMinute) * 60 + | ||||
currentSecond) | ||||
result = currentTime + r | ||||
# If we are rolling over on a certain day, add in the number of days until | ||||
# the next rollover, but offset by 1 since we just calculated the time | ||||
# until the next day starts. There are three cases: | ||||
# Case 1) The day to rollover is today; in this case, do nothing | ||||
# Case 2) The day to rollover is further in the interval (i.e., today is | ||||
# day 2 (Wednesday) and rollover is on day 6 (Sunday). Days to | ||||
# next rollover is simply 6 - 2 - 1, or 3. | ||||
# Case 3) The day to rollover is behind us in the interval (i.e., today | ||||
# is day 5 (Saturday) and rollover is on day 3 (Thursday). | ||||
# Days to rollover is 6 - 5 + 3, or 4. In this case, it's the | ||||
# number of days left in the current week (1) plus the number | ||||
# of days in the next week until the rollover day (3). | ||||
# The calculations described in 2) and 3) above need to have a day added. | ||||
# This is because the above time calculation takes us to midnight on this | ||||
# day, i.e. the start of the next day. | ||||
if self.when.startswith('W'): | ||||
day = t[6] # 0 is Monday | ||||
if day != self.dayOfWeek: | ||||
if day < self.dayOfWeek: | ||||
daysToWait = self.dayOfWeek - day | ||||
else: | ||||
daysToWait = 6 - day + self.dayOfWeek + 1 | ||||
newRolloverAt = result + (daysToWait * (60 * 60 * 24)) | ||||
if not self.utc: | ||||
dstNow = t[-1] | ||||
dstAtRollover = time.localtime(newRolloverAt)[-1] | ||||
if dstNow != dstAtRollover: | ||||
if not dstNow: # DST kicks in before next rollover, so we need to deduct an hour | ||||
addend = -3600 | ||||
else: # DST bows out before next rollover, so we need to add an hour | ||||
addend = 3600 | ||||
newRolloverAt += addend | ||||
result = newRolloverAt | ||||
return result | ||||
def shouldRollover(self, record): | ||||
""" | ||||
Determine if rollover should occur. | ||||
record is not used, as we are just comparing times, but it is needed so | ||||
the method signatures are the same | ||||
""" | ||||
t = int(time.time()) | ||||
if t >= self.rolloverAt: | ||||
return 1 | ||||
return 0 | ||||
def getFilesToDelete(self): | ||||
""" | ||||
Determine the files to delete when rolling over. | ||||
More specific than the earlier method, which just used glob.glob(). | ||||
""" | ||||
dirName, baseName = os.path.split(self.baseFilename) | ||||
fileNames = os.listdir(dirName) | ||||
result = [] | ||||
prefix = baseName + "." | ||||
plen = len(prefix) | ||||
for fileName in fileNames: | ||||
if fileName[:plen] == prefix: | ||||
suffix = fileName[plen:] | ||||
if self.extMatch.match(suffix): | ||||
result.append(os.path.join(dirName, fileName)) | ||||
result.sort() | ||||
if len(result) < self.backupCount: | ||||
result = [] | ||||
else: | ||||
result = result[:len(result) - self.backupCount] | ||||
return result | ||||
def doRollover(self): | ||||
""" | ||||
do a rollover; in this case, a date/time stamp is appended to the filename | ||||
when the rollover happens. However, you want the file to be named for the | ||||
start of the interval, not the current time. If there is a backup count, | ||||
then we have to get a list of matching filenames, sort them and remove | ||||
the one with the oldest suffix. | ||||
""" | ||||
if self.stream: | ||||
self.stream.close() | ||||
self.stream = None | ||||
# get the time that this sequence started at and make it a TimeTuple | ||||
currentTime = int(time.time()) | ||||
dstNow = time.localtime(currentTime)[-1] | ||||
t = self.rolloverAt - self.interval | ||||
if self.utc: | ||||
timeTuple = time.gmtime(t) | ||||
else: | ||||
timeTuple = time.localtime(t) | ||||
dstThen = timeTuple[-1] | ||||
if dstNow != dstThen: | ||||
if dstNow: | ||||
addend = 3600 | ||||
else: | ||||
addend = -3600 | ||||
timeTuple = time.localtime(t + addend) | ||||
dfn = self.rotation_filename(self.baseFilename + "." + | ||||
time.strftime(self.suffix, timeTuple)) | ||||
if os.path.exists(dfn): | ||||
os.remove(dfn) | ||||
self.rotate(self.baseFilename, dfn) | ||||
if self.backupCount > 0: | ||||
for s in self.getFilesToDelete(): | ||||
os.remove(s) | ||||
if not self.delay: | ||||
self.stream = self._open() | ||||
newRolloverAt = self.computeRollover(currentTime) | ||||
while newRolloverAt <= currentTime: | ||||
newRolloverAt = newRolloverAt + self.interval | ||||
#If DST changes and midnight or weekly rollover, adjust for this. | ||||
if (self.when == 'MIDNIGHT' or self.when.startswith('W')) and not self.utc: | ||||
dstAtRollover = time.localtime(newRolloverAt)[-1] | ||||
if dstNow != dstAtRollover: | ||||
if not dstNow: # DST kicks in before next rollover, so we need to deduct an hour | ||||
addend = -3600 | ||||
else: # DST bows out before next rollover, so we need to add an hour | ||||
addend = 3600 | ||||
newRolloverAt += addend | ||||
self.rolloverAt = newRolloverAt | ||||
class WatchedFileHandler(logging.FileHandler): | ||||
""" | ||||
A handler for logging to a file, which watches the file | ||||
to see if it has changed while in use. This can happen because of | ||||
usage of programs such as newsyslog and logrotate which perform | ||||
log file rotation. This handler, intended for use under Unix, | ||||
watches the file to see if it has changed since the last emit. | ||||
(A file has changed if its device or inode have changed.) | ||||
If it has changed, the old file stream is closed, and the file | ||||
opened to get a new stream. | ||||
This handler is not appropriate for use under Windows, because | ||||
under Windows open files cannot be moved or renamed - logging | ||||
opens the files with exclusive locks - and so there is no need | ||||
for such a handler. Furthermore, ST_INO is not supported under | ||||
Windows; stat always returns zero for this value. | ||||
This handler is based on a suggestion and patch by Chad J. | ||||
Schroeder. | ||||
""" | ||||
def __init__(self, filename, mode='a', encoding=None, delay=False): | ||||
logging.FileHandler.__init__(self, filename, mode, encoding, delay) | ||||
self.dev, self.ino = -1, -1 | ||||
self._statstream() | ||||
def _statstream(self): | ||||
if self.stream: | ||||
sres = os.fstat(self.stream.fileno()) | ||||
self.dev, self.ino = sres[ST_DEV], sres[ST_INO] | ||||
def emit(self, record): | ||||
""" | ||||
Emit a record. | ||||
First check if the underlying file has changed, and if it | ||||
has, close the old stream and reopen the file to get the | ||||
current stream. | ||||
""" | ||||
# Reduce the chance of race conditions by stat'ing by path only | ||||
# once and then fstat'ing our new fd if we opened a new log stream. | ||||
# See issue #14632: Thanks to John Mulligan for the problem report | ||||
# and patch. | ||||
try: | ||||
# stat the file by path, checking for existence | ||||
sres = os.stat(self.baseFilename) | ||||
except OSError as err: | ||||
if err.errno == errno.ENOENT: | ||||
sres = None | ||||
else: | ||||
raise | ||||
# compare file system stat with that of our stream file handle | ||||
if not sres or sres[ST_DEV] != self.dev or sres[ST_INO] != self.ino: | ||||
if self.stream is not None: | ||||
# we have an open file handle, clean it up | ||||
self.stream.flush() | ||||
self.stream.close() | ||||
# open a new file handle and get new stat info from that fd | ||||
self.stream = self._open() | ||||
self._statstream() | ||||
logging.FileHandler.emit(self, record) | ||||
class SocketHandler(logging.Handler): | ||||
""" | ||||
A handler class which writes logging records, in pickle format, to | ||||
a streaming socket. The socket is kept open across logging calls. | ||||
If the peer resets it, an attempt is made to reconnect on the next call. | ||||
The pickle which is sent is that of the LogRecord's attribute dictionary | ||||
(__dict__), so that the receiver does not need to have the logging module | ||||
installed in order to process the logging event. | ||||
To unpickle the record at the receiving end into a LogRecord, use the | ||||
makeLogRecord function. | ||||
""" | ||||
def __init__(self, host, port): | ||||
""" | ||||
Initializes the handler with a specific host address and port. | ||||
When the attribute *closeOnError* is set to True - if a socket error | ||||
occurs, the socket is silently closed and then reopened on the next | ||||
logging call. | ||||
""" | ||||
logging.Handler.__init__(self) | ||||
self.host = host | ||||
self.port = port | ||||
self.sock = None | ||||
self.closeOnError = False | ||||
self.retryTime = None | ||||
# | ||||
# Exponential backoff parameters. | ||||
# | ||||
self.retryStart = 1.0 | ||||
self.retryMax = 30.0 | ||||
self.retryFactor = 2.0 | ||||
def makeSocket(self, timeout=1): | ||||
""" | ||||
A factory method which allows subclasses to define the precise | ||||
type of socket they want. | ||||
""" | ||||
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) | ||||
if hasattr(s, 'settimeout'): | ||||
s.settimeout(timeout) | ||||
try: | ||||
s.connect((self.host, self.port)) | ||||
return s | ||||
except socket.error: | ||||
s.close() | ||||
raise | ||||
def createSocket(self): | ||||
""" | ||||
Try to create a socket, using an exponential backoff with | ||||
a max retry time. Thanks to Robert Olson for the original patch | ||||
(SF #815911) which has been slightly refactored. | ||||
""" | ||||
now = time.time() | ||||
# Either retryTime is None, in which case this | ||||
# is the first time back after a disconnect, or | ||||
# we've waited long enough. | ||||
if self.retryTime is None: | ||||
attempt = True | ||||
else: | ||||
attempt = (now >= self.retryTime) | ||||
if attempt: | ||||
try: | ||||
self.sock = self.makeSocket() | ||||
self.retryTime = None # next time, no delay before trying | ||||
except socket.error: | ||||
#Creation failed, so set the retry time and return. | ||||
if self.retryTime is None: | ||||
self.retryPeriod = self.retryStart | ||||
else: | ||||
self.retryPeriod = self.retryPeriod * self.retryFactor | ||||
if self.retryPeriod > self.retryMax: | ||||
self.retryPeriod = self.retryMax | ||||
self.retryTime = now + self.retryPeriod | ||||
def send(self, s): | ||||
""" | ||||
Send a pickled string to the socket. | ||||
This function allows for partial sends which can happen when the | ||||
network is busy. | ||||
""" | ||||
if self.sock is None: | ||||
self.createSocket() | ||||
#self.sock can be None either because we haven't reached the retry | ||||
#time yet, or because we have reached the retry time and retried, | ||||
#but are still unable to connect. | ||||
if self.sock: | ||||
try: | ||||
if hasattr(self.sock, "sendall"): | ||||
self.sock.sendall(s) | ||||
else: #pragma: no cover | ||||
sentsofar = 0 | ||||
left = len(s) | ||||
while left > 0: | ||||
sent = self.sock.send(s[sentsofar:]) | ||||
sentsofar = sentsofar + sent | ||||
left = left - sent | ||||
except socket.error: #pragma: no cover | ||||
self.sock.close() | ||||
self.sock = None # so we can call createSocket next time | ||||
def makePickle(self, record): | ||||
""" | ||||
Pickles the record in binary format with a length prefix, and | ||||
returns it ready for transmission across the socket. | ||||
""" | ||||
ei = record.exc_info | ||||
if ei: | ||||
# just to get traceback text into record.exc_text ... | ||||
dummy = self.format(record) | ||||
# See issue #14436: If msg or args are objects, they may not be | ||||
# available on the receiving end. So we convert the msg % args | ||||
# to a string, save it as msg and zap the args. | ||||
d = dict(record.__dict__) | ||||
d['msg'] = record.getMessage() | ||||
d['args'] = None | ||||
d['exc_info'] = None | ||||
s = pickle.dumps(d, 1) | ||||
slen = struct.pack(">L", len(s)) | ||||
return slen + s | ||||
def handleError(self, record): | ||||
""" | ||||
Handle an error during logging. | ||||
An error has occurred during logging. Most likely cause - | ||||
connection lost. Close the socket so that we can retry on the | ||||
next event. | ||||
""" | ||||
if self.closeOnError and self.sock: | ||||
self.sock.close() | ||||
self.sock = None #try to reconnect next time | ||||
else: | ||||
logging.Handler.handleError(self, record) | ||||
def emit(self, record): | ||||
""" | ||||
Emit a record. | ||||
Pickles the record and writes it to the socket in binary format. | ||||
If there is an error with the socket, silently drop the packet. | ||||
If there was a problem with the socket, re-establishes the | ||||
socket. | ||||
""" | ||||
try: | ||||
s = self.makePickle(record) | ||||
self.send(s) | ||||
except (KeyboardInterrupt, SystemExit): #pragma: no cover | ||||
raise | ||||
except: | ||||
self.handleError(record) | ||||
def close(self): | ||||
""" | ||||
Closes the socket. | ||||
""" | ||||
self.acquire() | ||||
try: | ||||
if self.sock: | ||||
self.sock.close() | ||||
self.sock = None | ||||
logging.Handler.close(self) | ||||
finally: | ||||
self.release() | ||||
class DatagramHandler(SocketHandler): | ||||
""" | ||||
A handler class which writes logging records, in pickle format, to | ||||
a datagram socket. The pickle which is sent is that of the LogRecord's | ||||
attribute dictionary (__dict__), so that the receiver does not need to | ||||
have the logging module installed in order to process the logging event. | ||||
To unpickle the record at the receiving end into a LogRecord, use the | ||||
makeLogRecord function. | ||||
""" | ||||
def __init__(self, host, port): | ||||
""" | ||||
Initializes the handler with a specific host address and port. | ||||
""" | ||||
SocketHandler.__init__(self, host, port) | ||||
self.closeOnError = False | ||||
def makeSocket(self): | ||||
""" | ||||
The factory method of SocketHandler is here overridden to create | ||||
a UDP socket (SOCK_DGRAM). | ||||
""" | ||||
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) | ||||
return s | ||||
def send(self, s): | ||||
""" | ||||
Send a pickled string to a socket. | ||||
This function no longer allows for partial sends which can happen | ||||
when the network is busy - UDP does not guarantee delivery and | ||||
can deliver packets out of sequence. | ||||
""" | ||||
if self.sock is None: | ||||
self.createSocket() | ||||
self.sock.sendto(s, (self.host, self.port)) | ||||
class SysLogHandler(logging.Handler): | ||||
""" | ||||
A handler class which sends formatted logging records to a syslog | ||||
server. Based on Sam Rushing's syslog module: | ||||
http://www.nightmare.com/squirl/python-ext/misc/syslog.py | ||||
Contributed by Nicolas Untz (after which minor refactoring changes | ||||
have been made). | ||||
""" | ||||
# from <linux/sys/syslog.h>: | ||||
# ====================================================================== | ||||
# priorities/facilities are encoded into a single 32-bit quantity, where | ||||
# the bottom 3 bits are the priority (0-7) and the top 28 bits are the | ||||
# facility (0-big number). Both the priorities and the facilities map | ||||
# roughly one-to-one to strings in the syslogd(8) source code. This | ||||
# mapping is included in this file. | ||||
# | ||||
# priorities (these are ordered) | ||||
LOG_EMERG = 0 # system is unusable | ||||
LOG_ALERT = 1 # action must be taken immediately | ||||
LOG_CRIT = 2 # critical conditions | ||||
LOG_ERR = 3 # error conditions | ||||
LOG_WARNING = 4 # warning conditions | ||||
LOG_NOTICE = 5 # normal but significant condition | ||||
LOG_INFO = 6 # informational | ||||
LOG_DEBUG = 7 # debug-level messages | ||||
# facility codes | ||||
LOG_KERN = 0 # kernel messages | ||||
LOG_USER = 1 # random user-level messages | ||||
LOG_MAIL = 2 # mail system | ||||
LOG_DAEMON = 3 # system daemons | ||||
LOG_AUTH = 4 # security/authorization messages | ||||
LOG_SYSLOG = 5 # messages generated internally by syslogd | ||||
LOG_LPR = 6 # line printer subsystem | ||||
LOG_NEWS = 7 # network news subsystem | ||||
LOG_UUCP = 8 # UUCP subsystem | ||||
LOG_CRON = 9 # clock daemon | ||||
LOG_AUTHPRIV = 10 # security/authorization messages (private) | ||||
LOG_FTP = 11 # FTP daemon | ||||
# other codes through 15 reserved for system use | ||||
LOG_LOCAL0 = 16 # reserved for local use | ||||
LOG_LOCAL1 = 17 # reserved for local use | ||||
LOG_LOCAL2 = 18 # reserved for local use | ||||
LOG_LOCAL3 = 19 # reserved for local use | ||||
LOG_LOCAL4 = 20 # reserved for local use | ||||
LOG_LOCAL5 = 21 # reserved for local use | ||||
LOG_LOCAL6 = 22 # reserved for local use | ||||
LOG_LOCAL7 = 23 # reserved for local use | ||||
priority_names = { | ||||
"alert": LOG_ALERT, | ||||
"crit": LOG_CRIT, | ||||
"critical": LOG_CRIT, | ||||
"debug": LOG_DEBUG, | ||||
"emerg": LOG_EMERG, | ||||
"err": LOG_ERR, | ||||
"error": LOG_ERR, # DEPRECATED | ||||
"info": LOG_INFO, | ||||
"notice": LOG_NOTICE, | ||||
"panic": LOG_EMERG, # DEPRECATED | ||||
"warn": LOG_WARNING, # DEPRECATED | ||||
"warning": LOG_WARNING, | ||||
} | ||||
facility_names = { | ||||
"auth": LOG_AUTH, | ||||
"authpriv": LOG_AUTHPRIV, | ||||
"cron": LOG_CRON, | ||||
"daemon": LOG_DAEMON, | ||||
"ftp": LOG_FTP, | ||||
"kern": LOG_KERN, | ||||
"lpr": LOG_LPR, | ||||
"mail": LOG_MAIL, | ||||
"news": LOG_NEWS, | ||||
"security": LOG_AUTH, # DEPRECATED | ||||
"syslog": LOG_SYSLOG, | ||||
"user": LOG_USER, | ||||
"uucp": LOG_UUCP, | ||||
"local0": LOG_LOCAL0, | ||||
"local1": LOG_LOCAL1, | ||||
"local2": LOG_LOCAL2, | ||||
"local3": LOG_LOCAL3, | ||||
"local4": LOG_LOCAL4, | ||||
"local5": LOG_LOCAL5, | ||||
"local6": LOG_LOCAL6, | ||||
"local7": LOG_LOCAL7, | ||||
} | ||||
#The map below appears to be trivially lowercasing the key. However, | ||||
#there's more to it than meets the eye - in some locales, lowercasing | ||||
#gives unexpected results. See SF #1524081: in the Turkish locale, | ||||
#"INFO".lower() != "info" | ||||
priority_map = { | ||||
"DEBUG" : "debug", | ||||
"INFO" : "info", | ||||
"WARNING" : "warning", | ||||
"ERROR" : "error", | ||||
"CRITICAL" : "critical" | ||||
} | ||||
def __init__(self, address=('localhost', SYSLOG_UDP_PORT), | ||||
facility=LOG_USER, socktype=None): | ||||
""" | ||||
Initialize a handler. | ||||
If address is specified as a string, a UNIX socket is used. To log to a | ||||
local syslogd, "SysLogHandler(address="/dev/log")" can be used. | ||||
If facility is not specified, LOG_USER is used. | ||||
""" | ||||
logging.Handler.__init__(self) | ||||
self.address = address | ||||
self.facility = facility | ||||
self.socktype = socktype | ||||
if isinstance(address, str): | ||||
self.unixsocket = True | ||||
self._connect_unixsocket(address) | ||||
else: | ||||
self.unixsocket = False | ||||
if socktype is None: | ||||
socktype = socket.SOCK_DGRAM | ||||
self.socket = socket.socket(socket.AF_INET, socktype) | ||||
if socktype == socket.SOCK_STREAM: | ||||
self.socket.connect(address) | ||||
self.socktype = socktype | ||||
self.formatter = None | ||||
def _connect_unixsocket(self, address): | ||||
use_socktype = self.socktype | ||||
if use_socktype is None: | ||||
use_socktype = socket.SOCK_DGRAM | ||||
self.socket = socket.socket(socket.AF_UNIX, use_socktype) | ||||
try: | ||||
self.socket.connect(address) | ||||
# it worked, so set self.socktype to the used type | ||||
self.socktype = use_socktype | ||||
except socket.error: | ||||
self.socket.close() | ||||
if self.socktype is not None: | ||||
# user didn't specify falling back, so fail | ||||
raise | ||||
use_socktype = socket.SOCK_STREAM | ||||
self.socket = socket.socket(socket.AF_UNIX, use_socktype) | ||||
try: | ||||
self.socket.connect(address) | ||||
# it worked, so set self.socktype to the used type | ||||
self.socktype = use_socktype | ||||
except socket.error: | ||||
self.socket.close() | ||||
raise | ||||
def encodePriority(self, facility, priority): | ||||
""" | ||||
Encode the facility and priority. You can pass in strings or | ||||
integers - if strings are passed, the facility_names and | ||||
priority_names mapping dictionaries are used to convert them to | ||||
integers. | ||||
""" | ||||
if isinstance(facility, str): | ||||
facility = self.facility_names[facility] | ||||
if isinstance(priority, str): | ||||
priority = self.priority_names[priority] | ||||
return (facility << 3) | priority | ||||
def close (self): | ||||
""" | ||||
Closes the socket. | ||||
""" | ||||
self.acquire() | ||||
try: | ||||
self.socket.close() | ||||
logging.Handler.close(self) | ||||
finally: | ||||
self.release() | ||||
def mapPriority(self, levelName): | ||||
""" | ||||
Map a logging level name to a key in the priority_names map. | ||||
This is useful in two scenarios: when custom levels are being | ||||
used, and in the case where you can't do a straightforward | ||||
mapping by lowercasing the logging level name because of locale- | ||||
specific issues (see SF #1524081). | ||||
""" | ||||
return self.priority_map.get(levelName, "warning") | ||||
ident = '' # prepended to all messages | ||||
append_nul = True # some old syslog daemons expect a NUL terminator | ||||
def emit(self, record): | ||||
""" | ||||
Emit a record. | ||||
The record is formatted, and then sent to the syslog server. If | ||||
exception information is present, it is NOT sent to the server. | ||||
""" | ||||
msg = self.format(record) | ||||
if self.ident: | ||||
msg = self.ident + msg | ||||
if self.append_nul: | ||||
msg += '\000' | ||||
""" | ||||
We need to convert record level to lowercase, maybe this will | ||||
change in the future. | ||||
""" | ||||
prio = '<%d>' % self.encodePriority(self.facility, | ||||
self.mapPriority(record.levelname)) | ||||
prio = prio.encode('utf-8') | ||||
# Message is a string. Convert to bytes as required by RFC 5424 | ||||
msg = msg.encode('utf-8') | ||||
msg = prio + msg | ||||
try: | ||||
if self.unixsocket: | ||||
try: | ||||
self.socket.send(msg) | ||||
except socket.error: | ||||
self.socket.close() | ||||
self._connect_unixsocket(self.address) | ||||
self.socket.send(msg) | ||||
elif self.socktype == socket.SOCK_DGRAM: | ||||
self.socket.sendto(msg, self.address) | ||||
else: | ||||
self.socket.sendall(msg) | ||||
except (KeyboardInterrupt, SystemExit): #pragma: no cover | ||||
raise | ||||
except: | ||||
self.handleError(record) | ||||
class SMTPHandler(logging.Handler): | ||||
""" | ||||
A handler class which sends an SMTP email for each logging event. | ||||
""" | ||||
def __init__(self, mailhost, fromaddr, toaddrs, subject, | ||||
credentials=None, secure=None, timeout=5.0): | ||||
""" | ||||
Initialize the handler. | ||||
Initialize the instance with the from and to addresses and subject | ||||
line of the email. To specify a non-standard SMTP port, use the | ||||
(host, port) tuple format for the mailhost argument. To specify | ||||
authentication credentials, supply a (username, password) tuple | ||||
for the credentials argument. To specify the use of a secure | ||||
protocol (TLS), pass in a tuple for the secure argument. This will | ||||
only be used when authentication credentials are supplied. The tuple | ||||
will be either an empty tuple, or a single-value tuple with the name | ||||
of a keyfile, or a 2-value tuple with the names of the keyfile and | ||||
certificate file. (This tuple is passed to the `starttls` method). | ||||
A timeout in seconds can be specified for the SMTP connection (the | ||||
default is one second). | ||||
""" | ||||
logging.Handler.__init__(self) | ||||
if isinstance(mailhost, tuple): | ||||
self.mailhost, self.mailport = mailhost | ||||
else: | ||||
self.mailhost, self.mailport = mailhost, None | ||||
if isinstance(credentials, tuple): | ||||
self.username, self.password = credentials | ||||
else: | ||||
self.username = None | ||||
self.fromaddr = fromaddr | ||||
if isinstance(toaddrs, str): | ||||
toaddrs = [toaddrs] | ||||
self.toaddrs = toaddrs | ||||
self.subject = subject | ||||
self.secure = secure | ||||
self.timeout = timeout | ||||
def getSubject(self, record): | ||||
""" | ||||
Determine the subject for the email. | ||||
If you want to specify a subject line which is record-dependent, | ||||
override this method. | ||||
""" | ||||
return self.subject | ||||
def emit(self, record): | ||||
""" | ||||
Emit a record. | ||||
Format the record and send it to the specified addressees. | ||||
""" | ||||
try: | ||||
import smtplib | ||||
from email.utils import formatdate | ||||
port = self.mailport | ||||
if not port: | ||||
port = smtplib.SMTP_PORT | ||||
smtp = smtplib.SMTP(self.mailhost, port, timeout=self.timeout) | ||||
msg = self.format(record) | ||||
msg = "From: %s\r\nTo: %s\r\nSubject: %s\r\nDate: %s\r\n\r\n%s" % ( | ||||
self.fromaddr, | ||||
",".join(self.toaddrs), | ||||
self.getSubject(record), | ||||
formatdate(), msg) | ||||
if self.username: | ||||
if self.secure is not None: | ||||
smtp.ehlo() | ||||
smtp.starttls(*self.secure) | ||||
smtp.ehlo() | ||||
smtp.login(self.username, self.password) | ||||
smtp.sendmail(self.fromaddr, self.toaddrs, msg) | ||||
smtp.quit() | ||||
except (KeyboardInterrupt, SystemExit): #pragma: no cover | ||||
raise | ||||
except: | ||||
self.handleError(record) | ||||
class NTEventLogHandler(logging.Handler): | ||||
""" | ||||
A handler class which sends events to the NT Event Log. Adds a | ||||
registry entry for the specified application name. If no dllname is | ||||
provided, win32service.pyd (which contains some basic message | ||||
placeholders) is used. Note that use of these placeholders will make | ||||
your event logs big, as the entire message source is held in the log. | ||||
If you want slimmer logs, you have to pass in the name of your own DLL | ||||
which contains the message definitions you want to use in the event log. | ||||
""" | ||||
def __init__(self, appname, dllname=None, logtype="Application"): | ||||
logging.Handler.__init__(self) | ||||
try: | ||||
import win32evtlogutil, win32evtlog | ||||
self.appname = appname | ||||
self._welu = win32evtlogutil | ||||
if not dllname: | ||||
dllname = os.path.split(self._welu.__file__) | ||||
dllname = os.path.split(dllname[0]) | ||||
dllname = os.path.join(dllname[0], r'win32service.pyd') | ||||
self.dllname = dllname | ||||
self.logtype = logtype | ||||
self._welu.AddSourceToRegistry(appname, dllname, logtype) | ||||
self.deftype = win32evtlog.EVENTLOG_ERROR_TYPE | ||||
self.typemap = { | ||||
logging.DEBUG : win32evtlog.EVENTLOG_INFORMATION_TYPE, | ||||
logging.INFO : win32evtlog.EVENTLOG_INFORMATION_TYPE, | ||||
logging.WARNING : win32evtlog.EVENTLOG_WARNING_TYPE, | ||||
logging.ERROR : win32evtlog.EVENTLOG_ERROR_TYPE, | ||||
logging.CRITICAL: win32evtlog.EVENTLOG_ERROR_TYPE, | ||||
} | ||||
except ImportError: | ||||
print("The Python Win32 extensions for NT (service, event "\ | ||||
"logging) appear not to be available.") | ||||
self._welu = None | ||||
def getMessageID(self, record): | ||||
""" | ||||
Return the message ID for the event record. If you are using your | ||||
own messages, you could do this by having the msg passed to the | ||||
logger being an ID rather than a formatting string. Then, in here, | ||||
you could use a dictionary lookup to get the message ID. This | ||||
version returns 1, which is the base message ID in win32service.pyd. | ||||
""" | ||||
return 1 | ||||
def getEventCategory(self, record): | ||||
""" | ||||
Return the event category for the record. | ||||
Override this if you want to specify your own categories. This version | ||||
returns 0. | ||||
""" | ||||
return 0 | ||||
def getEventType(self, record): | ||||
""" | ||||
Return the event type for the record. | ||||
Override this if you want to specify your own types. This version does | ||||
a mapping using the handler's typemap attribute, which is set up in | ||||
__init__() to a dictionary which contains mappings for DEBUG, INFO, | ||||
WARNING, ERROR and CRITICAL. If you are using your own levels you will | ||||
either need to override this method or place a suitable dictionary in | ||||
the handler's typemap attribute. | ||||
""" | ||||
return self.typemap.get(record.levelno, self.deftype) | ||||
def emit(self, record): | ||||
""" | ||||
Emit a record. | ||||
Determine the message ID, event category and event type. Then | ||||
log the message in the NT event log. | ||||
""" | ||||
if self._welu: | ||||
try: | ||||
id = self.getMessageID(record) | ||||
cat = self.getEventCategory(record) | ||||
type = self.getEventType(record) | ||||
msg = self.format(record) | ||||
self._welu.ReportEvent(self.appname, id, cat, type, [msg]) | ||||
except (KeyboardInterrupt, SystemExit): #pragma: no cover | ||||
raise | ||||
except: | ||||
self.handleError(record) | ||||
def close(self): | ||||
""" | ||||
Clean up this handler. | ||||
You can remove the application name from the registry as a | ||||
source of event log entries. However, if you do this, you will | ||||
not be able to see the events as you intended in the Event Log | ||||
Viewer - it needs to be able to access the registry to get the | ||||
DLL name. | ||||
""" | ||||
#self._welu.RemoveSourceFromRegistry(self.appname, self.logtype) | ||||
logging.Handler.close(self) | ||||
class HTTPHandler(logging.Handler): | ||||
""" | ||||
A class which sends records to a Web server, using either GET or | ||||
POST semantics. | ||||
""" | ||||
def __init__(self, host, url, method="GET", secure=False, credentials=None): | ||||
""" | ||||
Initialize the instance with the host, the request URL, and the method | ||||
("GET" or "POST") | ||||
""" | ||||
logging.Handler.__init__(self) | ||||
method = method.upper() | ||||
if method not in ["GET", "POST"]: | ||||
raise ValueError("method must be GET or POST") | ||||
self.host = host | ||||
self.url = url | ||||
self.method = method | ||||
self.secure = secure | ||||
self.credentials = credentials | ||||
def mapLogRecord(self, record): | ||||
""" | ||||
Default implementation of mapping the log record into a dict | ||||
that is sent as the CGI data. Overwrite in your class. | ||||
Contributed by Franz Glasner. | ||||
""" | ||||
return record.__dict__ | ||||
def emit(self, record): | ||||
""" | ||||
Emit a record. | ||||
Send the record to the Web server as a percent-encoded dictionary | ||||
""" | ||||
try: | ||||
import http.client, urllib.parse | ||||
host = self.host | ||||
if self.secure: | ||||
h = http.client.HTTPSConnection(host) | ||||
else: | ||||
h = http.client.HTTPConnection(host) | ||||
url = self.url | ||||
data = urllib.parse.urlencode(self.mapLogRecord(record)) | ||||
if self.method == "GET": | ||||
if (url.find('?') >= 0): | ||||
sep = '&' | ||||
else: | ||||
sep = '?' | ||||
url = url + "%c%s" % (sep, data) | ||||
h.putrequest(self.method, url) | ||||
# support multiple hosts on one IP address... | ||||
# need to strip optional :port from host, if present | ||||
i = host.find(":") | ||||
if i >= 0: | ||||
host = host[:i] | ||||
h.putheader("Host", host) | ||||
if self.method == "POST": | ||||
h.putheader("Content-type", | ||||
"application/x-www-form-urlencoded") | ||||
h.putheader("Content-length", str(len(data))) | ||||
if self.credentials: | ||||
import base64 | ||||
s = ('u%s:%s' % self.credentials).encode('utf-8') | ||||
s = 'Basic ' + base64.b64encode(s).strip() | ||||
h.putheader('Authorization', s) | ||||
h.endheaders() | ||||
if self.method == "POST": | ||||
h.send(data.encode('utf-8')) | ||||
h.getresponse() #can't do anything with the result | ||||
except (KeyboardInterrupt, SystemExit): #pragma: no cover | ||||
raise | ||||
except: | ||||
self.handleError(record) | ||||
class BufferingHandler(logging.Handler): | ||||
""" | ||||
A handler class which buffers logging records in memory. Whenever each | ||||
record is added to the buffer, a check is made to see if the buffer should | ||||
be flushed. If it should, then flush() is expected to do what's needed. | ||||
""" | ||||
def __init__(self, capacity): | ||||
""" | ||||
Initialize the handler with the buffer size. | ||||
""" | ||||
logging.Handler.__init__(self) | ||||
self.capacity = capacity | ||||
self.buffer = [] | ||||
def shouldFlush(self, record): | ||||
""" | ||||
Should the handler flush its buffer? | ||||
Returns true if the buffer is up to capacity. This method can be | ||||
overridden to implement custom flushing strategies. | ||||
""" | ||||
return (len(self.buffer) >= self.capacity) | ||||
def emit(self, record): | ||||
""" | ||||
Emit a record. | ||||
Append the record. If shouldFlush() tells us to, call flush() to process | ||||
the buffer. | ||||
""" | ||||
self.buffer.append(record) | ||||
if self.shouldFlush(record): | ||||
self.flush() | ||||
def flush(self): | ||||
""" | ||||
Override to implement custom flushing behaviour. | ||||
This version just zaps the buffer to empty. | ||||
""" | ||||
self.acquire() | ||||
try: | ||||
self.buffer = [] | ||||
finally: | ||||
self.release() | ||||
def close(self): | ||||
""" | ||||
Close the handler. | ||||
This version just flushes and chains to the parent class' close(). | ||||
""" | ||||
self.flush() | ||||
logging.Handler.close(self) | ||||
class MemoryHandler(BufferingHandler): | ||||
""" | ||||
A handler class which buffers logging records in memory, periodically | ||||
flushing them to a target handler. Flushing occurs whenever the buffer | ||||
is full, or when an event of a certain severity or greater is seen. | ||||
""" | ||||
def __init__(self, capacity, flushLevel=logging.ERROR, target=None): | ||||
""" | ||||
Initialize the handler with the buffer size, the level at which | ||||
flushing should occur and an optional target. | ||||
Note that without a target being set either here or via setTarget(), | ||||
a MemoryHandler is no use to anyone! | ||||
""" | ||||
BufferingHandler.__init__(self, capacity) | ||||
self.flushLevel = flushLevel | ||||
self.target = target | ||||
def shouldFlush(self, record): | ||||
""" | ||||
Check for buffer full or a record at the flushLevel or higher. | ||||
""" | ||||
return (len(self.buffer) >= self.capacity) or \ | ||||
(record.levelno >= self.flushLevel) | ||||
def setTarget(self, target): | ||||
""" | ||||
Set the target handler for this handler. | ||||
""" | ||||
self.target = target | ||||
def flush(self): | ||||
""" | ||||
For a MemoryHandler, flushing means just sending the buffered | ||||
records to the target, if there is one. Override if you want | ||||
different behaviour. | ||||
The record buffer is also cleared by this operation. | ||||
""" | ||||
self.acquire() | ||||
try: | ||||
if self.target: | ||||
for record in self.buffer: | ||||
self.target.handle(record) | ||||
self.buffer = [] | ||||
finally: | ||||
self.release() | ||||
def close(self): | ||||
""" | ||||
Flush, set the target to None and lose the buffer. | ||||
""" | ||||
self.flush() | ||||
self.acquire() | ||||
try: | ||||
self.target = None | ||||
BufferingHandler.close(self) | ||||
finally: | ||||
self.release() | ||||
class QueueHandler(logging.Handler): | ||||
""" | ||||
This handler sends events to a queue. Typically, it would be used together | ||||
with a multiprocessing Queue to centralise logging to file in one process | ||||
(in a multi-process application), so as to avoid file write contention | ||||
between processes. | ||||
This code is new in Python 3.2, but this class can be copy pasted into | ||||
user code for use with earlier Python versions. | ||||
""" | ||||
def __init__(self, queue): | ||||
""" | ||||
Initialise an instance, using the passed queue. | ||||
""" | ||||
logging.Handler.__init__(self) | ||||
self.queue = queue | ||||
def enqueue(self, record): | ||||
""" | ||||
Enqueue a record. | ||||
The base implementation uses put_nowait. You may want to override | ||||
this method if you want to use blocking, timeouts or custom queue | ||||
implementations. | ||||
""" | ||||
self.queue.put_nowait(record) | ||||
def prepare(self, record): | ||||
""" | ||||
Prepares a record for queuing. The object returned by this method is | ||||
enqueued. | ||||
The base implementation formats the record to merge the message | ||||
and arguments, and removes unpickleable items from the record | ||||
in-place. | ||||
You might want to override this method if you want to convert | ||||
the record to a dict or JSON string, or send a modified copy | ||||
of the record while leaving the original intact. | ||||
""" | ||||
# The format operation gets traceback text into record.exc_text | ||||
# (if there's exception data), and also puts the message into | ||||
# record.message. We can then use this to replace the original | ||||
# msg + args, as these might be unpickleable. We also zap the | ||||
# exc_info attribute, as it's no longer needed and, if not None, | ||||
# will typically not be pickleable. | ||||
self.format(record) | ||||
record.msg = record.message | ||||
record.args = None | ||||
record.exc_info = None | ||||
return record | ||||
def emit(self, record): | ||||
""" | ||||
Emit a record. | ||||
Writes the LogRecord to the queue, preparing it for pickling first. | ||||
""" | ||||
try: | ||||
self.enqueue(self.prepare(record)) | ||||
except (KeyboardInterrupt, SystemExit): #pragma: no cover | ||||
raise | ||||
except: | ||||
self.handleError(record) | ||||
if threading: | ||||
class QueueListener(object): | ||||
""" | ||||
This class implements an internal threaded listener which watches for | ||||
LogRecords being added to a queue, removes them and passes them to a | ||||
list of handlers for processing. | ||||
""" | ||||
_sentinel = None | ||||
def __init__(self, queue, *handlers): | ||||
""" | ||||
Initialise an instance with the specified queue and | ||||
handlers. | ||||
""" | ||||
self.queue = queue | ||||
self.handlers = handlers | ||||
self._stop = threading.Event() | ||||
self._thread = None | ||||
def dequeue(self, block): | ||||
""" | ||||
Dequeue a record and return it, optionally blocking. | ||||
The base implementation uses get. You may want to override this method | ||||
if you want to use timeouts or work with custom queue implementations. | ||||
""" | ||||
return self.queue.get(block) | ||||
def start(self): | ||||
""" | ||||
Start the listener. | ||||
This starts up a background thread to monitor the queue for | ||||
LogRecords to process. | ||||
""" | ||||
self._thread = t = threading.Thread(target=self._monitor) | ||||
t.setDaemon(True) | ||||
t.start() | ||||
def prepare(self , record): | ||||
""" | ||||
Prepare a record for handling. | ||||
This method just returns the passed-in record. You may want to | ||||
override this method if you need to do any custom marshalling or | ||||
manipulation of the record before passing it to the handlers. | ||||
""" | ||||
return record | ||||
def handle(self, record): | ||||
""" | ||||
Handle a record. | ||||
This just loops through the handlers offering them the record | ||||
to handle. | ||||
""" | ||||
record = self.prepare(record) | ||||
for handler in self.handlers: | ||||
handler.handle(record) | ||||
def _monitor(self): | ||||
""" | ||||
Monitor the queue for records, and ask the handler | ||||
to deal with them. | ||||
This method runs on a separate, internal thread. | ||||
The thread will terminate if it sees a sentinel object in the queue. | ||||
""" | ||||
q = self.queue | ||||
has_task_done = hasattr(q, 'task_done') | ||||
while not self._stop.isSet(): | ||||
try: | ||||
record = self.dequeue(True) | ||||
if record is self._sentinel: | ||||
break | ||||
self.handle(record) | ||||
if has_task_done: | ||||
q.task_done() | ||||
except queue.Empty: | ||||
pass | ||||
# There might still be records in the queue. | ||||
while True: | ||||
try: | ||||
record = self.dequeue(False) | ||||
if record is self._sentinel: | ||||
break | ||||
self.handle(record) | ||||
if has_task_done: | ||||
q.task_done() | ||||
except queue.Empty: | ||||
break | ||||
def enqueue_sentinel(self): | ||||
""" | ||||
This is used to enqueue the sentinel record. | ||||
The base implementation uses put_nowait. You may want to override this | ||||
method if you want to use timeouts or work with custom queue | ||||
implementations. | ||||
""" | ||||
self.queue.put_nowait(self._sentinel) | ||||
def stop(self): | ||||
""" | ||||
Stop the listener. | ||||
This asks the thread to terminate, and then waits for it to do so. | ||||
Note that if you don't call this before your application exits, there | ||||
may be some records still left on the queue, which won't be processed. | ||||
""" | ||||
self._stop.set() | ||||
self.enqueue_sentinel() | ||||
self._thread.join() | ||||
self._thread = None | ||||