Memory Service Documentation¶

Overview¶

MemoryService is a core component in trpc-agent for managing long-term memory. Unlike SessionService which manages the context of the current session, MemoryService focuses on storing and retrieving historical memories across sessions, helping the Agent recall relevant content in subsequent conversations.

Memory vs Session¶

Feature	Session	Memory
Scope	Single session	Cross-session (shared across all sessions)
Lifecycle	Created and destroyed with the session	Independent of sessions, controlled by TTL
Stored Content	Complete conversation history of the current session	Key events and knowledge fragments
Access Method	Automatically loaded into context	Retrieved via `load_memory` tool
Typical Use	Context for a single conversation	Long-term memory, user profiles, knowledge accumulation

Core Capabilities of MemoryService¶

Based on the implementation in trpc_agent_sdk/memory/, MemoryService provides the following core capabilities:

1. Storing Session Memory¶

Function: Stores key events from a Session as long-term memory.

Implementation Methods: - InMemoryMemoryService: Stored in an in-process memory dictionary - RedisMemoryService: Stored in a Redis List (JSON format) - SqlMemoryService: Stored in the mem_events table in MySQL/PostgreSQL - MempalaceMemoryService: Stored as MemPalace drawers in a local ChromaDB-backed palace

Code Example:

# Store session to Memory
await memory_service.store_session(session=session)

Storage Logic (using InMemoryMemoryService as an example):

# from trpc_agent_sdk/memory/_in_memory_memory_service.py
async def store_session(self, session: Session, agent_context: Optional[AgentContext] = None) -> None:
    # Data structure: {save_key: {session_id: [EventTtl, ...]}}
    self._session_events[session.save_key] = self._session_events.get(session.save_key, {})
    self._session_events[session.save_key][session.id] = [
        EventTtl(event=event, ttl=self._memory_service_config.ttl)
        for event in session.events
        if event.content and event.content.parts  # Only store events with content
    ]

Function: Searches for related historical memories based on query keywords.

Search Method: Built-in InMemory/Redis/SQL services use keyword matching; semantic memory services such as MemPalace and Mem0 use vector / semantic retrieval.

Implementation Logic (using InMemoryMemoryService as an example):

# From trpc_agent_sdk/memory/_in_memory_memory_service.py
async def search_memory(self, key: str, query: str, limit: int = 10, ...) -> SearchMemoryResponse:
    # 1. Extract query keywords (supports both Chinese and English)
    words_in_query = extract_words_lower(query)  # Extract English words and Chinese characters

    # 2. Iterate over all session events
    for session_events in self._session_events[key].values():
        for event_ttl in session_events:
            # 3. Extract keywords from the event
            words_in_event = extract_words_lower(' '.join([part.text for part in event.content.parts if part.text]))

            # 4. Keyword matching (return on any query word match)
            if any(query_word in words_in_event for query_word in words_in_query):
                response.memories.append(MemoryEntry(...))
                # 5. Refresh TTL (refresh expiration time on access)
                event_ttl.update_expired_at()

Keyword Extraction (_utils.py):

def extract_words_lower(text: str) -> set[str]:
    """Extract English words and Chinese characters"""
    words = set()
    # Extract English words (letter sequences)
    words.update([word.lower() for word in re.findall(r'[A-Za-z]+', text)])
    # Extract Chinese characters (Unicode range \u4e00-\u9fff)
    words.update(re.findall(r'[\u4e00-\u9fff]', text))
    return words

Usage Example:

from trpc_agent_sdk.types import SearchMemoryResponse

# Search related memories
search_key = f"{app_name}/{user_id}"  # Format: app_name/user_id
response: SearchMemoryResponse = await memory_service.search_memory(
    key=search_key,
    query="weather",  # Query keyword
    limit=10       # Return at most 10 memories
)

# Process search results
for memory in response.memories:
    print(f"Memory content: {memory.content}")
    print(f"Author: {memory.author}")
    print(f"Timestamp: {memory.timestamp}")

3. TTL (Time-To-Live) Cache Eviction¶

Function: Automatically cleans up expired memory data, preventing unlimited memory/storage growth.

Implementation Methods: - InMemoryMemoryService: Background periodic cleanup task (_cleanup_loop) - RedisMemoryService: Redis native EXPIRE mechanism (automatic expiration) - SqlMemoryService: Background periodic cleanup task (batch SQL DELETE) - MempalaceMemoryService: Background periodic cleanup task (batch drawer deletion by metadata timestamp)

TTL Configuration:

from trpc_agent_sdk.memory import MemoryServiceConfig

memory_service_config = MemoryServiceConfig(
    enabled=True,
    ttl=MemoryServiceConfig.create_ttl_config(
        enable=True,                    # Enable TTL
        ttl_seconds=86400,              # Memory expiration time: 24 hours
        cleanup_interval_seconds=3600,  # Cleanup interval: 1 hour (InMemory/SQL only)
    ),
)

TTL Refresh Mechanism: - Refresh on access: TTL is refreshed for matched events during search_memory - Refresh on storage: TTL is set for new events during store_session - Persistent semantic services: Some services, such as MemPalace, delete expired drawers by stored event timestamp rather than refreshing TTL on every search.

Function: Different sessions can share the same memory data.

Implementation Method: - Uses save_key (format: app_name/user_id) as the memory key - All sessions from the same user share the same memory space - Uses key=f"{app_name}/{user_id}" during search to retrieve all memories for that user

Data Structure (InMemoryMemoryService):

# Data structure: {save_key: {session_id: [EventTtl, ...]}}
_session_events = {
    "weather_app/user_001": {
        "session_1": [EventTtl(...), EventTtl(...)],
        "session_2": [EventTtl(...), EventTtl(...)],
    },
    "weather_app/user_002": {
        "session_3": [EventTtl(...)],
    }
}

MemoryService Implementations¶

trpc-agent provides multiple MemoryService implementations, allowing you to choose the appropriate storage backend based on your scenario:

InMemoryMemoryService¶

How It Works: Stores memory data directly in the application's memory.

Implementation Details (based on _in_memory_memory_service.py): - Data Structure: dict[str, dict[str, list[EventTtl]]] (nested dictionaries) - Storage Location: Process memory - Search Method: Keyword matching (iterating over in-memory dictionary) - TTL Mechanism: Background periodic cleanup task (_cleanup_loop) - Cleanup Method: Two-phase deletion (collect expired items → batch delete)

Persistence: ❌ None. All memory data is lost if the application restarts.

Applicable Scenarios: - ✅ Rapid development - ✅ Local testing - ✅ Demo examples - ✅ Scenarios that do not require long-term persistence

Configuration Example:

from trpc_agent_sdk.memory import InMemoryMemoryService, MemoryServiceConfig

memory_service_config = MemoryServiceConfig(
    enabled=True,
    ttl=MemoryServiceConfig.create_ttl_config(
        enable=True,
        ttl_seconds=86400,              # 24-hour expiration
        cleanup_interval_seconds=3600,  # Cleanup every 1 hour
    ),
)

memory_service = InMemoryMemoryService(memory_service_config=memory_service_config)

Notes: - When enabled=True, MemoryService automatically stores Session events, no need to manually call store_session - If enabled=False, MemoryService will not store any data - The cleanup task runs in the background, periodically deleting expired events

Related Examples: - 📁 examples/memory_service_with_in_memory/run_agent.py - Complete In-Memory Memory Service usage example

RedisMemoryService¶

How It Works: Uses Redis to store memory data, supporting multi-node sharing.

