celery worker 跑跑就不工作了. 如何 debug?

[chaleaoch]

大佬给指条明路.

rabbitmq 好好的. 因为 beat 不停的发消息. 成功的.
现在是消费者挂了,但是进程还在啊.

[northisland]

不搞架构，但用过 celery，纯属业余

我记得把 celery.tasks 里的函数，可以直接放在 test.py 的主函数里，按照 log 过一遍可疑的 mq 输入，应该能搞定复现。

[northisland]

@celery.task
的函数可以直接运行，不用连队列。

[4everLoveU]

1 、celery 启动有 debug 模式，打印的内容还是比较详细的；
2 、重载一下 celery.Task，自己实现 on_failure 功能，看看 trace

```python
class CustomTask(celery.Task):

...

def on_failure(self, exc, event_id, args, kwargs, einfo):
# do something
```

[cz5424]

看看是不是有耗时很久的队列，一直卡着走不动，比如 requests 没写 timeout

[chenqh]

有什么 log?

[abersheeran]

Celery 可以让你自己写代码反馈 Task 的进度，用这个 DEBUG，你就知道它卡在哪儿了。

[seven123]

之前用过 celery 貌似不太稳定？，可能会出现内存泄露的事情， 所以我会加上这个参数 。
celery 在长时间运行后可能出现内存泄漏，每个 worker 执行 5 个任务就死掉
CELERYD_MAX_TASKS_PER_CHILD = 5

[HashV2]

@chaleaoch task 中直接 print 出来任务执行相关情况 celery 启动的时候添加-f 参数指定日志文件 有问题及时查看日志

@seven123 不错的参数 加上了

[nano91]

进 flower 看一下每个 worker 的情况，7 楼的情况也有可能