大佬给指条明路.
rabbitmq 好好的. 因为 beat 不停的发消息. 成功的.
现在是消费者挂了,但是进程还在啊.
rabbitmq 好好的. 因为 beat 不停的发消息. 成功的.
现在是消费者挂了,但是进程还在啊.
|
northislandDec 17, 2020
1
|
|
northislandDec 17, 2020
2
@celery.task
的函数可以直接运行,不用连队列。 |
|
4everLoveUDec 17, 2020
3
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 ``` |
|
cz5424Dec 17, 2020 via iPhone
4
看看是不是有耗时很久的队列,一直卡着走不动,比如 requests 没写 timeout
|
|
simple2025Dec 17, 2020
5
有什么 log?
|
|
abersheeranDec 18, 2020
6
Celery 可以让你自己写代码反馈 Task 的进度,用这个 DEBUG,你就知道它卡在哪儿了。
|
|
seven123Dec 18, 2020
7
之前用过 celery 貌似不太稳定?,可能会出现内存泄露的事情, 所以我会加上这个参数 。
celery 在长时间运行后可能出现内存泄漏,每个 worker 执行 5 个任务就死掉 CELERYD_MAX_TASKS_PER_CHILD = 5 |
|
HashV2Dec 18, 2020
8
|
|
rSP0rcaA9K11RjszDec 25, 2020
9
进 flower 看一下每个 worker 的情况,7 楼的情况也有可能
|