dbpulse-agent 1.1.0

Lightweight database query capture agent for DBPulse — real-time monitoring for PostgreSQL, MySQL, and MongoDB

dbpulse-agent (Python)

Application-layer PostgreSQL query monitoring for Flask, Django, FastAPI, and other Python applications. Queries are timed, correlated with the current HTTP request, buffered, and sent to DBPulse without requiring PostgreSQL monitoring roles.

Supported PostgreSQL drivers

• psycopg2 — Flask, Django, SQLAlchemy, and raw connections
• psycopg v3 — sync/async applications and modern Django
• asyncpg — FastAPI and SQLAlchemy async engines

Install the agent and the driver used by your application:

pip install dbpulse-agent[postgresql]  # psycopg2
pip install dbpulse-agent[psycopg3]    # psycopg v3
pip install dbpulse-agent[asyncpg]     # asyncpg

Initialize DBPulse before creating database connections:

import os
from dbpulse_agent import DBPulseAgent

DBPulseAgent.init(
    api_key=os.environ["DBPULSE_API_KEY"],
    connection_id=os.environ["DBPULSE_CONNECTION_ID"],
    db_type="postgresql",
)

Flask

app = Flask(__name__)
DBPulseAgent.flask_middleware()(app)

Django

Initialize the agent near the top of settings.py, then add:

MIDDLEWARE = [
    "dbpulse_agent.middleware.django_mw.DBPulseDjangoMiddleware",
    # ...
]

FastAPI

app = FastAPI()
app.middleware("http")(DBPulseAgent.fastapi_middleware())

Call DBPulseAgent.shutdown() during application shutdown to flush remaining logs.