python - celery - 倒计时如何工作?

标签 python celery

我想了解提供 countdown=xx 如何影响任务的调度。根据http://docs.celeryproject.org/en/latest/userguide/calling.html?highlight=countdown#eta-and-countdown , 设置倒计时意味着任务至少需要 xx 秒来执行。

我想知道的是它是如何实现的。当我们为任务提供倒计时值时,任务是否已添加到队列中但没有工作人员接收它,或者工作人员接收了任务但推迟了它的执行,直到至少倒计时值到期?

最佳答案

任务由工作人员选择,但未确认。

这意味着如果电量耗尽,稍后将由不同的工作人员重新获取任务。

任务的 args/kwargs 会保存在 worker 的内存中,直到它完成,所以请记住这一点,因为你可能会很快用完大量倒计时任务和大的 args/kwargs。

关于python - celery - 倒计时如何工作?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/18977300/

相关文章:

python - 如何让 python httplib 接受不受信任的证书?

python - `pipenv install -e .` 有什么作用以及如何使用它?

python - 如何追溯函数内引发异常的原因?

django - 如何在 virtualenv 中为 Celery (django-celery) 编写 Ubuntu Upstart 作业

python - os x 10.8.5 上的 Celery WorkerLostError

python - 使用 CDK 的 EKS 部署显示 Kubernetes 版本错误

python - 获取错误 AttributeError : 'WebDriver' object has no attribute 'GoTo' "when executing a python script in selenium

python - Celery 任务的finally 子句不执行,我该如何清理?

python - 碎片化 1.0 : How to run crawler in Celery?

python - celery worker 接收任务,即使我在 RabbitMQ 队列上没有消息