Celery worker 在从其他队列消费时停止从特定队列消费

Celery worker stops consuming from a specific queue while it consumes from other queues

我正在使用 rabbitmq 作为代理,有一个奇怪的行为只发生在我的生产环境中。有时我的芹菜会随机停止从队列中消费消息,而它从其他队列中消费。

这会导致队列中的消息堆积,如果我重新启动我的 celeryd,一切都会开始正常工作。

"/var/logs/celeryd/worker" 不表示任何错误。我什至不知道从哪里开始寻找,因为我是 python/django.

的新手

任何帮助将不胜感激。

我在我的代码中发现了问题,

所以在我的一项任务中,我打开了一个连接来使用挂起的 urllib3 进行解析。

在异步任务中移出该部分后,现在一切正常。