Implementation Details (based on _redis_memory_service.py): - Data Structure: Redis List (RPUSH to store event JSON) - Storage Location: Redis external storage - Key Format: memory:{save_key}:{session_id} - Search Method: KEYS memory:{key}:* + keyword matching - TTL Mechanism: Redis native EXPIRE command (automatic expiration) - TTL Refresh: Automatically refreshed on access (during search_memory)

Persistence: ✅ Yes. Data is persisted in Redis and can be recovered after application restart.

Applicable Scenarios: - ✅ Production environments - ✅ Multi-node deployments - ✅ High-performance caching requirements - ✅ Distributed applications

Configuration Example:

import os
from trpc_agent_sdk.memory import RedisMemoryService, MemoryServiceConfig

# Read Redis configuration from environment variables
db_host = os.environ.get("REDIS_HOST", "127.0.0.1")
db_port = os.environ.get("REDIS_PORT", "6379")
db_password = os.environ.get("REDIS_PASSWORD", "")
db_db = os.environ.get("REDIS_DB", 0)

# Build Redis connection URL
if db_password:
    db_url = f"redis://:{db_password}@{db_host}:{db_port}/{db_db}"
else:
    db_url = f"redis://{db_host}:{db_port}/{db_db}"

memory_service_config = MemoryServiceConfig(
    enabled=True,
    ttl=MemoryServiceConfig.create_ttl_config(
        enable=True,
        ttl_seconds=86400,  # 24-hour expiration (automatically handled by Redis)
    ),
)

memory_service = RedisMemoryService(
    db_url=db_url,
    is_async=True,          # Use async mode (recommended)
    memory_service_config=memory_service_config,
    enabled=True,
)

Redis Data Structure:

# Storage format: Redis List
memory:weather_app/user_001:session_1
  └─ [0] '{"id":"event_1","author":"user","content":{...},"timestamp":...}'
  └─ [1] '{"id":"event_2","author":"assistant","content":{...},"timestamp":...}'

# TTL setting
EXPIRE memory:weather_app/user_001:session_1 86400  # Expires after 24 hours

Notes: - When is_async=True, the async Redis client is used, which is friendly for concurrent scenarios - When is_async=False, the synchronous Redis client is used - Redis's EXPIRE mechanism automatically handles expired keys, no background cleanup task required - The cleanup_interval_seconds parameter has no effect on RedisMemoryService (Redis handles expiration automatically)

Related Examples: - 📁 examples/memory_service_with_redis/run_agent.py - Complete Redis Memory Service usage example

SqlMemoryService¶

How It Works: Stores memory data in a relational database (MySQL/PostgreSQL).

Implementation Details (based on _sql_memory_service.py): - Data Structure: SQL table mem_events - Storage Location: MySQL/PostgreSQL database - Search Method: SQL SELECT + keyword matching - TTL Mechanism: Background periodic cleanup task (batch SQL DELETE) - Cleanup Method: Single SQL DELETE for batch deletion of expired events

Persistence: ✅ Yes. Data is persisted in the database and can be recovered after application restart.

Applicable Scenarios: - ✅ Production environments - ✅ Transaction safety requirements - ✅ Complex query and statistical analysis requirements - ✅ Data persistence and backup requirements

Configuration Example:

import os
from trpc_agent_sdk.memory import SqlMemoryService, MemoryServiceConfig

# Read MySQL configuration from environment variables
db_user = os.environ.get("MYSQL_USER", "root")
db_password = os.environ.get("MYSQL_PASSWORD", "")
db_host = os.environ.get("MYSQL_HOST", "127.0.0.1")
db_port = os.environ.get("MYSQL_PORT", "3306")
db_name = os.environ.get("MYSQL_DB", "trpc_agent_memory")

# Build database connection URL
# Synchronous operation (pymysql)
db_url = f"mysql+pymysql://{db_user}:{db_password}@{db_host}:{db_port}/{db_name}?charset=utf8mb4"

# Asynchronous operation (aiomysql)
# db_url = f"mysql+aiomysql://{db_user}:{db_password}@{db_host}:{db_port}/{db_name}?charset=utf8mb4"

memory_service_config = MemoryServiceConfig(
    enabled=True,
    ttl=MemoryServiceConfig.create_ttl_config(
        enable=True,
        ttl_seconds=86400,              # 24-hour expiration
        cleanup_interval_seconds=3600,  # Cleanup every 1 hour
    ),
)

memory_service = SqlMemoryService(
    db_url=db_url,
    is_async=True,          # Use async mode (recommended)
    memory_service_config=memory_service_config,
    enabled=True,
    pool_pre_ping=True,     # Connection health check (recommended)
    pool_recycle=3600,      # Connection recycle time: 1 hour
)

Database Table Structure:

CREATE TABLE mem_events (
    id VARCHAR(255) NOT NULL,              -- Event UUID
    save_key VARCHAR(255) NOT NULL,        -- app_name/user_id
    session_id VARCHAR(255) NOT NULL,       -- Session ID
    invocation_id VARCHAR(255),            -- Invocation ID
    author VARCHAR(255),                    -- Author (user/assistant)
    content JSON,                          -- Event content (JSON)
    timestamp TIMESTAMP DEFAULT CURRENT_TIMESTAMP,  -- Creation time
    -- ... other fields
    PRIMARY KEY (id, save_key, session_id),
    INDEX idx_save_key (save_key),         -- For retrieval
    INDEX idx_timestamp (timestamp)        -- For cleanup task
);

Cleanup Task (batch deletion):

# From _sql_memory_service.py
async def _cleanup_expired_async(self) -> None:
    """Batch delete expired events"""
    expire_before = datetime.now() - timedelta(seconds=self._memory_service_config.ttl.ttl_seconds)

    # Single SQL DELETE for batch deletion
    DELETE FROM mem_events
    WHERE timestamp < expire_before;

Notes: - When is_async=True, the aiomysql driver is used; requires installation: pip install aiomysql - When is_async=False, the pymysql driver is used; requires installation: pip install pymysql - pool_pre_ping=True is recommended to avoid stale connections - pool_recycle=3600 sets connection recycle time to avoid long-lived connections - The cleanup task uses batch SQL DELETE for performance optimization

Related Examples: - 📁 examples/memory_service_with_sql/run_agent.py - Complete SQL Memory Service usage example

Comparison of Three Implementations¶

Feature	InMemoryMemoryService	RedisMemoryService	SqlMemoryService
Data Storage	Process memory	Redis external storage	MySQL/PostgreSQL
Persistence	❌ Lost on process restart	✅ Persisted in Redis	✅ Persisted in database
Distributed	❌ Cannot share across processes	✅ Supports cross-process/server	✅ Supports cross-process/server
TTL Mechanism	✅ Periodic cleanup task	✅ Redis automatic expiration	✅ Periodic cleanup task (batch)
Cleanup Efficiency	⭐⭐⭐ Requires scanning	⭐⭐⭐⭐⭐ Redis native	⭐⭐⭐⭐ Single SQL batch delete
Transaction Support	❌	❌	✅ ACID transactions
Complex Queries	❌	❌	✅ SQL queries
Deployment Scenarios	Local development/single node	Production/distributed/caching	Production/distributed/relational data
Performance	⭐⭐⭐⭐⭐ Extremely fast	⭐⭐⭐⭐ Fast	⭐⭐⭐ Medium

Recommendations: - Development and testing → InMemoryMemoryService (zero dependencies, quick startup) - Production (high performance) → RedisMemoryService (Redis automatic expiration, no background tasks) - Production (transactions/queries) → SqlMemoryService (transaction safety, supports complex queries) - Enterprise (TRPC ecosystem) → TrpcRedisMemoryService (service discovery, monitoring and alerting)

Usage Examples¶

Basic Usage Flow¶

