This document describes Celery 2.4. For development docs, go here.

celery.log

class celery.log.ColorFormatter(msg, use_color=True)
COLORS = {'blue': <bound method colored.blue of ''>, 'black': <bound method colored.black of ''>, 'yellow': <bound method colored.yellow of ''>, 'cyan': <bound method colored.cyan of ''>, 'green': <bound method colored.green of ''>, 'magenta': <bound method colored.magenta of ''>, 'white': <bound method colored.white of ''>, 'red': <bound method colored.red of ''>}

Loglevel -> Color mapping.

colors = {'DEBUG': <bound method colored.blue of ''>, 'CRITICAL': <bound method colored.magenta of ''>, 'WARNING': <bound method colored.yellow of ''>, 'ERROR': <bound method colored.red of ''>}
format(record)
formatException(ei)
class celery.log.Logging(app)
colored(logfile=None)
get_default_logger(loglevel=None, name='celery')

Get default logger instance.

Parameters:loglevel – Initial log level.
get_task_logger(loglevel=None, name=None)
redirect_stdouts_to_logger(logger, loglevel=None, stdout=True, stderr=True)

Redirect sys.stdout and sys.stderr to a logging instance.

Parameters:
  • logger – The logging.Logger instance to redirect to.
  • loglevel – The loglevel redirected messages will be logged as.
setup_logger(loglevel=None, logfile=None, format=None, colorize=None, name='celery', root=True, app=None, **kwargs)

Setup the multiprocessing logger.

If logfile is not specified, then sys.stderr is used.

Returns logger object.

setup_logging_subsystem(loglevel=None, logfile=None, format=None, colorize=None, **kwargs)
setup_task_logger(loglevel=None, logfile=None, format=None, colorize=None, task_name=None, task_id=None, propagate=False, app=None, **kwargs)

Setup the task logger.

If logfile is not specified, then sys.stderr is used.

Returns logger object.

supports_color(logfile=None)
class celery.log.LoggingProxy(logger, loglevel=None)

Forward file object to logging.Logger instance.

Parameters:
  • logger – The logging.Logger instance to forward to.
  • loglevel – Loglevel to use when writing messages.
close()

When the object is closed, no write requests are forwarded to the logging object anymore.

closed = False
fileno()
flush()

This object is not buffered so any flush() requests are ignored.

isatty()

Always returns False. Just here for file support.

loglevel = 40
mode = 'w'
name = None
write(data)
writelines(sequence)

writelines(sequence_of_strings) -> None.

Write the strings to the file.

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

class celery.log.SilenceRepeated(action, max_iterations=10)

Only log action every n iterations.