基于 LangChain 与 LLM 的私有化文档搜索方案
大语言模型(LLM)的底模通常基于公开且过期的数据训练,对于新产生的知识或企业私有数据,LLM 往往无法准确作答,容易产生'幻觉'。针对这一问题,检索增强生成(RAG, Retrieval-Augmented Generation)是主流的解决方案。通过 RAG,我们可以将私有知识库作为上下文提供给 LLM,从而在不重新训练模型的情况下提升回答的准确性和时效性。
本文将详细介绍如何使用 LangChain 框架结合 LLM 快速构建一个私有化文档搜索工具。LangChain 是目前 LLM 应用开发的首选框架之一,提供了丰富的组件来简化文档处理、向量存储和检索流程。
1. RAG 检索核心流程
使用 LangChain 实现私有化文档搜索主要包含以下六个步骤:
- 文档加载:读取本地文件(如 PDF、Word、TXT)。
- 文档分割:将长文本切分为适合嵌入的小块(Chunks)。
- 文档嵌入:将文本块转换为高维向量表示。
- 向量化存储:将向量存入向量数据库(如 FAISS、Chroma)。
- 文档检索:根据用户问题检索最相关的文档块。
- 生成回答:将检索结果作为上下文输入 LLM 生成最终答案。
该流程确保了系统能够基于特定领域知识进行问答,同时避免了全量数据的传输成本。
2. 代码实践细节
2.1 环境准备
首先确保已安装必要的依赖库。以 Python 环境为例:
pip install langchain langchain-community langchain-openai faiss-cpu
2.2 文档加载
我们需要加载私有文档数据。支持多种格式,本文以 PDF 为例。使用 PyPDFLoader 可以方便地解析 PDF 内容。
from langchain_community.document_loaders import PyPDFLoader
loader = PyPDFLoader("./GV2.pdf")
docs = loader.load()
print(f"加载了 {len(docs)} 个文档片段")
2.3 文档分割
原始文档通常较长,直接嵌入会导致信息丢失或超出 Token 限制。因此需要按句子或固定长度进行分割。RecursiveCharacterTextSplitter 是 LangChain 推荐的分割器,它支持递归分割策略,能更好地保留语义完整性。
关键参数说明:
chunk_size: 每个分块的最大字符数。
chunk_overlap: 分块之间的重叠字符数,有助于保持上下文连贯。
separators: 优先使用的分割符列表。
from langchain.text_splitter import RecursiveCharacterTextSplitter
text_splitter = RecursiveCharacterTextSplitter(
chunk_size=500,
chunk_overlap=50,
separators=["\n", "。", "!", "?", ",", "、", " ", ""]
)
texts = text_splitter.split_documents(docs)
print(f"分割后共 {len(texts)} 个文本块")
2.4 文档嵌入 (Embeddings)
为了进行相似度搜索,需要将文本转换为向量。这里使用 OpenAI 兼容的 Embedding 接口。在实际生产环境中,可选择本地部署的 Embedding 模型(如 BGE、M3E)以保护数据隐私。
from langchain_openai import OpenAIEmbeddings
embeddings_model = OpenAIEmbeddings(
openai_api_key="sk-xxxxxxxxxxx",
openai_api_base="https://api.302.ai/v1",
)
txts = [txt.page_content for txt in texts]
embeddings = embeddings_model.embed_documents(txts[:5])
print(f"向量维度:{len(embeddings[0])}")
2.5 文档向量化存储
向量数据库用于高效存储和检索高维向量。FAISS 是 Facebook 开源的高性能向量检索库,适合单机部署。LangChain 提供了对 FAISS 的直接封装。
from langchain_community.vectorstores import FAISS
import os
db = FAISS.from_documents(texts, embeddings_model)
save_path = "faiss_db"
if not os.path.exists(save_path):
os.makedirs(save_path)
FAISS.save_local(db, save_path)
print(f"向量库已保存至 {save_path}")
2.6 文档检索
当用户提问时,系统需计算问题向量并在数据库中查找相似文档。LangChain 支持多种检索模式:
similarity: 基础余弦相似度。
mmr: 最大边际相关性,兼顾相关性和多样性。
score_threshold: 设置阈值过滤低置信度结果。
本文演示基础检索模式,并拼接上下文。
from langchain.retrievers.multi_query import MultiQueryRetriever
retriever = db.as_retriever(search_type="similarity", search_kwargs={"k": 3})
question = "张学立是谁?"
context_docs = retriever.get_relevant_documents(query=question)
_context = ""
for i, doc in enumerate(context_docs):
_context += f"来源{i+1}: {doc.page_content}\n"
print(f"检索到 {len(context_docs)} 条相关内容")
2.7 调用 LLM 生成回答
最后一步是将检索到的上下文注入 Prompt,引导 LLM 基于事实回答问题。使用 ChatPromptTemplate 可以灵活定义对话结构。
from langchain.prompts import ChatPromptTemplate
from langchain_core.output_parsers import StrOutputParser
from langchain_openai import ChatOpenAI
model = ChatOpenAI(
model_name="gpt-3.5-turbo",
openai_api_key="sk-xxxxxxx",
openai_api_base="https://api.302.ai/v1",
temperature=0.0
)
template = [
(
"system",
"你是一个专业的文档助手。请严格根据下方<context>标签内的上下文内容回答问题。如果上下文中没有相关信息,请直接告知无法回答,不要编造。\n<context>{context}</context>"
),
("human", "{question}")
]
prompt = ChatPromptTemplate.from_messages(template)
messages = prompt.format_messages(context=_context, question=question)
response = model.invoke(messages)
output_parser = StrOutputParser()
final_answer = output_parser.invoke(response)
print(f"回答:{final_answer}")
2.8 完整代码整合
将上述步骤整合为一个完整的脚本,便于部署和维护。
from langchain_openai import ChatOpenAI, OpenAIEmbeddings
from langchain_community.document_loaders import PyPDFLoader
from langchain.text_splitter import RecursiveCharacterTextSplitter
from langchain_community.vectorstores import FAISS
from langchain.prompts import ChatPromptTemplate
from langchain_core.output_parsers import StrOutputParser
API_KEY = "sk-xxxxxxx"
API_BASE = "https://api.302.ai/v1"
MODEL_NAME = "gpt-3.5-turbo"
DOC_PATH = "./GV2.pdf"
DB_PATH = "./faiss_db"
embeddings = OpenAIEmbeddings(openai_api_key=API_KEY, openai_api_base=API_BASE)
llm = ChatOpenAI(model_name=MODEL_NAME, openai_api_key=API_KEY, openai_api_base=API_BASE)
loader = PyPDFLoader(DOC_PATH)
docs = loader.load()
splitter = RecursiveCharacterTextSplitter(chunk_size=500, chunk_overlap=50)
texts = splitter.split_documents(docs)
try:
db = FAISS.load_local(DB_PATH, embeddings, allow_dangerous_deserialization=True)
except:
db = FAISS.from_documents(texts, embeddings)
db.save_local(DB_PATH)
retriever = db.as_retriever(search_kwargs={"k": 3})
query = "张学立是谁?"
context_docs = retriever.get_relevant_documents(query=query)
_context = "\n".join([d.page_content for d in context_docs])
prompt = ChatPromptTemplate.from_messages([
("system", "根据上下文回答:\n<context>{context}</context>"),
("human", "{question}")
])
chain = prompt | llm | StrOutputParser()
result = chain.invoke({: _context, : query})
(result)
3. 优化与扩展建议
3.1 检索策略优化
- 混合检索:结合关键词检索(BM25)与向量检索,提高召回率。
- 重排序(Re-ranking):在初步检索后使用 Cross-Encoder 模型对结果进行精排,提升 Top-K 质量。
- 元数据过滤:在向量库中增加文档来源、时间等元数据,支持更精细的筛选。
3.2 性能调优
- 批量嵌入:对于大量文档,建议使用异步批量调用 Embedding API 以减少延迟。
- 缓存机制:对相同的查询结果进行缓存,避免重复检索消耗 Token。
- 流式输出:在生成回答时使用 Stream Output,提升用户体验。
3.3 安全与隐私
- 本地部署:敏感数据场景建议部署本地 Embedding 模型及 LLM(如 Ollama + vLLM)。
- 权限控制:在检索层增加用户权限校验,防止未授权访问特定文档。
4. 总结
通过 LangChain 框架,开发者可以快速搭建基于 RAG 的私有化文档搜索系统。该方案有效解决了通用大模型在垂直领域知识上的不足,实现了低成本、高效率的知识问答能力。在实际应用中,可根据业务需求调整分块策略、检索算法及模型选型,以达到最佳效果。