Async MongoDB
Persist Agno sessions and other data asynchronously in MongoDB.
AsyncMongoDb stores Agent, Team, and Workflow sessions, memories, knowledge, evaluations, and traces asynchronously in MongoDB.
The v1-to-v2 migration script supports MongoDB. See the migration guide.
Usage
Start in a virtual environment and set the model key before running the example.
Set OpenAI Key
Set your OPENAI_API_KEY as an environment variable. You can get one from OpenAI.
export OPENAI_API_KEY=sk-***Install the pymongo (4.9 or later, for the async client) and openai packages:
uv pip install agno "pymongo>=4.9" openaimotor clients are also supported, but motor is deprecated. Use PyMongo's async client instead.
from agno.agent import Agent
from agno.db.mongo import AsyncMongoDb
db_url = "mongodb://mongoadmin:secret@localhost:27017"
db = AsyncMongoDb(db_url=db_url)
agent = Agent(db=db)Use async methods such as Agent.arun() and Agent.aprint_response() with this database.
Run MongoDB
Install Docker Desktop, then start MongoDB on port 27017:
docker run -d \
--name local-mongo \
-p 27017:27017 \
-e MONGO_INITDB_ROOT_USERNAME=mongoadmin \
-e MONGO_INITDB_ROOT_PASSWORD=secret \
mongoParameters
| Parameter | Type | Default | Description |
|---|---|---|---|
id | Optional[str] | - | Database ID. Derived deterministically from connection/client and database name when omitted. |
db_client | Optional[Union[AsyncIOMotorClient, AsyncMongoClient]] | - | The MongoDB async client to use. Supports Motor and PyMongo async clients. |
db_name | Optional[str] | - | The name of the database to use. |
db_url | Optional[str] | - | The database URL to connect to. |
session_collection | Optional[str] | - | Name of the collection to store sessions. |
runs_collection | Optional[str] | - | Name of the collection to store session runs. |
memory_collection | Optional[str] | - | Name of the collection to store memories. |
metrics_collection | Optional[str] | - | Name of the collection to store metrics. |
eval_collection | Optional[str] | - | Name of the collection to store evaluation runs. |
knowledge_collection | Optional[str] | - | Name of the collection to store knowledge documents. |
traces_collection | Optional[str] | - | Name of the collection to store traces. |
spans_collection | Optional[str] | - | Name of the collection to store spans. |
learnings_collection | Optional[str] | - | Name of the collection to store learnings. |
schedules_collection | Optional[str] | - | Name of the collection to store cron schedules. |
schedule_runs_collection | Optional[str] | - | Name of the collection to store schedule run history. |