from trpc_agent_sdk.sessions import InMemorySessionService
from trpc_agent_sdk.memory import MemoryServiceConfig
from trpc_agent_sdk.memory import InMemoryMemoryService
from trpc_agent_sdk.runners import Runner
from trpc_agent_sdk.types import Content, Part

# 1. Create MemoryService
memory_service_config = MemoryServiceConfig(
    enabled=True,
    ttl=MemoryServiceConfig.create_ttl_config(
        enable=True,
        ttl_seconds=86400,
        cleanup_interval_seconds=3600,
    ),
)
memory_service = InMemoryMemoryService(memory_service_config=memory_service_config)

# 2. Create SessionService
session_service = InMemorySessionService()

# 3. Create Runner and configure services
runner = Runner(
    app_name="my_app",
    agent=my_agent,
    session_service=session_service,
    memory_service=memory_service  # Configure MemoryService
)

# 4. Run Agent (MemoryService will automatically store events)
async for event in runner.run_async(
    user_id=user_id,
    session_id=session_id,
    new_message=user_message
):
    # Process events...
    pass

# 5. Search related memories (via load_memory tool)
# Agent will automatically call memory_service.search_memory()

Manual Storage and Search¶

# Manually store session to Memory
session = await session_service.get_session(
    app_name="my_app",
    user_id=user_id,
    session_id=session_id
)
if session:
    await memory_service.store_session(session=session)

# Manually search memories
search_key = f"{app_name}/{user_id}"
response = await memory_service.search_memory(
    key=search_key,
    query="user's name",
    limit=10
)

for memory in response.memories:
    print(f"Memory: {memory.content}")

Integrating SessionService and MemoryService¶

In practical applications, you typically need to use both SessionService and MemoryService together:

from trpc_agent_sdk.sessions import InMemorySessionService
from trpc_agent_sdk.memory import InMemoryMemoryService, MemoryServiceConfig
from trpc_agent_sdk.runners import Runner

# Create service instances
session_service = InMemorySessionService()
memory_service_config = MemoryServiceConfig(
    enabled=True,
    ttl=MemoryServiceConfig.create_ttl_config(
        enable=True,
        ttl_seconds=86400,
    ),
)
memory_service = InMemoryMemoryService(memory_service_config=memory_service_config)

# Create Runner and configure services
runner = Runner(
    app_name="my_app",
    agent=my_agent,
    session_service=session_service,
    memory_service=memory_service  # Optional: configure MemoryService
)

# Run Agent
async for event in runner.run_async(
    user_id=user_id,
    session_id=session_id,
    new_message=user_message
):
    # Process events...
    pass

Workflow:

SessionService manages the context of the current session (conversation history, state, etc.)
MemoryService automatically stores Session events to long-term memory (if enabled=True)
load_memory tool calls memory_service.search_memory() to retrieve related memories
The Agent can simultaneously access the current session context and historical memories, providing a more coherent conversation experience

The following examples demonstrate the usage of different MemoryService implementations:

InMemoryMemoryService¶

📁 Example Path: examples/memory_service_with_in_memory/run_agent.py

Description: - Demonstrates basic usage of In-Memory Memory Service - Shows cross-session memory sharing - Demonstrates TTL cache eviction mechanism - Includes detailed analysis of execution results

How to Run:

cd examples/memory_service_with_in_memory/
python3 run_agent.py

RedisMemoryService¶

📁 Example Path: examples/memory_service_with_redis/run_agent.py

Description: - Demonstrates Redis Memory Service usage - Shows Redis automatic expiration mechanism - Provides detailed Redis operations guide - Includes execution result analysis and Redis command examples

How to Run:

cd examples/memory_service_with_redis/
python3 run_agent.py

SqlMemoryService¶

📁 Example Path: examples/memory_service_with_sql/run_agent.py

Description: - Demonstrates SQL Memory Service usage - Shows MySQL table structure and data operations - Demonstrates batch cleanup task - Provides MySQL operation commands and execution result analysis

How to Run:

cd examples/memory_service_with_sql/
python3 run_agent.py

Integrating Mem0¶

What is Mem0?¶

Mem0 is an intelligent, self-improving memory layer for LLMs that can persist and retrieve user information across conversations, enabling more personalized and coherent user experiences.

Core Capabilities: - 🧠 Intelligent memory extraction and storage - 🔍 Semantic search of historical conversations - 🔄 Automatic memory updates and deduplication - 🎯 User-level memory isolation

Official Resources: - Official documentation: https://docs.mem0.ai/introduction - GitHub: https://github.com/mem0ai/mem0

tRPC-Agent Integration Methods¶

tRPC-Agent provides two methods for integrating Mem0:

Method	Class / Tool	Applicable Scenario
Framework-level memory service (recommended)	`Mem0MemoryService`	The framework automatically handles cross-session memory storage and retrieval, transparent to the Agent
Tool-based memory	`SearchMemoryTool` / `SaveMemoryTool`	The Agent actively calls Mem0 through tools, with flexible control over storage and retrieval timing

Mem0MemoryService (Recommended)¶

Mem0MemoryService is tRPC-Agent's framework-level memory service. The framework automatically calls store_session after each turn of the conversation completes to store session memories. The Agent actively retrieves related memories through the load_memory tool when generating a response, without manual management of storage and retrieval timing.

Core Design¶

Two-level key strategy: session.save_key → Mem0 user_id (user dimension); session.id → run_id (session dimension)
Cross-session sharing: Different sessions from the same user share the same memory
TTL automatic expiration: Background periodic cleanup of expired memories

Quick Integration¶

Step 1: Create Mem0MemoryService

from mem0 import AsyncMemory, AsyncMemoryClient
from trpc_agent_sdk.memory import MemoryServiceConfig
from trpc_agent_sdk.memory.mem0_memory_service import Mem0MemoryService

# Self-hosted mode (AsyncMemory + Qdrant)
from mem0.configs.base import MemoryConfig
mem0_client = AsyncMemory(config=MemoryConfig(**{
    "vector_store": {"provider": "qdrant", "config": {"host": "localhost", "port": 6333}},  # Vector database declaration
    "llm": {"provider": "deepseek", "config": {"model": "...", "api_key": "..."}},          # Used for memory summarization (used when infer=True)
    "embedder": {"provider": "huggingface", "config": {"model": "multi-qa-MiniLM-L6-cos-v1"}},  # Open-source embedding model
}))

# Or: Remote platform mode (AsyncMemoryClient), no self-hosted infrastructure needed
mem0_client = AsyncMemoryClient(api_key="your_mem0_api_key", host="https://api.mem0.ai")

memory_service = Mem0MemoryService(
    mem0_client=mem0_client,
    memory_service_config=MemoryServiceConfig(
        enabled=True,
        ttl=MemoryServiceConfig.create_ttl_config(enable=False),  # Disable TTL, memories are retained permanently
    ),
    infer=False,   # False=store raw content (stable), True=semantic extraction (intelligent)
)

Step 2: Pass memory_service to Runner

from trpc_agent_sdk.runners import Runner
from trpc_agent_sdk.tools import load_memory_tool

agent = LlmAgent(
    name="assistant",
    model=your_model,
    tools=[load_memory_tool],   # Agent actively retrieves memories through this tool
    instruction="Use load_memory to recall relevant past conversations before answering.",
)

runner = Runner(
    app_name="my_app",
    agent=agent,
    session_service=InMemorySessionService(),
    memory_service=memory_service,   # Framework handles storage automatically
)

Step 3: Run, memories are automatically persisted across sessions

# First conversation round (session_1)
async for event in runner.run_async(user_id="alice", session_id="session_1", new_message=...):
    ...
