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

celery.log

celery.log

class celery.log.ColorFormatter(msg, use_color=True)
COLORS

Loglevel -> Color mapping.

colors
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)

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.

Previous topic

celery.routes

Next topic

celery.events.snapshot

This Page