Feast-Powered AI Agent Example
This example demonstrates an AI agent with persistent memory that uses Feast as both a feature store and a context memory layer through the Model Context Protocol (MCP). This demo uses Milvus as the vector-capable online store, but Feast supports multiple vector backends -- including Milvus, Elasticsearch, Qdrant, PGVector, and FAISS -- swappable via configuration.
Agents need more than just access to data -- they need to remember what happened in prior interactions. Feast's online store is entity-keyed, low-latency, governed, and supports both reads and writes, making it a natural fit for agent context and memory.
Capability
How Feast Provides It
| Structured context |
Entity-keyed feature retrieval (customer profiles, account data) |
| Document search |
Vector similarity search via pluggable backends (Milvus, Elasticsearch, Qdrant, PGVector, FAISS) |
| Persistent memory |
Auto-checkpointed after each turn via write_to_online_store |
| Governance |
RBAC, audit trails, and feature-level permissions |
| TTL management |
Declarative expiration on feature views (memory auto-expires) |
| Offline analysis |
Memory is queryable offline like any other feature |
%%{init: {'theme': 'base', 'themeVariables': {'primaryColor': '#E3F2FD', 'primaryBorderColor': '#1565C0', 'primaryTextColor': '#0D47A1', 'lineColor': '#546E7A', 'secondaryColor': '#F3E5F5', 'tertiaryColor': '#E8F5E9'}}}%%
flowchart LR
User((("🧑 User"))):::userClass
subgraph AgentLoop ["🤖 Agent Loop"]
LLM["LLM Engine\ntool-calling · reasoning"]:::agentClass
end
subgraph Feast ["🏗️ Feast MCP Server"]
direction TB
ReadAPI["get_online_features\nretrieve_online_documents"]:::feastClass
WriteAPI["write_to_online_store"]:::feastClass
end
subgraph VectorStore ["🗄️ Online Store"]
direction TB
Profiles[("👤 customer_profile\nplan · spend · tickets")]:::storageClass
Articles[("📚 knowledge_base\nvector embeddings")]:::storageClass
Memory[("🧠 agent_memory\ntopic · resolution · prefs")]:::memoryClass
end
User -->|"query"| LLM
LLM -->|"MCP: recall_memory\nlookup_customer\nsearch_kb"| ReadAPI
LLM -->|"MCP: auto-checkpoint"| WriteAPI
ReadAPI --> Profiles
ReadAPI --> Articles
ReadAPI --> Memory
WriteAPI --> Memory
ReadAPI -.->|"results"| LLM
LLM -->|"answer"| User
classDef userClass fill:#E8EAF6,stroke:#283593,color:#1A237E
classDef agentClass fill:#E3F2FD,stroke:#1565C0,color:#0D47A1
classDef feastClass fill:#FFF3E0,stroke:#E65100,color:#BF360C
classDef storageClass fill:#E8F5E9,stroke:#2E7D32,color:#1B5E20
classDef memoryClass fill:#F3E5F5,stroke:#6A1B9A,color:#4A148C
Loading
The agent has four tools. Feast is both the read path (context) and the write path (memory):
Tool
Direction
What it does
When the LLM calls it
| lookup_customer |
READ |
Fetches customer profile features (plan, spend, tickets) |
Questions about the customer's account |
| search_knowledge_base |
READ |
Retrieves support articles from the vector store |
Questions needing product docs |
| recall_memory |
READ |
Reads past interaction context (last topic, open issues, preferences) |
Start of every conversation |
Memory is auto-saved after each agent turn (not as an LLM tool call). This follows the same pattern used by production frameworks -- see Memory as Infrastructure below.
The agent_memory feature view stores per-customer interaction state:
agent_memory = FeatureView(
name="agent_memory",
entities=[customer],
schema=[
Field(name="last_topic", dtype=String),
Field(name="last_resolution", dtype=String),
Field(name="interaction_count", dtype=Int64),
Field(name="preferences", dtype=String),
Field(name="open_issue", dtype=String),
],
ttl=timedelta(days=30),
)
This gives agents persistent, governed, entity-keyed memory that survives across sessions, is versioned, and lives under the same RBAC as every other feature -- unlike an ad-hoc Redis cache or an in-process dict.
Production agent frameworks treat memory as infrastructure, not an LLM decision. The framework auto-saves state after each step - the LLM never needs to "decide" to persist:
Framework
Memory mechanism
How it works
| LangGraph |
Checkpointers (MemorySaver, PostgresSaver) |
Every graph step is checkpointed automatically by thread_id |
| CrewAI |
Built-in memory (memory=True) |
Short-term, long-term, and entity memory auto-persist after each task |
| AutoGen |
Teachable agents |
Post-conversation hooks extract and store learnings in a vector DB |
| OpenAI Agents SDK |
Application-level |
Serialize RunResult between turns; framework manages state |
This demo follows the same pattern: the agent's three read tools (recall_memory, lookup_customer, search_knowledge_base) are exposed to the LLM for reasoning, while memory persistence is handled by the framework after each turn via _auto_save_memory. This ensures consistent, reliable memory regardless of LLM behaviour - no risk of the LLM forgetting to save, double-saving, or writing inconsistent state.
Feast is a natural fit for this checkpoint layer because it already provides:
- Entity-keyed storage: memory is keyed by customer ID (or any entity)
- TTL management: memory auto-expires via declarative feature view TTL
- Schema enforcement: typed fields prevent corrupt memory writes
- RBAC and audit trails: memory reads/writes are governed like any other feature
- Offline queryability: agent memory can be analysed in batch pipelines
- Python 3.10+
- Feast with MCP and Milvus support
- OpenAI API key (for live tool-calling; demo mode works without it)
cd examples/agent_feature_store
./run_demo.sh
# Or with live LLM tool-calling:
OPENAI_API_KEY=sk-... ./run_demo.sh
The script installs dependencies, generates sample data, starts the Feast server, runs the agent, and cleans up on exit.
pip install "feast[mcp,milvus]"
2. Generate sample data and apply the registry
cd examples/agent_feature_store
python setup_data.py
This creates:
- 3 customer profiles with attributes like plan tier, spend, and satisfaction score
- 6 knowledge-base articles with 384-dimensional vector embeddings
- Empty agent memory scaffold (populated as the agent runs)
3. Start the Feast MCP Feature Server
cd feature_repo
feast serve --host 0.0.0.0 --port 6566 --workers 1
In a new terminal:
# Without API key: runs in demo mode (simulated tool selection)
python agent.py
To run with a real LLM, set the API key and (optionally) the base URL:
# OpenAI
export OPENAI_API_KEY="sk-..." #pragma: allowlist secret
python agent.py
# Ollama (free, local -- no API key needed)
ollama pull llama3.1:8b
export OPENAI_API_KEY="ollama" #pragma: allowlist secret
export OPENAI_BASE_URL="http://localhost:11434/v1"
export LLM_MODEL="llama3.1:8b"
python agent.py
# Any OpenAI-compatible provider (Azure, vLLM, LiteLLM, etc.)
export OPENAI_API_KEY="your-key" #pragma: allowlist secret
export OPENAI_BASE_URL="https://your-endpoint/v1"
export LLM_MODEL="your-model"
python agent.py
Without an API key, the agent simulates the decision-making process with memory:
=================================================================
Scene 1: Enterprise customer (C1001) asks about SSO
Customer: C1001 | Query: "How do I set up SSO for my team?"
=================================================================
[Demo mode] Simulating agent reasoning
Round 1 | recall_memory(customer_id=C1001)
-> No prior interactions found
Round 1 | lookup_customer(customer_id=C1001)
-> Alice Johnson | enterprise plan | $24,500 spend | 1 open tickets
Round 1 | search_knowledge_base(query="How do I set up SSO for my team?...")
-> Best match: "Configuring single sign-on (SSO)"
Round 2 | Generating personalised response...
─────────────────────────────────────────────────────────────
Agent Response:
─────────────────────────────────────────────────────────────
Hi Alice!
Since you're on our Enterprise plan, SSO is available for your
team. Go to Settings > Security > SSO and enter your Identity
Provider metadata URL. We support SAML 2.0 and OIDC...
[Checkpoint] Memory saved: topic="SSO setup"
=================================================================
Scene 4: C1001 returns -- does the agent remember Scene 1?
Customer: C1001 | Query: "I'm back about my SSO question from earlier."
=================================================================
[Demo mode] Simulating agent reasoning
Round 1 | recall_memory(customer_id=C1001)
-> Previous topic: SSO setup
-> Open issue: none
-> Interaction count: 1
Round 1 | lookup_customer(customer_id=C1001)
-> Alice Johnson | enterprise plan | $24,500 spend | 1 open tickets
Round 2 | Generating personalised response...
─────────────────────────────────────────────────────────────
Agent Response:
─────────────────────────────────────────────────────────────
Welcome back, Alice! I can see from our records that we last
discussed "SSO setup". How can I help you today?
[Checkpoint] Memory saved: topic="SSO setup"
Scene 4 demonstrates memory continuity -- the agent recalls the SSO conversation from Scene 1 without the customer re-explaining.
Live mode output (with API key)
With an API key, the LLM autonomously decides which tools to use:
=================================================================
Scene 1: Enterprise customer (C1001) asks about SSO
Customer: C1001 | Query: "How do I set up SSO for my team?"
=================================================================
[Round 1] Tool call: recall_memory({'customer_id': 'C1001'})
[Round 1] Tool call: lookup_customer({'customer_id': 'C1001'})
[Round 1] Tool call: search_knowledge_base({'query': 'SSO setup'})
Agent finished after 2 round(s)
─────────────────────────────────────────────────────────────
Agent Response:
─────────────────────────────────────────────────────────────
Hi Alice! Since you're on our Enterprise plan, SSO is available
for your team. Go to Settings > Security > SSO and enter your
Identity Provider metadata URL. We support SAML 2.0 and OIDC...
[Checkpoint] Memory saved: topic="SSO setup"
Why a raw loop? This example builds the agent from scratch using the OpenAI tool-calling API and the MCP Python SDK to keep dependencies minimal and make every Feast call visible. All Feast interactions go through the MCP protocol -- the agent connects to Feast's MCP endpoint, discovers tools dynamically, and invokes them via session.call_tool(). In production, you would use a framework like LangChain/LangGraph, LlamaIndex, CrewAI, or AutoGen -- Feast's MCP endpoint lets any of them auto-discover the tools with zero custom wiring (see MCP Integration below).
The Agent Loop (agent.py)
from mcp import ClientSession
from mcp.client.streamable_http import streamablehttp_client
async with streamablehttp_client("http://localhost:6566/mcp") as (r, w, _):
async with ClientSession(r, w) as session:
await session.initialize()
tools = await session.list_tools() # discover Feast tools
for round in range(MAX_ROUNDS):
# 1. Send messages + read tools to LLM
response = call_llm(messages, tools=[...])
# 2. If LLM says "stop" -> return the answer
if response.finish_reason == "stop":
break
# 3. Execute tool calls via MCP
for tool_call in response.tool_calls:
result = await session.call_tool(name, args)
messages.append(tool_result(result))
# 4. Framework-style checkpoint: auto-save via MCP
await session.call_tool("write_to_online_store", {...})
The LLM sees the tool definitions (JSON Schema) and decides:
- Which tools to call (can call zero, one, or multiple per round)
- What arguments to pass (e.g., which customer ID to look up)
- When to stop (once it has enough information to answer)
All Feast calls go through MCP (session.call_tool()), not direct REST. Memory is saved automatically after each turn by the framework, not by the LLM. This mirrors how production frameworks handle persistence (see Memory as Infrastructure).
Feature Definitions (feature_repo/features.py)
- customer_profile: Structured data (name, plan, spend, tickets, satisfaction)
- knowledge_base: Support articles with 384-dim vector embeddings (Milvus in this demo; swappable to Elasticsearch, Qdrant, PGVector, or FAISS)
- agent_memory: Per-customer interaction history (last topic, resolution, preferences, open issues)
The Feast Feature Server exposes all endpoints as MCP tools at http://localhost:6566/mcp.
Any MCP-compatible framework can connect:
# LangChain / LangGraph
from langchain_mcp_adapters.client import MultiServerMCPClient
from langgraph.prebuilt import create_react_agent
async with MultiServerMCPClient(
{"feast": {"url": "http://localhost:6566/mcp", "transport": "streamable_http"}}
) as client:
tools = client.get_tools()
agent = create_react_agent(llm, tools)
result = await agent.ainvoke({"messages": "How do I set up SSO?"})
# LlamaIndex
from llama_index.tools.mcp import aget_tools_from_mcp_url
from llama_index.core.agent.function_calling import FunctionCallingAgent
from llama_index.llms.openai import OpenAI
tools = await aget_tools_from_mcp_url("http://localhost:6566/mcp")
agent = FunctionCallingAgent.from_tools(tools, llm=OpenAI(model="gpt-4o-mini"))
response = await agent.achat("How do I set up SSO?")
// Claude Desktop / Cursor
{
"mcpServers": {
"feast": {
"url": "http://localhost:6566/mcp",
"transport": "streamable_http"
}
}
}
Building the same agent with a framework: The examples above show the Feast-specific part -- connecting to the MCP endpoint and getting the tools. Once you have the tools, building the agent follows each framework's standard patterns. The key difference from this demo's raw loop: frameworks handle the tool-calling loop, message threading, and (with LangGraph checkpointers or CrewAI memory=True) automatic state persistence natively. Feast's MCP endpoint means zero custom integration code -- the tools are discovered and callable immediately.
Adapting to your use case: The demo's system prompt, tool wrappers (lookup_customer, recall_memory), and feature views are all specific to customer support. For your own agent, you define your feature views in Feast (e.g., product_catalog, order_history, fraud_signals), run feast apply, and start the server. The same three generic MCP tools -- get_online_features, retrieve_online_documents, and write_to_online_store -- serve any domain. With a framework like LangChain or LlamaIndex, you don't even need custom tool wrappers -- the LLM calls the generic Feast tools directly with your feature view names and entities.
For production, Feast fits into a layered platform architecture:
%%{init: {'theme': 'base', 'themeVariables': {'primaryColor': '#E3F2FD', 'primaryBorderColor': '#1565C0', 'lineColor': '#546E7A'}}}%%
flowchart TB
Agent(("🤖 AI Agent")):::agentClass
subgraph Platform ["🛡️ Production Platform"]
direction TB
Gateway["🔐 MCP Gateway\nJWT auth · tool filtering"]:::platformClass
Sandbox["📦 Sandboxed Container\nkernel-level isolation"]:::platformClass
Guardrails["🛑 Guardrails Orchestrator\ninput/output screening"]:::platformClass
end
subgraph Observability ["📊 Observability + Lifecycle"]
direction LR
OTel["OpenTelemetry + MLflow\ntraces · metrics · audit"]:::obsClass
Kagenti["Kagenti Operator\nAgentCard CRDs · discovery"]:::lifecycleClass
end
subgraph FeastSvc ["🏗️ Feast MCP Server"]
FS["/mcp · /get-online-features · /write-to-online-store"]:::feastClass
end
subgraph Store ["🗄️ Online Store"]
direction LR
P[("👤 Profiles")]:::storageClass
K[("📚 Knowledge Base")]:::storageClass
M[("🧠 Agent Memory")]:::memoryClass
end
Agent --> Gateway
Gateway --> Sandbox
Sandbox --> Guardrails
Guardrails --> FS
FS --> P
FS --> K
FS <--> M
OTel -.->|"traces"| FS
Kagenti -.->|"discover"| FS
classDef agentClass fill:#E3F2FD,stroke:#1565C0,color:#0D47A1
classDef platformClass fill:#FFEBEE,stroke:#C62828,color:#B71C1C
classDef obsClass fill:#FFF8E1,stroke:#F57F17,color:#E65100
classDef lifecycleClass fill:#E0F2F1,stroke:#00695C,color:#004D40
classDef feastClass fill:#FFF3E0,stroke:#E65100,color:#BF360C
classDef storageClass fill:#E8F5E9,stroke:#2E7D32,color:#1B5E20
classDef memoryClass fill:#F3E5F5,stroke:#6A1B9A,color:#4A148C
Loading
This demo uses Milvus Lite (embedded). For production, swap to any supported vector-capable backend by updating feature_store.yaml:
- Milvus cluster: Deploy via the Milvus Operator and set host/port instead of path.
- Elasticsearch: Set online_store: type: elasticsearch with your cluster URL.
- Qdrant: Set online_store: type: qdrant with your Qdrant endpoint.
- PGVector: Set online_store: type: postgres with pgvector_enabled: true.
- FAISS: Set online_store: type: faiss for in-process vector search.