# The framework automatically calls store_session after the conversation ends, storing this round's messages into Mem0

# Second conversation round (session_2) — new session, but can retrieve memories from session_1
async for event in runner.run_async(user_id="alice", session_id="session_2", new_message=...):
    ...

`infer` Parameter Selection¶

	`infer=False` (recommended)	`infer=True`
Stored Content	Raw conversation text	Semantic facts extracted by LLM
Stability	High, every entry is stored	Medium, not stored when LLM determines NONE
Token Consumption	Low (no LLM calls)	High (LLM called on each write)
Conflict Resolution	None	Automatic (new facts override old facts)
Recommended Scenario	Complete history archival, production environments	Long-term user profiling, preference extraction

TTL Configuration (Optional)¶

memory_service_config = MemoryServiceConfig(
    enabled=True,
    ttl=MemoryServiceConfig.create_ttl_config(
        enable=True,
        ttl_seconds=86400,           # Memory retention: 24 hours
        cleanup_interval_seconds=3600,  # Cleanup every 1 hour
    ),
)

For detailed explanations, execution result analysis, and FAQ: examples/memory_service_with_mem0/README.md

Tool-based Integration (mem0_tool)¶

tRPC-Agent integrates Mem0 through Tools, providing memory capabilities to Agents. The framework provides two core tool classes:

Tool Class	Tool Name	Function	Use Case
`SearchMemoryTool`	`search_memory`	Search historical memories	When the Agent needs to recall past conversations
`SaveMemoryTool`	`save_memory`	Save important information	When the Agent determines user information should be remembered

Note: Both tool classes require a Mem0 client to be passed during instantiation. The user_id is automatically injected by the framework through InvocationContext and does not need to be explicitly passed as a tool parameter.

Integration Architecture¶

┌──────────────────────┐
│    User Input        │
└──────────┬───────────┘
           │
           ▼
┌──────────────────────┐
│  tRPC-Agent          │◄─────────┐
│  LlmAgent            │          │
└──────────┬───────────┘          │
           │                      │
           │ Call tools            │ Return memories
           │                      │
           ▼                      │
┌──────────────────────┐          │
│  Mem0 Tools          │──────────┘
│  - SearchMemoryTool  │
│  - SaveMemoryTool    │
└──────────┬───────────┘
           │
           ▼
┌──────────────────────┐
│  Mem0 Client         │
│  (AsyncMemory /      │
│   AsyncMemoryClient) │
└──────────┬───────────┘
           │
           ▼
┌──────────────────────┐
│  Storage             │
│  - Qdrant            │
│  - Mem0 Cloud        │
└──────────────────────┘

Deployment Modes¶

tRPC-Agent supports two deployment modes for Mem0: self-hosted mode and platform mode

Mode Comparison¶

Feature	Self-hosted Mode	Platform Mode
Client Type	`AsyncMemory`	`AsyncMemoryClient`
Storage Location	Local vector database (e.g., Qdrant)	Mem0 Cloud
Dependencies	Vector database + Embedding model + LLM	API Key only
Data Control	Full control	Managed service
Applicable Scenario	Development testing, data-sensitive, local deployment	Production environment, rapid deployment

Mode 1: Self-hosted (AsyncMemory)¶

Suitable for scenarios requiring full control over data and infrastructure.

Core Components: - Vector Store: Supports multiple backends (see the complete list below) - LLM: Used for generating memory summaries (OpenAI / DeepSeek / Gemini, etc.) - Embedding Model: Used for vectorization (HuggingFace / OpenAI, etc.)

Complete List of Supported Vector Stores for Self-hosted: - azure_ai_search - azure_mysql - baidu - cassandra - chroma - databricks - elasticsearch - faiss - langchain - milvus - mongodb - neptune_analytics - opensearch - pgvector - pinecone - qdrant - redis - s3_vectors - supabase - turbopuffer - upstash_vector - valkey - vertex_ai_vector_search - weaviate

Official vector store implementation list (refer to the mem0 repository): mem0/vector_stores

Example Code:

from mem0 import AsyncMemory
from trpc_agent_sdk.tools.mem0_tool import SearchMemoryTool, SaveMemoryTool

# Configure custom components
config = {
    "vector_store": {"provider": "qdrant", "config": {...}},
    "llm": {"provider": "deepseek", "config": {...}},
    "embedder": {"provider": "huggingface", "config": {...}}
}

# Create Mem0 client
memory = await AsyncMemory.from_config(config)

# Instantiate tools with the client
search_memory_tool = SearchMemoryTool(client=memory)
save_memory_tool = SaveMemoryTool(client=memory)

Detailed Configuration: See Complete Example - Self-hosted Mode

Mode 2: Platform (AsyncMemoryClient)¶

Suitable for rapid deployment and production environment usage.

Prerequisites: - Register a Mem0 platform account - Obtain an API Key

Example Code:

from mem0 import AsyncMemoryClient
from trpc_agent_sdk.tools.mem0_tool import SearchMemoryTool, SaveMemoryTool

# Create platform client
client = AsyncMemoryClient(
    api_key="m0-your-api-key",
    host="https://api.mem0.ai"
)

# Instantiate tools with the client
search_memory_tool = SearchMemoryTool(client=client)
save_memory_tool = SaveMemoryTool(client=client)

Detailed Configuration: See Complete Example - Platform Mode

Mem0 Quick Start¶

1. Install Dependencies¶

# Install Mem0 core package
pip install mem0ai

# Additional dependencies for self-hosted mode
pip install sentence-transformers qdrant-client

# Or install via trpc-agent extension
pip install -e ".[mem0]"

2. Create Agent¶

from trpc_agent_sdk.agents import LlmAgent
from trpc_agent_sdk.tools.mem0_tool import SearchMemoryTool, SaveMemoryTool

# Step 1: Instantiate tools, pass in Mem0 client (choose self-hosted or platform mode)
search_memory_tool = SearchMemoryTool(client=your_mem0_client)
save_memory_tool = SaveMemoryTool(client=your_mem0_client)

# Step 2: Create Agent with memory tools
agent = LlmAgent(
    name="memory_assistant",
    description="A personal assistant with memory capabilities",
    model=your_model,
    instruction="""
    You are a helpful assistant with memory capabilities.
    - Use search_memory to recall past conversations
    - Use save_memory to store important information
    - Always personalize responses based on memory
    """,
    tools=[search_memory_tool, save_memory_tool],
)

3. Run Agent¶

from trpc_agent_sdk.runners import Runner

runner = Runner(
    app_name="memory_app",
    agent=agent,
    session_service=your_session_service
)

# Interact with Agent, memory features are used automatically
async for event in runner.run_async(
    user_id="alice",
    session_id="session_1",
    new_message=user_input
):
    # Process response
    pass

Complete Runnable Example: examples/memory_service_with_mem0/run_agent.py

Tool API¶

SearchMemoryTool¶

Search the user's historical memories.

Constructor:

SearchMemoryTool(
    client: Union[AsyncMemoryClient, AsyncMemory],
    filters_name: str | None = None,   # Optional: filter name passed through to BaseTool
    filters: dict | None = None,       # Optional: filter conditions passed through to BaseTool
    **kwargs,                          # Optional: additional parameters passed through to client.search() (e.g., limit)
)

Agent Tool Parameters (callable by LLM): - query (string, required): Search query content (natural language)

user_id is automatically injected by the framework from InvocationContext and does not need to be passed as a tool parameter.

Return Value:

# Memories found successfully
{
    "status": "success",
    "memories": "- Memory content 1\n- Memory content 2",
    "user_id": "alice"
}

# No memories found
{
    "status": "no_memories",
    "message": "No relevant memories found"
}

