改进图检索

使用 LangChain 的 Retrieval Augmented Generation (RAG)

Meri Nova

Machine Learning Engineer

技术要点

主要瓶颈:用户 → Cypher 的可靠性

改进图检索系统的策略:

  • 过滤图架构
  • 验证 Cypher 查询
  • 少样本提示
使用 LangChain 的 Retrieval Augmented Generation (RAG)

过滤

from langchain_community.chains.graph_qa.cypher import GraphCypherQAChain

llm = ChatOpenAI(api_key="...", model="gpt-4o-mini", temperature=0)

chain = GraphCypherQAChain.from_llm(
graph=graph, llm=llm, exclude_types=["Concept"], verbose=True
)
print(graph.get_schema)
Node properties:
Document {title: STRING, id: STRING, text: STRING, summary: STRING, source: STRING}
Organization {id: STRING}
使用 LangChain 的 Retrieval Augmented Generation (RAG)

验证 Cypher 查询

  • 难以正确理解关系的方向
chain = GraphCypherQAChain.from_llm(
    graph=graph, llm=llm, verbose=True, validate_cypher=True
)
  1. 识别节点与关系
  2. 判定关系方向
  3. 校验图架构
  4. 纠正关系方向
使用 LangChain 的 Retrieval Augmented Generation (RAG)

少样本提示

examples = [
    {
        "question": "How many notable large language models are mentioned in the article?",
        "query": "MATCH (m:Concept {id: 'Large Language Model'}) RETURN count(DISTINCT m)",
    },
    {
        "question": "Which companies or organizations have developed the large language models mentioned?",
        "query": "MATCH (o:Organization)-[:DEVELOPS]->(m:Concept {id: 'Large Language Model'}) RETURN DISTINCT o.id",
    },
    {
        "question": "What is the largest model size mentioned in the article, in terms of number of parameters?",
        "query": "MATCH (m:Concept {id: 'Large Language Model'}) RETURN max(m.parameters) AS largest_model",
    },
]
使用 LangChain 的 Retrieval Augmented Generation (RAG)

实现少样本提示

from langchain_core.prompts import FewShotPromptTemplate, PromptTemplate

example_prompt = PromptTemplate.from_template( "User input: {question}\nCypher query: {query}" )
cypher_prompt = FewShotPromptTemplate( examples=examples, example_prompt=example_prompt, prefix="You are a Neo4j expert. Given an input question, create a syntactically correct Cypher query to run.\n\nHere is the schema information\n{schema}.\n\n Below are a number of examples of questions and their corresponding Cypher queries.", suffix="User input: {question}\nCypher query: ", input_variables=["question"], )
使用 LangChain 的 Retrieval Augmented Generation (RAG)

完整提示

您是 Neo4j 专家。给定输入问题,生成可执行且语法正确的 Cypher 查询。

下面是一些问题及其对应的 Cypher 查询示例。

User input: How many notable large language models are mentioned in the article?
Cypher query: MATCH (p:Paper) RETURN count(DISTINCT p)

User input: Which companies or organizations have developed the large language models?
Cypher query: MATCH (o:Organization)-[:DEVELOPS]->(m:Concept {id: 'Large Language Model'}) RETURN DISTINCT o.id

User input: What is the largest model size mentioned in the article, in terms of number of parameters?
Cypher query: MATCH (m:Concept {id: 'Large Language Model'}) RETURN max(m.parameters) AS largest_model

User input: How many papers were published in 2016?
Cypher query:
使用 LangChain 的 Retrieval Augmented Generation (RAG)

加入少量示例

chain = GraphCypherQAChain.from_llm(
    graph=graph, llm=llm, cypher_prompt=cypher_prompt,
    verbose=True, validate_cypher=True
)
使用 LangChain 的 Retrieval Augmented Generation (RAG)

Let's practice!

使用 LangChain 的 Retrieval Augmented Generation (RAG)

Preparing Video For Download...