1
┌─────────────────────────────────────────────────────────────┐
2
│                    长久记忆存储系统                          │
3
├─────────────────────────────────────────────────────────────┤
4
│  向量数据库 (Chroma)           │    Markdown文档             │
5
│  - 动态记忆                   │    - 静态档案               │
6
│  - 非结构化数据               │    - 结构化数据             │
7
│  - 语义检索                   │    - 不常变化               │
8
│  - 事件、观点、情绪等         │    - 基础属性、能力等       │
9
└─────────────────────────────────────────────────────────────┘

1
{
2
    "category": "一级大类",           # 7个维度之一
3
    "importance": "high/medium/low",  # 重要性等级
4
    "timestamp": "2024-01-01",        # 时间戳
5
    "date": 1704067200,               # 整数时间戳（用于查询）
6
    "event_type": "event/memory",     # 类型标识
7
    "id": "uuid"                      # 唯一标识符
8
}

1
用户输入 → Memory Retrieve节点 → Memory Manager Agent
2
                                      ↓
3
                              调用查询工具
4
                                      ↓
5
                    ┌─────────────────┴─────────────────┐
6
                    │                                   │
7
              向量数据库查询                      MD文档读取
8
                    │                                   │
9
              语义检索+过滤                        静态档案
10
                    │                                   │
11
                    └─────────────────┬─────────────────┘
12
                                      ↓
13
                              整合记忆内容
14
                                      ↓
15
                              返回给对话流程

1
对话结束 → Final Output节点 → 异步记忆更新
2
                                      ↓
3
                              Memory Manager Agent
4
                                      ↓
5
                    ┌─────────────────┴─────────────────┐
6
                    │                                   │
7
              识别静态信息                      识别动态信息
8
                    │                                   │
9
              edit_user_info                     store_event/store_memory
10
                    │                                   │
11
              更新MD文档                         更新向量数据库
12
                    │                                   │
13
                    └─────────────────┬─────────────────┘
14
                                      ↓
15
                              记忆更新完成

1
┌─────────────────────────────────────────────────────────────┐
2
│                    多智能体协作流程                          │
3
└─────────────────────────────────────────────────────────────┘
4

5
用户输入
6
    ↓
7
┌───────────────────┐
8
│ Memory Manager    │ ← 检索相关记忆，构建上下文
9
│ (记忆检索模式)     │
10
└────────┬──────────┘
11
         ↓ 记忆信息
12
┌───────────────────┐
13
│ PlanExecute       │ ← 基于记忆生成个性化回复
14
│ (对话执行模式)     │
15
└────────┬──────────┘
16
         ↓ 回复结果
17
┌───────────────────┐
18
│ Evaluator         │ ← 评估回复质量和记忆一致性
19
│ (质量检查模式)     │   最多重试3次
20
└────────┬──────────┘
21
         ↓ 最终回复
22
┌───────────────────┐
23
│ Summarizer        │ ← 生成最终回复 + 触发异步记忆更新
24
│ (总结更新模式)     │
25
└────────┬──────────┘
26
         ↓
27
    用户接收
28
         ↓
29
┌───────────────────┐
30
│ Memory Manager    │ ← 异步更新记忆库
31
│ (记忆更新模式)     │
32
└───────────────────┘

1
# GlobalState中的记忆字段传递
2
class GlobalState(TypedDict):
3
    memory: Optional[str]      # Memory Manager检索的记忆
4
    # 其他智能体通过state["memory"]访问记忆信息

1
对话结束 → Final Output节点
2
              ↓
3
         启动异步线程
4
              ↓
5
    ┌─────────────────────┐
6
    │ Memory Manager      │
7
    │ (更新模式)          │
8
    └──────────┬──────────┘
9
               ↓
10
    ┌─────────────────────┐
11
    │ 信息识别与分类      │
12
    └──────────┬──────────┘
13
               ↓
14
    ┌─────────────────────┐
15
    │ 静态信息？          │
16
    └──┬──────────────┬───┘
17
       │ 是           │ 否
18
       ↓              ↓
19
┌──────────────┐  ┌──────────────┐
20
│read_user_info│  │分析信息类型  │
21
│获取现有档案  │  └──────┬───────┘
22
└──────┬───────┘         │
23
       │         ┌───────┴───────┐
24
       │         │事件？  其他？  │
25
       │         ↓       ↓       │
26
       │    ┌────────┐ ┌────────┐ │
27
       │    │store_  │ │store_  │ │
28
       │    │event   │ │memory  │ │
29
       │    └────────┘ └────────┘ │
30
       │         │       │       │
31
       └─────────┴───────┴───────┘
32
                 ↓
33
        ┌────────────────┐
34
        │ 记忆更新完成    │
35
        └────────────────┘

1
# final_output.py中的异步更新
2
def update_memory_async(user_input: str, conversation_history: list = None):
3
    try:
4
        memory_manager = AgentFactory.create_role_agent(
5
            "memory_manager",
6
            tools_for_memory_manager,
7
            memory_manager_system_prompt_summarize,  # 使用更新模式提示词
8
        )
9

10
        messages = []
11
        if conversation_history:
12
            messages.extend(conversation_history)
13
        messages.append(HumanMessage(
14
            content=f"这是新的用户输入: '{user_input}'\n你不需要对用户输入回应，请你开始更新记忆"
15
        ))
16

17
        response = memory_manager.invoke({"messages": messages})
18
        logger.info("更新记忆成功")
19
    except Exception as e:
20
        logger.error(f"更新记忆失败: {e}")

1
# 使用Chroma向量数据库
2
db_path = "database/agent/vector_memory.db"
3
client = chromadb.PersistentClient(path=db_path)
4
collection = client.get_or_create_collection(name="vector_memory")

1
class GlobalState(TypedDict):
2
    messages: list[BaseMessage]      # 对话历史
3
    user_input: str                  # 用户输入
4
    memory: Optional[str]            # 召回的长期记忆
5
    # ... 其他状态字段

1
START → memory_retrieve → plan_execute → evaluate → final_output → END