SaveMemoryTool¶

Save important information to user memory.

Constructor:

SaveMemoryTool(
    client: Union[AsyncMemoryClient, AsyncMemory],
    filters_name: str | None = None,   # Optional: filter name passed through to BaseTool
    filters: dict | None = None,       # Optional: filter conditions passed through to BaseTool
    infer: bool = True,                # Optional: whether to enable LLM semantic extraction (default True)
    **kwargs,                          # Optional: additional parameters passed through to client.add()
)

When infer=True, Mem0 calls the LLM for semantic extraction before storage; when infer=False, the raw content is stored directly.

Agent Tool Parameters (callable by LLM): - content (string, required): Content to save

user_id is automatically injected by the framework from InvocationContext and does not need to be passed as a tool parameter.

Return Value:

# Save successful
{
    "status": "success",
    "message": "Information saved to memory",
    "result": {...},
    "user_id": "alice"
}

# Save failed
{
    "status": "error",
    "message": "Failed to save memory: error details",
    "user_id": "alice"
}

Tool Source Code: trpc_agent_sdk/tools/mem0_tool.py

Typical Workflow (Tool-based)¶

Scenario: Personal Assistant Remembering User Preferences¶

1. User: Do you remember my name?
   ↓
   Agent calls: search_memory(query="user's name")
   Framework automatically injects user_id="alice"
   ↓
   Result: no_memories
   ↓
   Agent: I don't have your name. Could you tell me?

2. User: My name is Alice
   ↓
   Agent calls: save_memory(content="User's name is Alice")
   Framework automatically injects user_id="alice"
   ↓
   Result: success
   ↓
   Agent: Thank you, Alice! I'll remember that.

3. User: Do you remember my name?
   ↓
   Agent calls: search_memory(query="user's name")
   Framework automatically injects user_id="alice"
   ↓
   Result: success, memories="- Name is Alice"
   ↓
   Agent: Yes, your name is Alice!

View Complete Demo Output (Mem0MemoryService): Execution Result Analysis

Advanced Features¶

Multi-user Memory Isolation¶

Memory isolation at the user level is achieved through the user_id parameter:

# User A's memories
await runner.run_async(user_id="user_a", ...)

# User B's memories (completely independent)
await runner.run_async(user_id="user_b", ...)

Memory Filtering and Search¶

The filters parameter enables fine-grained memory retrieval, supporting filtering by user, category, and other dimensions to avoid interference from cross-user or irrelevant memories:

memories = await mem0_client.search(
    query="favorite food",       # Semantic search query (Mem0 vectorizes and matches)
    filters={
        "user_id": "alice",      # Restrict to user scope, ensuring memory isolation
        "category": "preferences",  # Custom category tag, narrowing search scope
    },
    limit=5,                     # Return at most 5 most relevant memories
)

Direct Memory Management¶

In addition to indirect operations through Agent tools, you can also directly call the Mem0 client API to manage memories (add, delete, query):

# Get all memories for a specific user
all_memories = await memory.get_all(user_id="alice")

# Delete a single memory by memory_id
await memory.delete(memory_id="memory-id")

# Clear all memories for the user
await memory.delete_all(user_id="alice")

More Advanced Usage: Advanced Usage Documentation

Mem0 FAQ¶

How to Choose a Deployment Mode?¶

Consideration	Self-hosted	Platform
High data privacy requirements	✅	❌
Quick startup	❌	✅
Need custom embedding models	✅	❌
Production high availability	❌	✅
Cost-sensitive (small scale)	✅	❌

Common Errors in Self-hosted Mode¶

Vector Dimension Mismatch:

Vector dimension error: expected dim: 1536, got 384

Cause: Embedding model dimensions do not match the vector database collection. Solution: Ensure the embedding model and vector database collection have matching dimensions (e.g., multi-qa-MiniLM-L6-cos-v1 outputs 384 dimensions).

Cannot Connect to Qdrant:

ConnectionError: Cannot connect to Qdrant at localhost:6333

Solution: Confirm Qdrant is running (docker run -p 6333:6333 qdrant/qdrant).

More Issues: Mem0MemoryService FAQ

Mem0 References¶

Framework Resources¶

Resource	Path	Description
`Mem0MemoryService` complete example	examples/memory_service_with_mem0/	Includes execution result analysis, FAQ
`Mem0MemoryService` source code	mem0_memory_service.py	Service implementation
Tool-based integration source code	mem0_tools.py	`SearchMemoryTool` / `SaveMemoryTool` tool classes
infer parameter details	README.md#infer-参数详解	True vs False comparison
FAQ	README.md#常见问题-qa	Error analysis and answers

Mem0 Official Resources¶

Official Documentation: https://docs.mem0.ai/introduction
GitHub: https://github.com/mem0ai/mem0
Example Code: https://github.com/mem0ai/mem0/tree/main/examples
Platform Console: https://app.mem0.ai/dashboard

Next Steps¶

Quick Start (recommended): Check out the Mem0MemoryService Complete Example and run run_agent.py
Choose Deployment Mode: Refer to the Self-hosted vs Remote Platform Comparison
Understand infer Differences: Refer to infer Parameter Details to choose the appropriate configuration
Platform Deployment: Register on the Mem0 Platform and obtain an API Key
Custom Development: Extend custom logic based on the Mem0MemoryService Source Code

Integrating MemPalace¶

What is MemPalace?¶

MemPalace is a local-first memory system for storing verbatim memories and retrieving historical context with semantic search. Its core storage hierarchy can be understood as:

Palace
  └── Wing
        └── Room
              └── Drawer

In MempalaceMemoryService, each storable framework event is filed as a drawer. The drawer contains the original text and metadata such as wing, room, session_id, event_id, author, and timestamp.

Core Capabilities: - Local persistent storage in a MemPalace palace directory - Semantic search through MemPalace / ChromaDB - wing and room filters for memory isolation - CLI inspection through mempalace search - TTL cleanup managed by the framework memory service

tRPC-Agent Integration Methods¶

The recommended integration path is the framework-level memory service:

Method	Class / Tool	Applicable Scenario
Framework-level memory service (recommended)	`MempalaceMemoryService`	The framework automatically writes cross-session memories; the Agent retrieves them through `load_memory`
MemPalace tools	`mempalace_search` / `mempalace_add_drawer`, etc.	The Agent needs direct access to MemPalace drawers, diary, KG, or other advanced capabilities

MempalaceMemoryService is the standard MemoryService integration for this project. The framework calls store_session() automatically after each turn to persist memory, while the Agent calls load_memory during response generation to retrieve historical memories through search_memory().

MempalaceMemoryService (Recommended)¶

MempalaceMemoryService is a framework-level memory service. The framework stores session memories automatically after each turn, while the Agent retrieves related memories through the built-in load_memory tool.

How It Works: Stores memory data as MemPalace drawers in a local-first memory palace backed by ChromaDB.

Implementation Details (based on mempalace_memory_service.py): - Data Structure: MemPalace Palace -> Wing -> Room -> Drawer - Storage Location: Local MemPalace palace directory, usually ~/.mempalace/palace - Search Method: MemPalace hybrid semantic search (search_memories) with wing / room filters - TTL Mechanism: Background periodic cleanup task; expired drawers are deleted by metadata timestamp - Write Mode: Incremental background writes; events already scheduled or stored in the current process are skipped - Cross-session sharing: session.save_key, usually {app_name}/{user_id}, is used as the cross-session memory dimension

Persistence: ✅ Yes. Data is persisted in the MemPalace palace directory and can be recovered after application restart.

