AsyncMySQLDb stores an Agent’s sessions and run history asynchronously in MySQL. Use async Agent methods such as arun() and aprint_response().
Usage
Install thesqlalchemy, asyncmy, openai, and ddgs packages:
uv pip install sqlalchemy asyncmy openai ddgs
Run MySQL
Install Docker Desktop, then start MySQL on port3306:
docker run -d \
--name mysql \
-e MYSQL_ROOT_PASSWORD=ai \
-e MYSQL_DATABASE=ai \
-e MYSQL_USER=ai \
-e MYSQL_PASSWORD=ai \
-p 3306:3306 \
mysql:8
async_mysql_for_agent.py
import asyncio
import uuid
from agno.agent import Agent
from agno.db.base import SessionType
from agno.db.mysql import AsyncMySQLDb
from agno.tools.websearch import WebSearchTools
db_url = "mysql+asyncmy://ai:ai@localhost:3306/ai"
db = AsyncMySQLDb(db_url=db_url)
agent = Agent(
db=db,
tools=[WebSearchTools()],
add_history_to_context=True,
add_datetime_to_context=True,
)
async def main():
try:
session_id = str(uuid.uuid4())
await agent.aprint_response(
"How many people live in Canada?", session_id=session_id
)
await agent.aprint_response(
"What is their national anthem called?", session_id=session_id
)
session_data = await db.get_session(
session_id=session_id, session_type=SessionType.AGENT
)
print("\n=== SESSION DATA ===")
print(session_data.to_dict())
finally:
await db.close()
if __name__ == "__main__":
asyncio.run(main())
Parameters
| Parameter | Type | Default | Description |
|---|---|---|---|
id | Optional[str] | - | The ID of the database instance. UUID by default. |
db_url | Optional[str] | - | The database URL to connect to. |
db_engine | Optional[AsyncEngine] | - | The SQLAlchemy async database engine to use. |
db_schema | Optional[str] | - | The database schema to use. |
session_table | Optional[str] | - | Name of the table to store Agent, Team and Workflow sessions. |
memory_table | Optional[str] | - | Name of the table to store memories. |
metrics_table | Optional[str] | - | Name of the table to store metrics. |
eval_table | Optional[str] | - | Name of the table to store evaluation runs data. |
knowledge_table | Optional[str] | - | Name of the table to store knowledge content. |
culture_table | Optional[str] | - | Name of the table to store cultural knowledge. |
traces_table | Optional[str] | - | Name of the table to store traces. |
spans_table | Optional[str] | - | Name of the table to store spans. |
versions_table | Optional[str] | - | Name of the table to store schema versions. |
create_schema | bool | True | Whether to create the database schema if it doesn't exist. Set to False when the schema is managed externally. |