【发布时间】:2017-08-05 00:56:31
【问题描述】:
我正在尝试使用 scikit-learn 对大量文本文档进行分类,尽管我使用的是核心功能(SGDClassifier 和 HashingVectorizer),但该程序似乎消耗了很多内存 (>10GB)。在此之前,我执行了词形还原并从文本数据中删除了停用词。我觉得我在这里错过了一些重要的东西。你能在我的代码中发现一个错误吗?
非常感谢您的任何建议!
这是我的python代码:
import time
import numpy as np
import os
import re
import pyprind
from sklearn.feature_extraction.text import HashingVectorizer
from sklearn.linear_model import SGDClassifier
from sklearn.naive_bayes import MultinomialNB
from sklearn import metrics
directory = "mydirectory"
batch_size = 1000
n_batches = 44
pbar = pyprind.ProgBar(n_batches)
class Doc_Iterable:
def __init__(self, file):
self.file = file
def __iter__(self):
for line in self.file:
line = re.sub('[^\w\s]|(.\d{1,4}[\./]\d{1,2}[\./]\d{1,4})|(\s\d{1,})', '', line)
yield line
def stream_docs(path, texts_file, labels_file):
with open(path + texts_file, 'r') as fX, open(path + labels_file, 'r') as fy:
for text in fX:
label = next(fy)
text = re.sub('[^\w\s]|(.\d{1,4}[\./]\d{1,2}[\./]\d{1,4})|(\s\d{1,})', '', text)
yield text, label
def get_minibatch(doc_stream, size):
X, y = [], []
for _ in range(size):
text, label = next(doc_stream)
X.append(text)
y.append(label)
return X, y
classes = set()
for label in open(directory + 'y_train', 'r'):
classes.add(label)
for label in open(directory + 'y_test', 'r'):
classes.add(label)
classes = list(classes)
validation_scores = []
training_set_size = []
h_vectorizer = HashingVectorizer(lowercase=True, ngram_range=(1,1))
clf = SGDClassifier(loss='hinge', n_iter=5, alpha=1e-4, shuffle=True)
doc_stream = stream_docs(path=directory, texts_file='X_train', labels_file='y_train')
n_samples = 0
iteration = 0
for _ in range(n_batches):
print("Training with batch nr.", iteration)
iteration += 1
X_train, y_train = get_minibatch(doc_stream, size=batch_size)
n_samples += len(X_train)
X_train = h_vectorizer.transform(X_train)
clf.partial_fit(X_train, y_train, classes=classes)
pbar.update()
del X_train
del y_train
print("Training complete. Classifier trained with " + str(n_samples) + " samples.")
print()
print("Testing...")
print()
X_test = h_vectorizer.transform(Doc_Iterable(open(directory + 'X_test')))
y_test = np.genfromtxt(directory + 'y_test', dtype=None, delimiter='|').astype(str)
prediction = clf.predict(X_test)
score = metrics.accuracy_score(y_test, prediction)
print("Accuracy: ", score)
print()
【问题讨论】:
-
您的数据集的总大小是多少:44000 个文档?您是否尝试过将 HashingVectorizer 应用于完整数据集?根据我的经验,从 700000 封文本电子邮件中提取特征而不使用核心方法需要不到 16GB 的 RAM,所以你的数字非常大。除非文件很长。减少特征的数量无论如何都不会显着改变它,因为它是稀疏数组,几乎没有哈希冲突(我不同意下面的回复)。
-
谢谢。我有 300 万份文档,我可能需要在预处理方面做更多工作以减少特征数量/词汇量。使用 Tf-idf 似乎可以很好地处理最多 1GB 的文本文件的子集作为输入。我也将尝试使用
HashingVectorizer而不进行核外学习... -
300 万个文档相当大。您应该使用
memory_profiler进行逐行分析,以了解内存分配(或未释放)的位置。如果是脚本,用python -m memory_profiler运行就足够了……
标签: python scikit-learn text-classification