Applicable Scenarios: - ✅ Local-first semantic memory - ✅ Cross-session user profile and preference memory - ✅ Development or private deployments that should keep memory data on local disk - ✅ Scenarios where CLI inspection with mempalace search is useful

Quick Integration¶

Step 1: Install dependencies

# Install through the trpc-agent extra
pip install -e ".[mempalace]"

# Or install MemPalace directly
pip install mempalace

Step 2: Create MempalaceMemoryService

from trpc_agent_sdk.memory import MemoryServiceConfig
from trpc_agent_sdk.memory.mempalace_memory_service import MempalaceMemoryService

memory_service = MempalaceMemoryService(
    memory_service_config=MemoryServiceConfig(
        enabled=True,
        ttl=MemoryServiceConfig.create_ttl_config(
            enable=True,
            ttl_seconds=86400,
            cleanup_interval_seconds=3600,
        ),
    ),
    wing="my_app_user",
    room="conversations",
)

Step 3: Pass memory_service to Runner

from trpc_agent_sdk.runners import Runner
from trpc_agent_sdk.sessions import InMemorySessionService
from trpc_agent_sdk.tools import load_memory_tool

agent = LlmAgent(
    name="assistant",
    model=your_model,
    tools=[load_memory_tool],
    instruction="Use load_memory to recall relevant past conversations before answering.",
)

runner = Runner(
    app_name="my_app",
    agent=agent,
    session_service=InMemorySessionService(),
    memory_service=memory_service,
)

Step 4: Run the Agent; memories are persisted across sessions automatically

# First conversation round (session_1)
async for event in runner.run_async(user_id="alice", session_id="session_1", new_message=...):
    ...
# After the turn finishes, the framework calls store_session and writes storable events to MemPalace.

# Second conversation round (session_2) — a new session can still retrieve memories from session_1.
async for event in runner.run_async(user_id="alice", session_id="session_2", new_message=...):
    ...

Complete Runnable Example: examples/memory_service_with_mempalace/run_agent.py

MemPalace Hierarchy Mapping¶

session.save_key = "{app_name}/{user_id}"   -> wing (when wing is not explicitly configured)
room                                      -> room, defaults to conversations
Event                                     -> drawer
session.id / event.id / author / timestamp -> drawer metadata

If wing="trpc-agent" is configured explicitly, all memories are written into that wing. If wing is omitted, the service derives the wing from save_key, which is usually the more natural isolation strategy for app/user-scoped long-term memory.

Path and CLI Search¶

MemPalace stores data under MempalaceConfig().palace_path. The default path is usually:

~/.mempalace/palace

You can configure a custom path through an environment variable:

export MEMPALACE_PALACE_PATH=/path/to/palace

Or through ~/.mempalace/config.json:

{
  "palace_path": "/path/to/palace",
  "collection_name": "mempalace_drawers"
}

If the application is configured to use a custom palace path, CLI search must use the same path:

mempalace --palace /path/to/palace search "user name"

Filter by wing and room:

mempalace --palace /path/to/palace search "user name" \
  --wing my_app_user \
  --room conversations

If no custom path is configured, MemPalace uses its default config, and CLI search can omit --palace:

mempalace search "user name" --wing my_app_user --room conversations

/path/to/palace is the MemPalace data directory that contains chroma.sqlite3, not a single database file.

TTL Configuration (Optional)¶

memory_service_config = MemoryServiceConfig(
    enabled=True,
    ttl=MemoryServiceConfig.create_ttl_config(
        enable=True,
        ttl_seconds=86400,              # Keep memories for 24 hours
        cleanup_interval_seconds=3600,  # Run cleanup every hour
    ),
)

Important notes:

MemPalace itself does not delete memories automatically just because they have not been used for a long time.
MempalaceMemoryService implements TTL cleanup at the framework layer.
Cleanup scans drawers written by this service and deletes expired records based on the timestamp metadata.
This TTL policy is based on the original event timestamp; it is not an "extend expiration on access" policy.

Direct Memory Management¶

The service provides a helper to delete all drawers in a wing, or only drawers in a specific room:

await memory_service.delete_memory(wing="my_app_user")
await memory_service.delete_memory(wing="my_app_user", room="conversations")

MemPalace CLI currently does not provide a direct command to delete all memories by wing / room; use the service helper or call the underlying collection delete(where=...).

Storage Content Policy¶

In general, only ordinary text events with long-term value should be written to MemPalace. Intermediate tool calls, tool responses, and code execution results are usually poor long-term memories because they can cause:

load_memory results to be written back into memory again
nested historical memory JSON inside newly stored memories
tool logs polluting long-term memory and reducing retrieval quality

MempalaceMemoryService is better suited for memories such as:

User: My name is Alice.
User: My favorite color is blue.
Assistant: Confirmed the user's name or preference.

Rather than:

[tool_call] load_memory: ...
[tool_response] load_memory: {"memories": [...]}

Typical Workflow¶

1. User: Do you remember my name?
   ↓
   Agent calls: load_memory(query="user name")
   ↓
   Result: {"memories": []}
   ↓
   Agent: I don't know your name yet.

2. User: My name is Alice
   ↓
   After the turn, the framework automatically calls MempalaceMemoryService.store_session()
   ↓
   The user message is written as a drawer under the configured wing/room

3. User starts a new session: Do you remember my name?
   ↓
   Agent calls: load_memory(query="user name")
   ↓
   MemPalace returns a historical memory containing "My name is Alice"
   ↓
   Agent: Yes, your name is Alice.

Complete Demo Output (MempalaceMemoryService): examples/memory_service_with_mempalace/README.md

Tool-based Integration (mempalace_tool)¶

mempalace_tool is another way to integrate with MemPalace. It is not the recommended standard MemoryService path. Instead, it exposes MemPalace capabilities as Agent-callable tools, allowing the Agent to decide when to search, write drawers, read or write diary entries, or maintain KG facts.

The difference from MempalaceMemoryService is:

Method	Write Timing	Retrieval Method	Applicable Scenario
`MempalaceMemoryService`	The framework writes automatically after each turn	`load_memory` indirectly calls `search_memory()`	Standard cross-session long-term memory
`mempalace_tool`	The Agent explicitly calls tools to write	The Agent explicitly calls `mempalace_search`	Fine-grained control over MemPalace drawers, diary, KG, or manual memory management

Available Tools¶

Tool Class	Tool Name	Function	Use Case
`MempalaceSearchTool`	`mempalace_search`	Semantically search saved drawer content	The Agent needs to recall user profiles, preferences, or historical facts
`MempalaceAddDrawerTool`	`mempalace_add_drawer`	Write a verbatim drawer under a specified `wing/room`	The user explicitly asks the Agent to remember long-term information
`MempalaceDiaryWriteTool`	`mempalace_diary_write`	Write an agent diary entry	Record runtime observations, task progress, or interim summaries
`MempalaceDiaryReadTool`	`mempalace_diary_read`	Read recent diary entries for an agent	The Agent needs to review previous task notes
`MempalaceKGAddTool`	`mempalace_kg_add`	Write a knowledge-graph triple fact	Structured facts such as `subject -> predicate -> object`
`MempalaceKGQueryTool`	`mempalace_kg_query`	Query relationships for a knowledge-graph entity	Query facts about Alice, project dependencies, or entity relationships
`MempalaceKGTimelineTool`	`mempalace_kg_timeline`	Read knowledge-graph facts as a timeline	Inspect how an entity's relationships change over time
`MempalaceKGInvalidateTool`	`mempalace_kg_invalidate`	Mark a current fact as no longer valid	Represent fact changes while keeping historical records

