在我的 Django 项目中，我使用Celery ( docs )、Django-Celery和RabbitMQ作为代理运行一些异步任务。虽然它通常有效，但我的设置有两个问题：
a）任务执行似乎与我的请求线程相结合。因此，用户 http 请求似乎要等到任务执行完毕
b) 任务执行似乎忽略了倒计时标志
出于测试目的，我设置了一个简单的 TestTask：
from celery.task import Task
from celery.registry import tasks
#in project_management.tasks.py
class TestTask(Task):
def run(self, x, y):
print "running TestTask"
return x + y
tasks.register(TestTask)
从控制台中运行此任务会给我以下结果：
python manage.py shell
from project_management.tasks import TestTask
result = TestTask.apply_async(args=[5, 5], kwargs={}, countdown=10)#immediately outputs "running TestTask"
result.result -> immediately returns 10
result.ready() -> immediately returns True
因此设置为 10 的倒计时标志被完全忽略。知道我的设置有什么问题吗？
我使用以下命令启动 Celery 和 RabbitMQ：
RABBITMQ_NODE_PORT=5672 rabbitmq-server
python manage.py celeryd --loglevel=info
更新：
我认为这个问题与时区设置有关。有关更多信息，请参阅此线程。无论如何不知道如何规避它。我执行了这个测试，总是得到与立即可用的结果相同的结果：
>>> from project_management.tasks import add
>>> from datetime import timedelta, datetime
>>> eta = datetime.now() + timedelta(seconds=60)
>>> result = add.apply_async(args=[5, 5], kwargs={}, eta=eta)
>>> result.ready()
True
>>> eta = datetime.utcnow() + timedelta(seconds=60)
>>> result = add.apply_async(args=[5, 5], kwargs={}, eta=eta)
>>> result.ready()
True