我刚刚开始了一个项目,试图启动一个非常简单的 Django Celery 项目。因为我主要只是想看看它是如何工作的,所以我的设置如下所示:
BROKER_TRANSPORT = "django"
CELERY_ALWAYS_EAGER = True
CELERYBEAT_SCHEDULER = "djcelery.schedulers.DatabaseScheduler"
我已经apply_async()
通过在 Django 管理站点中安排它们来测试发布任务,并且两者都工作得很好。
我目前看到的唯一问题是我需要运行两个单独的进程来测试我的任务,django runserver
并且django celerybeat
. 当我更改周期性任务时,我需要重新启动celerybeat
进程以使其重新加载。有什么方法可以让我运行celerybeat
集成的进程runserver
,以避免必须记住启动另一个进程?