Note: Like mem0_tool, mempalace_tool exposes tools to the Agent and lets the model decide when to call them. Unlike Mem0's two search/save tools, MemPalace tools also cover diary and KG operations. See the complete example at examples/mempalace_tools/README.md, and the tool source at mempalace_tool.py.

Integration Architecture¶

┌──────────────────────┐
│    User Input        │
└──────────┬───────────┘
           │
           ▼
┌──────────────────────┐
│  tRPC-Agent          │◄────────────────┐
│  LlmAgent            │                 │
└──────────┬───────────┘                 │
           │                             │ returns tool results
           │ calls tools                 │
           ▼                             │
┌──────────────────────┐                 │
│  MemPalace Tools     │─────────────────┘
│  - mempalace_search  │
│  - add_drawer        │
│  - diary read/write  │
│  - KG tools          │
└──────────┬───────────┘
           │
           ▼
┌──────────────────────┐
│  MemPalace Backend   │
│  - Palace / ChromaDB │
│  - KG SQLite         │
└──────────────────────┘

Quick Integration¶

from trpc_agent_sdk.agents import LlmAgent
from trpc_agent_sdk.tools.mempalace_tool import MempalaceAddDrawerTool
from trpc_agent_sdk.tools.mempalace_tool import MempalaceDiaryReadTool
from trpc_agent_sdk.tools.mempalace_tool import MempalaceDiaryWriteTool
from trpc_agent_sdk.tools.mempalace_tool import MempalaceKGAddTool
from trpc_agent_sdk.tools.mempalace_tool import MempalaceKGInvalidateTool
from trpc_agent_sdk.tools.mempalace_tool import MempalaceKGQueryTool
from trpc_agent_sdk.tools.mempalace_tool import MempalaceKGTimelineTool
from trpc_agent_sdk.tools.mempalace_tool import MempalaceSearchTool

palace_path = "/tmp/trpc-agent-mempalace-demo"
kg_path = "/tmp/trpc-agent-mempalace-demo/knowledge_graph.sqlite3"

tools = [
    MempalaceSearchTool(palace_path=palace_path),
    MempalaceAddDrawerTool(palace_path=palace_path),
    MempalaceDiaryWriteTool(palace_path=palace_path),
    MempalaceDiaryReadTool(palace_path=palace_path),
    MempalaceKGAddTool(palace_path=palace_path, kg_path=kg_path),
    MempalaceKGQueryTool(palace_path=palace_path, kg_path=kg_path),
    MempalaceKGTimelineTool(palace_path=palace_path, kg_path=kg_path),
    MempalaceKGInvalidateTool(palace_path=palace_path, kg_path=kg_path),
]

agent = LlmAgent(
    name="memory_assistant",
    model=your_model,
    instruction="""
    You are a helpful assistant with MemPalace tools.
    - Use mempalace_search before answering questions that may require past memory.
    - Use mempalace_add_drawer when the user explicitly asks you to remember stable facts.
    - Use diary tools for agent diary entries.
    - Use KG tools for structured facts such as Alice -> likes -> Italian food.
    """,
    tools=tools,
)

Specify the MemPalace Path¶

Tool classes accept palace_path. If it is omitted, they use MempalaceConfig().palace_path. KG tools also accept kg_path; if kg_path is omitted and palace_path is provided, they default to palace_path/knowledge_graph.sqlite3:

mempalace_search_tool = MempalaceSearchTool(palace_path="/path/to/palace")
mempalace_add_drawer_tool = MempalaceAddDrawerTool(palace_path="/path/to/palace")
mempalace_kg_query_tool = MempalaceKGQueryTool(
    palace_path="/path/to/palace",
    kg_path="/path/to/palace/knowledge_graph.sqlite3",
)

Use the same path when inspecting memories from the CLI:

mempalace --palace /path/to/palace search "user name"

The example manages paths through .env:

MEMPALACE_PALACE_PATH=/tmp/trpc-agent-mempalace-demo
MEMPALACE_KG_PATH=/tmp/trpc-agent-mempalace-demo/knowledge_graph.sqlite3
MEMPALACE_WING=personal_assistant_alice
MEMPALACE_ROOM=user_profile

Tool-based Workflow¶

1. User: Use mempalace_search to check whether you remember my name.
   ↓
   Agent calls: mempalace_search(
       query="name",
       wing="personal_assistant_alice",
       room="user_profile"
   )
   ↓
   Result: No palace found or empty results
   ↓
   Agent: I do not know your name yet.

2. User: Use mempalace_add_drawer to remember that my name is Alice.
   ↓
   Agent calls: mempalace_add_drawer(
       wing="personal_assistant_alice",
       room="user_profile",
       content="User's name is Alice."
   )
   ↓
   MemPalace writes the drawer

3. User starts a new session: Use mempalace_search to recall my name.
   ↓
   Agent calls: mempalace_search(query="name", wing="personal_assistant_alice", room="user_profile")
   ↓
   MemPalace returns "User's name is Alice."
   ↓
   Agent: Your name is Alice.

4. User: Use mempalace_kg_add to add this fact: Alice likes Italian food.
   ↓
   Agent calls: mempalace_kg_add(subject="Alice", predicate="likes", object="Italian food")
   ↓
   KG writes the triple fact: Alice -> likes -> Italian food

5. User: Use mempalace_kg_invalidate to mark the fact Alice likes Italian food as ended today.
   ↓
   Agent calls: mempalace_kg_invalidate(subject="Alice", predicate="likes", object="Italian food")
   ↓
   KG keeps the historical fact but marks current as false

Complete tool-based demo and result analysis: examples/mempalace_tools/README.md

MempalaceSearchTool¶

Semantically searches drawer content saved in MemPalace.

Constructor:

MempalaceSearchTool(
    palace_path: str | None = None,
    filters_name: list[str] | None = None,
    filters: list[Any] | None = None,
)

Agent Tool Parameters (callable by LLM): - query (string, required): Search query - limit (integer, optional): Maximum number of results, defaults to 5 - wing (string, optional): Filter by wing - room (string, optional): Filter by room

Return Value Example:

{
    "query": "name favorite food",
    "filters": {"wing": "personal_assistant_alice", "room": "user_profile"},
    "results": [
        {"text": "User's name is Alice.", "wing": "personal_assistant_alice", "room": "user_profile"},
        {"text": "My favorite food is Italian food.", "wing": "personal_assistant_alice", "room": "user_profile"},
    ],
}

MempalaceAddDrawerTool¶

Writes a verbatim drawer under a specified wing/room. It is suitable for long-term facts that the user explicitly asks the Agent to remember.

Agent Tool Parameters (callable by LLM): - wing (string, required): Storage scope, for example personal_assistant_alice - room (string, required): Memory topic, for example user_profile - content (string, required): Verbatim content to save - source_file (string, optional): Source identifier

Return Value Example:

{
    "success": True,
    "drawer_id": "drawer_personal_assistant_alice_user_profile_xxx",
    "wing": "personal_assistant_alice",
    "room": "user_profile",
}

Diary Tools¶

MempalaceDiaryWriteTool and MempalaceDiaryReadTool record and read agent diary entries. They are useful for "what happened in this task, what was observed, and what to watch next" style runtime notes, and should not replace user-profile memories.

Tool	Key Parameters	Return Highlights
`mempalace_diary_write`	`entry`, `agent_name`, `topic`, `wing`	`success`, `entry_id`, `agent`, `topic`
`mempalace_diary_read`	`agent_name`, `last_n`, `wing`	`entries`, `total`, `showing`

In the example output, after writing Alice tested the MemPalace tools example today., a later new session can still read that diary entry, showing that diary data is persisted.

KG Tools¶

KG tools maintain structured facts. A fact is usually represented as a triple:

