我是我最近部署的kombu/celery 设置。任务执行良好,但似乎几乎连续运行,而不是尊重 run_every 属性。也许更奇怪的是,这种行为只出现在生产中并且在本地运行良好。
我的tasks.py
样子是这样的:
from celery.task import PeriodicTask
from datetime import timedelta, datetime
class FirstTask(PeriodicTask):
run_every = timedelta(seconds = 30)
# Do Stuff
我的settings.py
包括
BROKER_URL = "django://"
import djcelery
djcelery.setup_loader()
加上'djcelery'
和'kombu.transport.django'
在INSTALLED_APPS
。
在生产中,我python manage.py celeryd -v 2 -B -s celery -E -l INFO
开始运行我的任务。如果可以解决其他问题,我一直在关注 Chase Seibert 的教程。