#!/usr/bin/env python3
"""批量操作示例."""
from src.config_manager import ConfigManager
from src.graphiti_client import GraphitiClient
def main():
"""批量操作示例."""
print("🚀 批量操作示例\n")
config_manager = ConfigManager()
client = GraphitiClient(config_manager)
if not client.connect():
print("❌ 连接失败")
return
# 批量添加 Episode
print("📝 批量添加 Episode...")
episodes = [
{
"content": "我喜欢使用 TypeScript 进行类型安全的开发",
"metadata": {"type": "preference", "category": "programming"}
},
{
"content": "我使用 React 和 Next.js 构建前端应用",
"metadata": {"type": "preference", "category": "framework"}
},
{
"content": "我的数据库偏好是 PostgreSQL",
"metadata": {"type": "preference", "category": "database"}
},
{
"content": "我遵循函数式编程的最佳实践",
"metadata": {"type": "practice", "category": "programming"}
}
]
result = client.add_episodes_bulk(episodes)
print(f"✅ {result['message']}")
print(f" 总计: {result['total']} 个")
print(f" 成功: {result['success_count']} 个")
print(f" 失败: {result['fail_count']} 个")
client.disconnect()
print("\n🎉 批量操作完成！")
if __name__ == "__main__":
main()