subject -> predicate -> object
Alice -> likes -> Italian food

Tool	Key Parameters	Semantics
`mempalace_kg_add`	`subject`, `predicate`, `object`, `valid_from`, `valid_to`, `confidence`	Write a structured fact
`mempalace_kg_query`	`entity`, `as_of`, `direction`	Query facts related to an entity
`mempalace_kg_timeline`	`entity`	Inspect an entity's fact timeline
`mempalace_kg_invalidate`	`subject`, `predicate`, `object`, `ended`	Mark a fact as no longer valid

mempalace_kg_invalidate does not delete the historical fact. It sets valid_to and makes current=False. The example therefore runs invalidation after the second-phase persistence verification, so it does not alter the query result used to validate persistence.

Recommendations¶

If you only need standard cross-session long-term memory, prefer MempalaceMemoryService.
Use mempalace_tool when the Agent needs direct control over what to write, how to classify it, diary operations, or KG maintenance.
For user profiles and preferences, write to a stable wing/room, such as personal_assistant_alice/user_profile.
For KG fact changes, prefer mempalace_kg_invalidate to express "no longer true" instead of deleting history.
Do not let the Agent write load_memory tool results, code execution outputs, or other intermediate traces directly into drawers, as this can pollute long-term memory.

MemPalace Resources¶

Resource	Path	Description
`MempalaceMemoryService` complete example	examples/memory_service_with_mempalace/	Installation, path configuration, CLI search, and execution result analysis
`MempalaceMemoryService` source code	mempalace_memory_service.py	Recommended framework-level memory service implementation
MemPalace tools source code	mempalace_tool.py	Optional tool-based integration: `mempalace_search`, `mempalace_add_drawer`, diary, KG tools

Core Feature Summary¶

✅ Different sessions can access the same memory data
✅ Uses save_key (app_name/user_id) as the memory key
✅ Suitable for storing user profiles, long-term preferences, and other cross-session information

2. Keyword or Semantic Search¶

✅ Supports keyword extraction and matching for both Chinese and English
✅ Uses extract_words_lower to extract English words and Chinese characters
✅ Matching logic: returns on any query word match
✅ Semantic memory services such as MempalaceMemoryService and Mem0MemoryService use vector / semantic retrieval instead of simple keyword matching

3. TTL Cache Eviction¶

✅ Automatically cleans up expired memories, preventing unlimited storage growth
✅ Refreshes TTL on access (during search_memory)
✅ Different implementations use different cleanup mechanisms
⚠️ Some persistent semantic services may use fixed event timestamps for TTL cleanup rather than refreshing TTL on every search

4. Automatic Storage¶

✅ When enabled=True, MemoryService automatically stores Session events
✅ No need to manually call store_session (unless special control is required)
✅ Only stores events with content (event.content and event.content.parts)

5. Flexible Storage Backends¶

✅ Supports multiple implementations: In-Memory, Redis, SQL, Mem0, etc.
✅ Supports TRPC Redis integration
✅ Supports Mem0 semantic memory integration (vector search + LLM extraction)
✅ Supports MemPalace local-first semantic memory integration (ChromaDB-backed palace)
✅ Choose the appropriate implementation based on your scenario

Notes¶

1. enabled Parameter¶

enabled=True: MemoryService automatically stores Session events, no need to manually call store_session
enabled=False: MemoryService does not store any data; both store_session and search_memory will have no effect

2. Keyword Search Limitations¶

The built-in InMemory/Redis/SQL implementations use keyword (token) matching, not semantic search
After extract_words_lower (whole English words, individual Chinese characters), any query token that appears in the event's token set counts as a match (this is not full-sentence semantic similarity)
Suitable for rapid prototyping, not suitable for complex semantic retrieval requirements
For semantic retrieval, use MempalaceMemoryService or Mem0MemoryService

3. TTL Configuration¶

ttl_seconds: Memory expiration time (in seconds)
cleanup_interval_seconds: Cleanup interval (InMemory/SQL/MemPalace; Redis handles expiration automatically)
InMemory/Redis refresh TTL on access; persistent semantic services may use stored timestamps for expiration

4. Concurrency Safety¶

InMemoryMemoryService: Thread-safe within a single process
RedisMemoryService: Supports multi-process/multi-server concurrency
SqlMemoryService: Supports multi-process/multi-server concurrency (using database transactions)
MempalaceMemoryService: Local-first storage; avoid multiple processes writing to the same palace unless the underlying MemPalace/ChromaDB deployment is managed carefully

Summary¶

MemoryService provides powerful long-term memory management capabilities:

✅ Cross-session sharing: Different sessions can access shared memories
✅ Automatic storage: Automatically stores Session events when enabled=True
✅ Search: Supports keyword matching and semantic memory retrieval depending on implementation
✅ TTL eviction: Automatically cleans up expired memories
✅ Multiple implementations: In-Memory, Redis, SQL, TRPC Redis, Mem0, MemPalace

Through proper use of MemoryService, you can achieve: - User profile construction - Long-term preference memory - Cross-session knowledge sharing - Intelligent conversation context

For more detailed usage examples, please refer to the related examples in the examples/ directory.

Memory Service Documentation¶

Overview¶

Memory vs Session¶

Core Capabilities of MemoryService¶

1. Storing Session Memory¶

2. Searching Related Memories¶

3. TTL (Time-To-Live) Cache Eviction¶

4. Cross-Session Sharing¶

MemoryService Implementations¶

InMemoryMemoryService¶

RedisMemoryService¶

SqlMemoryService¶

Comparison of Three Implementations¶

Usage Examples¶

Basic Usage Flow¶

Manual Storage and Search¶

Integrating SessionService and MemoryService¶

Related Examples¶

InMemoryMemoryService¶

RedisMemoryService¶

SqlMemoryService¶

Integrating Mem0¶

What is Mem0?¶

tRPC-Agent Integration Methods¶

Mem0MemoryService (Recommended)¶

Core Design¶

Quick Integration¶

infer Parameter Selection¶

TTL Configuration (Optional)¶

Tool-based Integration (mem0_tool)¶

Integration Architecture¶

Deployment Modes¶

Mode Comparison¶

Mode 1: Self-hosted (AsyncMemory)¶

Mode 2: Platform (AsyncMemoryClient)¶

Mem0 Quick Start¶

1. Install Dependencies¶

2. Create Agent¶

3. Run Agent¶

Tool API¶

SearchMemoryTool¶

SaveMemoryTool¶

Typical Workflow (Tool-based)¶

Scenario: Personal Assistant Remembering User Preferences¶

Advanced Features¶

Multi-user Memory Isolation¶

Memory Filtering and Search¶

Direct Memory Management¶

Mem0 FAQ¶

How to Choose a Deployment Mode?¶

Common Errors in Self-hosted Mode¶

Mem0 References¶

Framework Resources¶

Mem0 Official Resources¶

Next Steps¶

Integrating MemPalace¶

What is MemPalace?¶

tRPC-Agent Integration Methods¶

MempalaceMemoryService (Recommended)¶

Quick Integration¶

MemPalace Hierarchy Mapping¶

Path and CLI Search¶

TTL Configuration (Optional)¶

Direct Memory Management¶

Storage Content Policy¶

Typical Workflow¶

Tool-based Integration (mempalace_tool)¶

Available Tools¶

Integration Architecture¶

Quick Integration¶

Specify the MemPalace Path¶

Tool-based Workflow¶

MempalaceSearchTool¶

MempalaceAddDrawerTool¶

Diary Tools¶

KG Tools¶

Recommendations¶

MemPalace Resources¶

Core Feature Summary¶

1. Cross-session Memory Sharing¶

`infer` Parameter Selection¶