# -*- coding: utf-8 -*-
# Copyright (c) 2010-2014, GEM Foundation.
#
# OpenQuake is free software: you can redistribute it and/or modify it
# under the terms of the GNU Affero General Public License as published
# by the Free Software Foundation, either version 3 of the License, or
# (at your option) any later version.
#
# OpenQuake is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU Affero General Public License
# along with OpenQuake. If not, see <http://www.gnu.org/licenses/>.
"""
Set up some system-wide loggers
"""
import logging
from contextlib import contextmanager
# Place the new level between info and warning
logging.PROGRESS = 25
logging.addLevelName(logging.PROGRESS, "PROGRESS")
LEVELS = {'debug': logging.DEBUG,
'info': logging.INFO,
'warn': logging.WARNING,
'progress': logging.PROGRESS,
'error': logging.ERROR,
'critical': logging.CRITICAL}
LOG_FORMAT = ('[%(asctime)s %(job_type)s job #%(job_id)s %(hostname)s '
'%(levelname)s %(processName)s/%(process)s] %(message)s')
LOG = logging.getLogger()
def _log_progress(msg, *args, **kwargs):
"""
Log the message using the progress reporting logging level.
``args`` and ``kwargs`` are the same as :meth:`logging.Logger.debug`,
except that this method has an additional possible keyword: ``indent``.
Normally, progress messages are logged with a '** ' prefix. If ``indent``
is `True`, messages will be logged with a '** >' prefix.
If ``indent`` is not specified, it will default to `False`.
"""
indent = kwargs.get('indent')
if indent is None:
indent = False
else:
# 'indent' is an invalid kwarg for the logger's _log method
# we need to remove it before we call _log:
del kwargs['indent']
if indent:
prefix = '** >'
else:
prefix = '** '
msg = '%s %s' % (prefix, msg)
LOG._log(logging.PROGRESS, msg, args, **kwargs)
LOG.progress = _log_progress
[docs]def set_level(level):
"""
Initialize logs to write records with level `level` or above.
"""
logging.root.setLevel(LEVELS.get(level, logging.WARNING))
def _update_log_record(self, record):
"""
Massage a log record before emitting it. Intended to be used by the
custom log handlers defined in this module.
"""
if not hasattr(record, 'hostname'):
record.hostname = '-'
if not hasattr(record, 'job_type'):
record.job_type = self.job_type
if not hasattr(record, 'job_id'):
record.job_id = self.job.id
[docs]class LogStreamHandler(logging.StreamHandler):
"""
Log stream handler
"""
def __init__(self, job):
super(LogStreamHandler, self).__init__()
self.setFormatter(logging.Formatter(LOG_FORMAT))
self.job_type = job.job_type
self.job = job
[docs] def emit(self, record): # pylint: disable=E0202
_update_log_record(self, record)
super(LogStreamHandler, self).emit(record)
[docs]class LogFileHandler(logging.FileHandler):
"""
Log file handler
"""
def __init__(self, job, log_file):
super(LogFileHandler, self).__init__(log_file)
self.setFormatter(logging.Formatter(LOG_FORMAT))
self.job_type = job.job_type
self.job = job
self.log_file = log_file
[docs] def emit(self, record): # pylint: disable=E0202
_update_log_record(self, record)
super(LogFileHandler, self).emit(record)
@contextmanager
[docs]def handle(job, log_level='info', log_file=None):
"""
Context manager adding and removing log handlers.
:param job:
a :class:`openquake.engine.db.models.OqJob` instance
:param log_level:
one of debug, info, warn, progress, error, critical
:param log_file:
log file path (if None, logs on stdout only)
"""
handler = (LogFileHandler(job, log_file) if log_file
else LogStreamHandler(job))
logging.root.addHandler(handler)
set_level(log_level)
try:
yield
finally:
logging.root.removeHandler(handler)
[docs]class tracing(object):
"""
Simple context manager util to handle tracing. E.g.
with log("exports"):
do_export()
"""
def __init__(self, msg):
self.msg = msg
def __enter__(self):
LOG.debug('starting ' + self.msg)
def __exit__(self, *args):
LOG.debug('ending ' + self.msg)