我如何定期清除 celery 隊(duì)列，比如在隊(duì)列中有任何未完成的任務(wù)后每分鐘清除一次，然后我需要在一分鐘后清除所有這些任務(wù)。我該怎么做呢？
2 回答
qq_笑_17
TA貢獻(xiàn)1818條經(jīng)驗(yàn) 獲得超7個(gè)贊
您可以設(shè)置time_limit任務(wù)在一定時(shí)間后殺死它。 芹菜時(shí)間限制
@app.task(time_limit=60)
def long_running_task():
...
添加回答
舉報(bào)
0/150
提交
取消