AsyncMemoryClient 异步客户端

from tencentdb_agent_memory.v3 import AsyncMemoryClient

import asyncio
from tencentdb_agent_memory.v3 import AsyncMemoryClient

async def main():
    async with AsyncMemoryClient(
        endpoint="https://memory.tdai.tencentyun.com",
        api_key="sk-xxxxxxxxxxxxxxxx",
        service_id="tdai-mem-xxxxxxxx",
        team_id="team-abc123",
        agent_id="agt-xyz789",
        user_id="usr-456",
        session_id="agent-main:sess-001",
    ) as client:
        # 写入对话
        result = await client.add_conversation(
            messages=[
                {"role": "user", "content": "帮我查一下上周的会议纪要"},
            ],
        )
        print(f"受理 {result['total_count']} 条消息")

        # 检索记忆
        memories = await client.search_conversation(
            query="会议纪要",
            limit=5,
        )
        for msg in memories["messages"]:
            print(f"[score={msg['score']:.2f}] {msg['content']}")

asyncio.run(main())