发布者终止后，任务在芹菜amqp中徘徊

Question

我使用Celery同一个RabbitMQ服务器。我有一个发布者，该发布者可能会被终止，SIGKILL并且由于无法观看此信号，因此我无法撤消任务。在发布者不再活跃的情况下，撤销任务的常见方法是什么？

我在工作人员端进行了间隔试验，但是发布者显然未注册为工作人员，因此我不知道如何检测到超时

Answer 1

芹菜没有内置任何东西可以监视生产者/发布者的状态，只有工人/消费者的状态。您还可以考虑其他替代方法，例如，使用Redis过期密钥，该密钥必须由发布者定期更新，该发布者可以充当发布者是否还活着的代理。然后在任务中检查是否在redis中仍然存在发布者的标志，如果不是，则该任务返回不执行任何操作。

Answer 2

在我的情况下有效的另一个解决方案是仅在当前处理的任务完成后才添加下一个任务。在这种情况下，队列不会填满。