sqlalchemy event timing

model.py

import time

from sqlalchemy import event
from sqlalchemy.engine import Engine as SaEngine
from sqlalchemy.orm import Session as SaSession

logger = logging.getLogger("sqlalchemy.engine.base.Engine")

@event.listens_for(SaEngine, "before_cursor_execute")
def before_cursor_execute(conn, cursor, statement, 
                        parameters, context, executemany):
    context._query_start_time = time.time()


@event.listens_for(SaEngine, "after_cursor_execute")
def after_cursor_execute(conn, cursor, statement, 
                        parameters, context, executemany):
    total = time.time() - context._query_start_time
    logger.info("Query Complete! Total Time: %f" % total)