django - 使用 Django 的 call 命令用 celerybeat 启动 celery worker

Question

我想用 celerybeat 从 Python 脚本启动一个 Django celery worker。在命令行上，我会这样做：

python manage.py celery worker --beat --schedule celerybeat-schedule.db

我从一个脚本中尝试了这个，但它抛出了一个异常：

from django.core.management import call_command
call_command("cerlery", "worker", "--beat", "--schedule", "celerybeat-schedule.db")

Answer 1

我倾向于这样做..

./manage.py celeryd --event --beat --loglevel=INFO --logfile=./celeryd.log

然后运行相机..

./manage.py celeryev --camera=djcelery.snapshot.Camera --logfile=./celeryev.log 

希望这可以帮助。

Answer 2

我通过这样做来解决它：

from djcelery.management.commands import celery
args = ['manage.py', 'celery', 'worker', '--beat', '--schedule',
        'celerybeat-schedule']
command = celery.Command()
command.run_from_argv(args)

但如果可以使用call_command，我想知道如何使用。