栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Python

【celery 内存泄漏问题的排查->task

Python 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

【celery 内存泄漏问题的排查->task

项目场景:

提示:通过celery执行大量爬虫任务。


问题描述

提示:celery 的 worker每运行半小时就会重启,python3.8.7 celery5.2.3 redis作为中间人

@celery_app.task(soft_time_limit=60)  # time_limit 设置硬超时时间
def test(xxx):
    ...

原因分析:

提示:由于celery worker是在腾讯云集群上运行的,查看pod运行的资源监控图

pod limit设置为200Mi-800Mi,可以看到差不多半小时达到1000Mi后就pod就开始重启,内存泄漏应该就是造成pod不断重启的原因。


解决方案:

提示:1.google大法搜一搜,发现这个

不过是2013年的不知道还行不行。

2.再去celery github上看看

在issuess搜索oom,可以看到关于内存泄漏大量的bug反馈。
有说5.2.3已经修复了一个小泄漏(PS:看来还不是一个地方有问题),不过我们已经是最新版本了。

再继续看看,发现这个

可以看到13年到18年这个问题竟然还存在,我们可以去掉这个软硬时间试试看。

@celery_app.task  # 不再设置软硬超时时间
def test():
    ...

3.修改代码如上,更新到pod
运行一段时间后发现没有重启了,我们查看资源情况,如图

可以看到已经不会出现内存泄漏的问题。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/767969.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号