AllenNLP predictor提前加载导致脚本挂起及日志锁死问题咨询
成因分析
- 日志提前输出+锁死的原因:Hugging Face Transformers库的警告默认输出到标准错误流(stderr),stderr默认无缓冲会立刻写入文件;而Python默认将标准输出流(stdout)设置为块缓冲(尤其是重定向到日志文件时),你写的print语句内容会暂存在缓冲区中,直到进程结束才统一输出,就会出现警告先出、后续日志卡住的假象。
- 内存异常占用的原因:你将
Predictor.from_path()放在自定义函数内部,每次调用函数都会重新加载一次大小超过1G的SpanBERT预训练模型,重复加载会导致内存快速堆积;就算只调用一次,大模型本身加载到内存也会占用数GB空间,属于正常现象但可以优化。 - 额外说明:你看到的权重未初始化警告是正常现象,SpanBERT预训练时未训练pooler层,而AllenNLP共指模型也不会用到这部分权重,完全不影响推理效果。
解决方案
1. 修复日志无法实时输出的问题
- 运行脚本时添加
-u参数禁用Python输出缓冲,示例命令:
python -u your_script_name.py > run.log 2>&1
- 也可以在所有print语句中添加flush参数强制刷新缓冲区:
print("HERE TEST", flush=True)
- 如需屏蔽无关的权重警告,可在最开头导入模块前添加警告过滤规则:
import warnings warnings.filterwarnings("ignore", message="Some weights of BertModel were not initialized")
2. 优化内存占用
- 核心修改:将Predictor初始化逻辑移到函数外部,全局仅加载一次模型,避免重复加载浪费内存,修改后代码示例:
import warnings from allennlp.predictors.predictor import Predictor import allennlp_models.tagging import pandas as pd # 屏蔽无关警告 warnings.filterwarnings("ignore", message="Some weights of BertModel were not initialized") # 全局仅加载一次模型 predictor = Predictor.from_path("https://storage.googleapis.com/allennlp-public-models/coref-spanbert-large-2021.03.10.tar.gz") print("HERE TEST", flush=True) def predictorFunc(article): resolved_object = predictor(document=article) ### 其他集群处理逻辑 ### return resolved_object['document'] df = pd.read_csv('articles.csv') ### 其他pandas处理逻辑 ### resolved_text = predictorFunc(article_pre_resolved)
- 若使用CPU运行,可开启半精度加载减少内存占用;如有GPU资源,指定GPU推理可同时提升速度和内存利用率。
- 大批量处理数据时分批加载、分批落盘,避免全量数据堆积在内存中。
内容的提问来源于stack exchange,提问作者JoshuaYLevy
相关产品推荐
相关产品推荐

