691 字

3 分钟

LangChain链路与会话历史

2026-04-28

LangChain

/

项目实战

/

Prompt

/

MessageHistory

/

SQLite

LangChain链路与会话历史#

本篇聚焦项目中的 LangChain 初始化部分，重点不是“如何写出一条最短链”，而是看 ChatPromptTemplate、SQLChatMessageHistory 与 RunnableWithMessageHistory 在真实项目里是如何组合起来的。

三个核心对象#

1. ChatPromptTemplate#

1
prompt = ChatPromptTemplate.from_messages([
2
    # ① system 消息：每次都发给模型，设定人格和能力范围
3
    ('system', "你是一个强大的多模态AI助手，可以精准地处理文本和图像输入。"),
4

5
    # ② 历史占位符：运行时被替换为真实的历史消息列表
6
    #    variable_name 必须与 invoke({'messages': [...]}) 的键名一致
7
    MessagesPlaceholder(variable_name="messages"),
8
])

MessagesPlaceholder 的作用
它是一个「空位」，告诉 LangChain：

调用时把 messages 参数的值插到这里

RunnableWithMessageHistory 会在这个位置前自动插入历史消息

实际发给模型的消息结构：
1
[system]  你是一个强大的多模态AI助手...
2
[user]    （历史消息1）
3
[assistant]（历史回复1）
4
[user]    （历史消息2）
5
[assistant]（历史回复2）
6
  ...
7
[user]    （本轮新消息）  ← invoke() 传入的 messages

2. Chain 组合（管道符 `|`）#

1
chain = prompt | multiModal_llm

| 是 LangChain 的管道操作符，等价于：

1
# 手动写就是这样，但用 | 更简洁
2
def chain(input):
3
    prompt_value = prompt.format_messages(**input)
4
    return multiModal_llm.invoke(prompt_value)

数据流向：

1
用户输入字典
2
    → prompt 模板渲染（填入 system + 历史 + 当前消息）
3
    → multiModal_llm 调用（发给阿里云 API）
4
    → AIMessage 对象（包含回复文字）

3. get_session_history#

1
def get_session_history(session_id: str) -> SQLChatMessageHistory:
2
    return SQLChatMessageHistory(
3
        session_id=session_id,
4
        connection='sqlite:///chat_history.db',
5
    )

这个函数什么时候被调用？
RunnableWithMessageHistory 在每次 invoke 时自动调用它：

调用前：用 session_id 查数据库，取出历史消息注入 Prompt

调用后：把新的 user + assistant 消息写回数据库

你不需要手动调这个函数，只是把它作为「工厂函数」传给框架。

SQLite 连接字符串格式

1
sqlite:///相对路径.db    → 相对于当前工作目录
2
sqlite:////绝对路径.db   → 四个斜杠

4. RunnableWithMessageHistory#

1
chain_history = RunnableWithMessageHistory(
2
    chain,              # 要包装的链
3
    get_session_history # 如何获取历史存储对象
4
)
5

6
config = {"configurable": {"session_id": "usr000"}}

调用方式：

1
resp = chain_history.invoke(
2
    {'messages': [input_message]},  # 只传本轮新消息！历史由框架自动加载
3
    config                           # 指定 session_id
4
)

当前代码的限制：session_id 硬编码
1
config = {"configurable": {"session_id": "usr000"}}
所有用户共享同一段历史，适合单用户本地使用。
多用户场景的改进方案：
1
import uuid
2
# 每次启动生成新 session（无记忆）
3
config = {"configurable": {"session_id": str(uuid.uuid4())}}
4

5
# 或者根据用户身份生成固定 ID（跨会话记忆）
6
config = {"configurable": {"session_id": f"user_{user_id}"}}

完整调用时序#

相关笔记

LangChain链路与会话历史

https://fuwari.vercel.app/posts/ai/llm/langchain/notes/08_project_case_studies/01_多模态聊天机器人/04_langchain链路与会话历史/

作者

OopsYanxi

发布于

2026-04-28

许可协议

CC BY-NC-SA 4.0

图像处理与多模态消息组装

完整注释代码

1

LangChain链路与会话历史

三个核心对象

1. ChatPromptTemplate

2. Chain 组合（管道符 |）

3. get_session_history

4. RunnableWithMessageHistory

完整调用时序

LangChain链路与会话历史#

三个核心对象#

1. ChatPromptTemplate#

2. Chain 组合（管道符 |）#

3. get_session_history#

4. RunnableWithMessageHistory#

完整调用时序#

2. Chain 组合（管道符 `|`）#