SuperAPI AI 工具集

storage-sync

智能体与模型

查看项目

更新于 10-15 20:30

技能介绍

用途:在 Turso(持久存储)与 redb(缓存层)之间同步记忆数据,适用于启动初始化后、定时后台同步、redb 缓存显得陈旧、存储故障恢复以及手动触发等场景。

主要能力与流程:先检查连接健康(turso_client.ping().await? 与 redb_env.check_integrity()?),再从 Turso 拉取最新数据(按 timestamp 倒序并限制条数的查询),随后通过 tokio::task::spawn_blocking 在 redb 写事务中批量写入 episodes;若启用,还会同步 patterns 与 embeddings。

配置项:SyncConfig 包含 max_episodes_cache(默认 1000)、batch_size(默认 100)、sync_patterns(默认 true)、sync_embeddings(默认 true)。

错误处理:Turso 不可用时跳过同步、记录警告并稍后重试;redb 损坏时尝试修复并从 Turso 重建;部分同步则跟踪进度并从断点续传。

性能建议:小操作批量执行、增量同步、用 Tokio 并行拉取、写入前预准备。同步后需校验 episode 数量、最新 episode 是否存在、pattern 计数一致、无孤立 embedding。

限制与排障:资料未提供具体安装命令、运行入口、平台与收费信息。同步慢可减小缓存规模并增大 batch;redb 锁错误建议使用专用写任务;内存压力大时流式处理大结果并减小批次。