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

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

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

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

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
```

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

有什么 log?

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

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

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

@seven123 不错的参数 加上了

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