如何定期清除 celery rabbitmq 中的队列？

Question

我如何定期清除 celery 队列，比如在队列中有任何未完成的任务后每分钟清除一次，然后我需要在一分钟后清除所有这些任务。我该怎么做呢？

Answer 1

您可以设置time_limit任务在一定时间后杀死它。 芹菜时间限制

@app.task(time_limit=60)

def long_running_task():

    ...