在 LangGraph 中长期记忆是通过Store接口实现的。它与管理单次会话线程的短期记忆Checkpointer是互补的两种持久化机制。简单来说Checkpointer像是一个会话的“书签”帮你记住当前对话进行到哪了而Store则像一个跨会话的“笔记本”用来记录用户的偏好、个人信息等需要长期保留的知识。 短期记忆 vs. 长期记忆特性短期记忆 (Short-term Memory)长期记忆 (Long-term Memory)作用范围单个会话线程内跨会话、跨线程核心组件Checkpointer(如MemorySaver,PostgresSaver)Store(如InMemoryStore,PostgresStore)存储内容图的状态 (State)、对话历史用户画像、偏好、事实知识等 JSON 文档生命周期线程结束或手动清除持久化可长期保留典型用途维护当前对话的上下文在多轮对话中记住用户信息⚙️ 核心组件Store接口Store是一个简单的、基于命名空间的键值存储其核心设计如下存储模型记忆以JSON 文档的形式存储。组织方式通过namespace命名空间和key键来组织。namespace是一个元组用于逻辑分组例如(memories, user_id)方便隔离不同用户或应用的数据。核心操作Store接口支持put写入、get读取和search搜索等基本操作。存储后端LangGraph 提供了多种Store实现InMemoryStore数据存储在内存中进程重启后丢失适合开发和测试。PostgresStore使用 PostgreSQL 作为持久化后端适合生产环境。 如何在 LangGraph 中实现长期记忆1. 初始化Store实例首先你需要创建一个Store实例。在测试时可以使用InMemoryStore。fromlanggraph.store.memoryimportInMemoryStore# 创建一个内存存储实例用于开发和测试storeInMemoryStore()2. 将Store注入 Agent创建 Agent 时通过store参数将存储实例传入。fromlangchain.agentsimportcreate_agentfromlangchain_core.runnablesimportRunnable# ... (初始化模型、工具等)# 将 store 注入 agentagent:Runnablecreate_agent(modelyour-model,tools[...],storestore,# 关键注入 store 实例)3. 在工具中读写记忆这是长期记忆发挥作用的核心。在自定义工具中可以通过ToolRuntime访问store实例。写入记忆从上下文中获取user_id构建namespace然后使用store.put()保存信息。读取记忆同样在工具中通过store.get()读取特定键的记忆或使用store.search()进行搜索。 设计与最佳实践命名空间设计建议使用(user_id, context)的结构例如(user_id, preferences)或(user_id, interests)以便于管理和检索。记忆的写入时机可以由 Agent 主动调用工具写入或利用langmem等库提供的工具让模型自主决定何时写入记忆。关键在于设计清晰的 Prompt 和 Tool 描述引导模型正确使用。数据的演进长期记忆是动态的。可以设计工具来更新或删除已有的记忆保持信息的准确性和时效性。总而言之LangGraph 通过Store接口提供了一种灵活、可扩展的长期记忆方案让你可以根据应用场景自由定制记忆的存储、检索和管理逻辑。长期记忆的判断逻辑一个完整的工程方案面试官追问的核心是“你怎么区分‘值得记住’和‘不值得记住’的对话内容”这是一个非常关键的系统设计问题。你不需要真的在生产环境实现过完整的判断逻辑但需要展示出你对这个问题的深度思考和系统设计能力。下面是一个完整、可直接落地的三层判断方案包含清晰的代码示例和面试话术。 为什么这个问题这么重要面试官真正想考察的不是你用了什么存储技术而是你有没有思考过“记忆的价值”。如果把所有对话都往长期记忆里存会出现存储成本无限增长检索效率下降噪音太多模型生成时被大量无关信息干扰上下文污染因此设计一个“记忆过滤器”是长期记忆系统的核心工程决策。️ 完整的三层判断架构用户输入 ↓ ┌─────────────────────────────────────────────────┐ │ ① 语义分类意图识别 │ │ - 个人信息姓名、年龄、职业→ 高优先级 │ │ - 偏好设置喜欢什么、讨厌什么→ 高优先级 │ │ - 重要事件计划、承诺、约定→ 中优先级 │ │ - 闲聊、问候、无关问题 → 低优先级/不存 │ └─────────────────────────────────────────────────┘ ↓ ┌─────────────────────────────────────────────────┐ │ ② 重要性评分规则 语义 │ │ 计算综合得分0~1超过阈值才存 │ │ 因子实体密度、情感强度、承诺性词汇、消息长度 │ └─────────────────────────────────────────────────┘ ↓ ┌─────────────────────────────────────────────────┐ │ ③ 定期摘要压缩后台任务 │ │ - 每周对已存记忆做合并和压缩 │ │ - 保留关键信息丢弃冗余细节 │ │ - 防止长期记忆无限膨胀 │ └─────────────────────────────────────────────────┘ 完整代码实现importrefromtypingimportList,Dict,Any,Optionalfromlangchain_openaiimportChatOpenAIfromlangchain.promptsimportPromptTemplateclassLongTermMemoryFilter: 长期记忆智能判断过滤器 决定哪些用户输入应该存入长期记忆 def__init__(self,llm:Optional[ChatOpenAI]None):self.llmllm self.importance_threshold0.6# 存入长期记忆的阈值# 高优先级关键词个人信息、偏好self.high_priority_keywords[我叫,我的名字,我是,姓,名,喜欢,讨厌,爱好,偏好,最,生日,出生,年,岁,年龄,职业,工作,公司,职位,岗位]# 中优先级关键词计划、承诺self.medium_priority_keywords[计划,打算,准备,约,答应,承诺,一定要,必须,保证]def_classify_intent(self,text:str)-str:① 语义分类基于规则判断意图类型text_lowertext.lower()# 个人信息ifany(kwintext_lowerforkwin[我叫,我的名字,我是,姓]):returnpersonal_info# 偏好设置ifany(kwintext_lowerforkwin[喜欢,讨厌,爱好,偏好,最]):returnpreference# 重要事件/计划ifany(kwintext_lowerforkwin[计划,打算,答应,承诺]):returnimportant_event# 简单问候ifany(kwintext_lowerforkwin[你好,hi,hello,谢谢,感谢]):returngreetingreturnunknowndef_compute_importance_score(self,text:str,intent:str)-float:② 计算重要性得分0~1score0.0# 基础意图分intent_base_score{personal_info:0.85,preference:0.80,important_event:0.70,greeting:0.10,unknown:0.25}scoreintent_base_score.get(intent,0.25)# 实体密度加分出现人名、地名、时间entity_patterns[r[\u4e00-\u9fa5]{2,4},# 中文2-4字r\d{4}[-年]\d{1,2}[-月]\d{1,2},# 日期r[0-9][点分时]# 时间]entity_count0forpatterninentity_patterns:entity_countlen(re.findall(pattern,text))ifentity_count3:score0.15elifentity_count1:score0.08# 长度加分较长的消息包含更多信息iflen(text)30:score0.10eliflen(text)15:score0.05# 承诺性词汇加分ifany(kwintextforkwin[一定,务必,记住,以后,将来]):score0.10# 情感强度加分程度副词ifany(kwintextforkwin[非常,特别,很,超级,极其]):score0.05returnmin(score,1.0)defshould_store(self,text:str)-bool:③ 综合判断是否应该存入长期记忆intentself._classify_intent(text)scoreself._compute_importance_score(text,intent)print(f[评估] 消息: {text[:30]}... 意图:{intent}, 得分:{score:.2f})# 闲聊类直接忽略即使得分高也可能误判ifintentgreeting:returnFalsereturnscoreself.importance_thresholddefextract_key_facts(self,text:str)-dict:从消息中提取关键事实用于结构化存储facts{}# 提取姓名name_matchre.search(r[我姓|我叫|我是](\S{2,4}),text)ifname_match:facts[name]name_match.group(1)# 提取年龄age_matchre.search(r(\d{1,3})[岁],text)ifage_match:facts[age]int(age_match.group(1))# 提取偏好like_matchre.search(r喜欢(\S{2,6}),text)iflike_match:facts[likes]like_match.group(1)returnfacts# 使用示例 classMemoryManager:记忆管理器集成过滤逻辑def__init__(self):self.filterLongTermMemoryFilter()self.long_term_memory[]# 实际生产会用向量库defprocess_user_message(self,text:str)-dict:处理用户消息result{original:text,stored:False,intent:None,score:0.0,facts:{}}# 1. 判断是否存入ifself.filter.should_store(text):result[stored]Trueresult[intent]self.filter._classify_intent(text)result[score]self.filter._compute_importance_score(text,result[intent])result[facts]self.filter.extract_key_facts(text)# 存入长期记忆self.long_term_memory.append({content:text,facts:result[facts],score:result[score],intent:result[intent]})returnresultdefgenerate_summary(self)-str:生成记忆摘要iflen(self.long_term_memory)20:# 触发摘要压缩第四层# 实际可用LLM进行摘要pass# 测试 if__name____main__:managerMemoryManager()test_messages[你好我叫张三。,我是一名软件工程师在腾讯工作。,今天天气真好。,我喜欢打篮球和看电影。,谢谢你的帮助。,我计划下个月去日本旅游。,我会记住你说的话。]formsgintest_messages:resultmanager.process_user_message(msg)ifresult[stored]:print(f✅ 已存入:{msg}(得分:{result[score]:.2f}))else:print(f❌ 忽略:{msg})print(---)print(f\n 长期记忆共{len(manager.long_term_memory)}条:)foriteminmanager.long_term_memory:print(f -{item[content]}(事实:{item[facts]}))预期输出[评估] 消息: 你好我叫张三。... 意图: personal_info, 得分: 0.92 ✅ 已存入: 你好我叫张三。 (得分: 0.92) --- [评估] 消息: 我是一名软件工程师在腾讯工作。... 意图: personal_info, 得分: 0.90 ✅ 已存入: 我是一名软件工程师在腾讯工作。 (得分: 0.90) --- [评估] 消息: 今天天气真好。... 意图: greeting, 得分: 0.12 ❌ 忽略: 今天天气真好。 --- ... 面试话术完整版如果面试官问“你怎么判断哪些用户输入需要存长期记忆”“我会分层设计一个判断逻辑第一层是语义分类。我预先定义了几类值得存储的意图个人信息姓名、职业、偏好设置喜欢什么、重要事件计划、承诺。通过关键词规则或小模型做分类闲聊、问候类直接过滤掉。第二层是重要性评分。对每条消息计算综合得分考虑因子包括实体密度有没有出现人名、地名、时间、是否包含承诺性词汇、消息长度和情感强度。只有得分超过阈值才会存入长期记忆。第三层是定期摘要压缩。长期记忆不是无限的我会定期对存储的记忆做合并和摘要用 LLM 把多条记忆压缩成一段概述既保留关键信息又控制存储规模。当然这套方案可以根据业务需求调整——比如在客服场景可以额外识别‘投诉’、‘退换货’这类高优先级意图让系统自动记住用户的问题历史。”
