我使用码头运行芹菜+红葡萄酒+烧瓶,我想知道有多少任务等待执行芹菜。我试图用命令在redis中找到信息。
keys *我得到了结果:
127.0.0.1:6379> keys *
1) "unacked_mutex"
2) "_kombu.binding.celeryev"
3) "unacked_index"
4) "_kombu.binding.celery.pidbox"
5) "_kombu.binding.celery"
6) "unacked"这些物品中没有一个似乎包含芹菜队列信息。我怎样才能读出芹菜的队列大小?
这是芹菜编码:
from celery import Celery
import time
app = Celery('tasks', broker='redis://redis:6379')
@app.task
def sleeptest():
time.sleep(100)我就是这样提交芹菜工作的:
import tasks
import time
tasks.sleeptest.delay()
time.sleep(1)
tasks.sleeptest.delay()
time.sleep(1)
tasks.sleeptest.delay()
time.sleep(1)
tasks.sleeptest.delay()
time.sleep(1)
tasks.sleeptest.delay()
time.sleep(1)当我发布100个任务时,就会出现芹菜队列。但是,当我只发布5个任务时,芹菜队列没有显示,尽管我将并发设置为1和4个任务实际上正在等待。
发布于 2019-12-18 09:17:23
这些信息被深深地埋藏在芹菜文档中-- 监视redis队列。如果您什么也没看到,这意味着这些任务要么已经完成,要么正在运行,要么已经被保留(请查看有关乘数的详细信息)。
https://stackoverflow.com/questions/59386049
复制相似问题