Struct FileBasedStorage 

pub struct FileBasedStorage { /* private fields */ }

基于文件的持久化存储

文件结构:

memory/
├── data.json              # KV 存储 (MemoryValue items)
├── MEMORY.md              # 长期记忆
├── sessions/              # 会话历史
│   ├── <session_id>.json  # 单个会话的消息历史
├── 2024-01-15.md          # 每日笔记 (YYYY-MM-DD.md)
└── ...

特性

• 持久化到磁盘
• 线程安全 (Arc<RwLock>)
• 原子文件写入 (临时文件 + rename)
• 懒加载 (启动时从文件加载到内存)

Implementations

impl FileBasedStorage

pub async fn new( base_dir: impl AsRef<Path>, ) -> Result<FileBasedStorage, AgentError>

创建新的基于文件的存储

参数

• base_dir: 基础目录，将在其下创建 memory/ 和 memory/sessions/

示例

use mofa_foundation::agent::components::memory::FileBasedStorage;

let storage = FileBasedStorage::new("/tmp/workspace").await?;

pub async fn read_today_file(&self) -> Result<String, AgentError>

读取今日笔记内容

pub async fn append_today_file(&self, content: &str) -> Result<(), AgentError>

追加内容到今日笔记

pub async fn read_long_term_file(&self) -> Result<String, AgentError>

读取长期记忆 (MEMORY.md)

pub async fn write_long_term_file( &self, content: &str, ) -> Result<(), AgentError>

写入长期记忆 (MEMORY.md)

pub async fn get_recent_memories_files( &self, days: u32, ) -> Result<String, AgentError>

获取最近 N 天的记忆

pub async fn get_memory_context(&self) -> Result<String, AgentError>

获取记忆上下文

pub async fn read_today(&self) -> Result<String, AgentError>

读取今日笔记

pub async fn append_today(&self, content: &str) -> Result<(), AgentError>

追加今日笔记

pub async fn read_long_term(&self) -> Result<String, AgentError>

读取长期记忆

pub async fn write_long_term(&self, content: &str) -> Result<(), AgentError>

写入长期记忆

pub async fn get_recent_memories(&self, days: u32) -> Result<String, AgentError>

获取最近记忆

Trait Implementations

impl Memory for FileBasedStorage

fn store<'life0, 'life1, 'async_trait>( &'life0 mut self, key: &'life1 str, value: MemoryValue, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileBasedStorage: 'async_trait,

存储记忆项

fn retrieve<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<MemoryValue>, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileBasedStorage: 'async_trait,

检索记忆项

fn remove<'life0, 'life1, 'async_trait>( &'life0 mut self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileBasedStorage: 'async_trait,

删除记忆项

fn search<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<MemoryItem>, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileBasedStorage: 'async_trait,

语义搜索

fn clear<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileBasedStorage: 'async_trait,

清空所有记忆

fn get_history<'life0, 'life1, 'async_trait>( &'life0 self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<Message>, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileBasedStorage: 'async_trait,

获取对话历史

fn add_to_history<'life0, 'life1, 'async_trait>( &'life0 mut self, session_id: &'life1 str, message: Message, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileBasedStorage: 'async_trait,

添加对话消息

fn clear_history<'life0, 'life1, 'async_trait>( &'life0 mut self, session_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, FileBasedStorage: 'async_trait,

清空对话历史

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<MemoryStats, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, FileBasedStorage: 'async_trait,

获取记忆统计

fn memory_type(&self) -> &str

记忆类型名称

fn contains<'life0, 'life1, 'async_trait>( &'life0 self, key: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, AgentError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

检查是否存在