Celery Worker Daemon - celery.bin.celeryd¶

celeryd

-c, --concurrency¶

Number of child processes processing the queue. The default is the number of CPUs available on your system.

-f, --logfile¶

Path to log file. If no logfile is specified, stderr is used.

-l, --loglevel¶

Logging level, choose between DEBUG, INFO, WARNING, ERROR, CRITICAL, or FATAL.

-p, --pidfile¶

Path to pidfile.

-s, --statistics¶

Turn on reporting of statistics (remember to flush the statistics message queue from time to time).

-d, --detach, --daemon¶

Run in the background as a daemon.

-S, --supervised¶

Restart the worker server if it dies.

--discard¶

Discard all waiting tasks before the daemon is started. WARNING: This is unrecoverable, and the tasks will be deleted from the messaging server.

-u, --uid¶

User-id to run celeryd as when in daemon mode.

-g, --gid¶

Group-id to run celeryd as when in daemon mode.

--umask¶

umask of the process when in daemon mode.

--workdir¶

Directory to change to when in daemon mode.

--chroot¶

Change root directory to this path when in daemon mode.

celery.bin.celeryd.acquire_pidlock(pidfile)¶

Get the daemon.pidlockfile.PIDLockFile handler for pidfile.

If the pidfile already exists, but the process is not running the pidfile will be removed, a "stale pidfile" message is emitted and execution continues as normally. However, if the process is still running the program will exit complaning that the program is already running in the background somewhere.

celery.bin.celeryd.install_restart_signal_handler(worker, context)¶

Installs a signal handler that restarts the current program when it receives the SIGHUP signal.

celery.bin.celeryd.parse_options(arguments)¶

Parse the available options to celeryd.

celery.bin.celeryd.run_worker(concurrency=16, detach=False, loglevel=20, logfile='celeryd.log', discard=False, pidfile='celeryd.pid', umask=0, uid=None, gid=None, supervised=False, working_directory=None, chroot=None, statistics=None, **kwargs)¶

Starts the celery worker server.