Warning

This document is for an in-development version of Galaxy. You can alternatively view this page in the latest release if it exists or view the top of the latest release's documentation.

Source code for galaxy.model.orm.logging_connection_proxy

import inspect
import logging
import os
import threading

from sqlalchemy.interfaces import ConnectionProxy

try:
    from time import process_time
except ImportError:
    # For compatibility with Python < 3.3
    from time import clock as process_time

log = logging.getLogger(__name__)

wd = os.getcwd()


[docs]def stripwd(s): if s.startswith(wd): return s[len(wd):] return s
[docs]def pretty_stack(): rval = [] for _, fname, line, funcname, _, _ in inspect.stack()[2:]: rval.append("%s:%s@%d" % (stripwd(fname), funcname, line)) return rval
[docs]class LoggingProxy(ConnectionProxy): """ Logs SQL statements using standard logging module """
[docs] def begin(self, conn, begin): thread_ident = threading.current_thread().ident begin(conn) log.debug("begin transaction: thread: %r" % thread_ident)
[docs] def commit(self, conn, commit): thread_ident = threading.current_thread().ident commit(conn) log.debug("commit transaction: thread: %r" % thread_ident)
[docs] def rollback(self, conn, rollback): thread_ident = threading.current_thread().ident rollback(conn) log.debug("rollback transaction: thread: %r" % thread_ident)
[docs] def cursor_execute(self, execute, cursor, statement, parameters, context, executemany): thread_ident = threading.current_thread().ident start = process_time() rval = execute(cursor, statement, parameters, context) duration = process_time() - start log.debug("statement: %r parameters: %r executemany: %r duration: %r stack: %r thread: %r", statement, parameters, executemany, duration, " > ".join(pretty_stack()), thread_ident) return rval
[docs]class TraceLoggerProxy(ConnectionProxy): """ Logs SQL statements using a metlog client """
[docs] def __init__(self, trace_logger): self.trace_logger = trace_logger
[docs] def cursor_execute(self, execute, cursor, statement, parameters, context, executemany): start = process_time() rval = execute(cursor, statement, parameters, context) duration = process_time() - start self.trace_logger.log( "sqlalchemy_query", message="Query executed", statement=statement, parameters=parameters, executemany=executemany, duration=duration ) return rval