This document describes the current stable version of Celery (4.0). For development docs, go here.

celery.utils.log

Logging utilities.

class celery.utils.log.ColorFormatter(fmt=None, use_color=True)[source]

Logging formatter that adds colors based on severity.

COLORS = {u'blue': <bound method colored.blue of u''>, u'black': <bound method colored.black of u''>, u'yellow': <bound method colored.yellow of u''>, u'cyan': <bound method colored.cyan of u''>, u'green': <bound method colored.green of u''>, u'magenta': <bound method colored.magenta of u''>, u'white': <bound method colored.white of u''>, u'red': <bound method colored.red of u''>}
colors = {u'DEBUG': <bound method colored.blue of u''>, u'CRITICAL': <bound method colored.magenta of u''>, u'WARNING': <bound method colored.yellow of u''>, u'ERROR': <bound method colored.red of u''>}
format(record)[source]
formatException(ei)[source]
class celery.utils.log.LoggingProxy(logger, loglevel=None)[source]

Forward file object to logging.Logger instance.

Parameters:
  • logger (Logger) – Logger instance to forward to.
  • loglevel (int, str) – Log level to use when logging messages.
close()[source]
closed = False
flush()[source]
isatty()[source]

Here for file support.

loglevel = 40
mode = u'w'
name = None
write(data)[source]

Write message to logging object.

writelines(sequence)[source]

Write list of strings to file.

The sequence can be any iterable object producing strings. This is equivalent to calling write() for each string.

celery.utils.log.set_in_sighandler(value)[source]

Set flag signifiying that we’re inside a signal handler.

celery.utils.log.in_sighandler(*args, **kwds)[source]

Context that records that we are in a signal handler.

celery.utils.log.get_logger(name)[source]

Get logger by name.

celery.utils.log.get_task_logger(name)[source]

Get logger for task module by name.

celery.utils.log.mlevel(level)[source]

Convert level name/int to log level.

celery.utils.log.get_multiprocessing_logger()[source]

Return the multiprocessing logger.

celery.utils.log.reset_multiprocessing_logger()[source]

Reset multiprocessing logging setup.