Mri*_*lla 13 python django celery django-celery
我有一个小脚本,将任务排入队列.此脚本生成大量数据库查询以获取应入队的项目.我面临的问题是,芹菜工人一旦被剧本排队就开始接收任务.这是正确的,这是芹菜应该工作的方式,但这往往导致我的脚本和芹菜工人之间的僵局.
有没有办法可以从脚本中排除我的所有任务,但延迟执行直到脚本完成或直到固定的时间延迟？
我在芹菜或django-芹菜的文件中找不到这个.这可能吗？
目前作为一个快速修复我想到将要处理的所有项目添加到列表中,当我的脚本完成所有查询后,我可以简单地遍历列表并将任务排队.也许这会解决问题,但是当你有数千个物品入队时,这可能是一个坏主意.
mhe*_*her 15
eta/countdown选项可以延迟任务执行:
http://docs.celeryproject.org/en/master/userguide/calling.html#eta-and-countdown
| 归档时间： |
|
| 查看次数： |
19603 次 |
| 最近记录： |