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

celery.log

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

Loglevel -> Color mapping.

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.

fileno()
flush()

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

isatty()

Always returns False. Just here for file support.

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