¿Cómo crear un controlador de registro para conectarse a Oracle?

Question

Así que ahora necesito crear e implementar una extensión del módulo de registro de Python que se utilizará para iniciar sesión en nuestra base de datos. Básicamente tenemos varias aplicaciones python (que se ejecutan todas en segundo plano) que actualmente se conectan a una mezcolanza aleatoria de archivos de texto. Lo que hace que sea casi imposible averiguar si una aplicación determinada falló o no.

El problema que se me presenta es mover dicho registro a archivos de texto a una base de datos Oracle. Las tablas ya se han definido, y donde las cosas deben registrarse, pero en este momento, estoy buscando agregar otro controlador de registro que se registrará en el DB.

Estoy usando Python 2.5.4 y cx_Oracle y las aplicaciones en general pueden ser ejecutadas como un servicio/daemon o una aplicación directa.

Solo tengo curiosidad sobre cuál sería la mejor manera de hacerlo. Algunas preguntas:

1. Si se produce algún error con cx_Oracle, ¿dónde deberían registrarse estos errores? Si está abajo, ¿sería mejor ir y hacer que el registrador se retire al archivo de texto predeterminado?

2. Hace un tiempo comenzamos a exigir que las personas usen sys.stderr/stdout.write en lugar de imprimir, por lo que en el peor de los casos no nos toparíamos con ningún problema con la impresión en desuso. ¿Hay alguna manera de hacer que todas las miles de llamadas a sys.std se canalicen directamente al registrador, y que la recuperación del registrador sea floja?

3. Después de cada mensaje registrado, ¿el script debe hacer una confirmación automáticamente? (Habrá varias docenas por segundo.)

4. ¿Cuál es la mejor manera de implementar un nuevo controlador para el sistema de registro? La herencia de la clase básica de Handler parece ser la más fácil.

Cualquier idea/sugerencia sería genial.

Answer 1

1. Si se producen errores con cx_Oracle, es probable que sea mejor registrarlos en un archivo de texto.
2. Puede intentar redireccionar sys.stdout y sys.stderr a objetos similares a archivos que registran lo que está escrito en un registrador.
3. Supongo que desea comprometerse después de cada evento, a menos que tenga razones de peso para no hacerlo. Alternativamente, puede almacenar varios eventos y escribirlos todos en una sola transacción cada cierto tiempo.
4. A continuación se muestra un ejemplo que utiliza mx.ODBC, probablemente puede adaptar esto a cx_Oracle sin demasiados problemas. Creo que es compatible con Python DB-API 2.0.

La distribución Python independiente de registro (antes de añadir el registro a Python) está en http://www.red-dove.com/python_logging.html y aunque el paquete de registro en Python es mucho más hasta la fecha, la distribución independiente contiene un directorio de prueba que tiene una gran cantidad de ejemplos útiles de clases de controlador derivado.

#!/usr/bin/env python 
# 
# Copyright 2001-2009 by Vinay Sajip. All Rights Reserved. 
# 
# Permission to use, copy, modify, and distribute this software and its 
# documentation for any purpose and without fee is hereby granted, 
# provided that the above copyright notice appear in all copies and that 
# both that copyright notice and this permission notice appear in 
# supporting documentation, and that the name of Vinay Sajip 
# not be used in advertising or publicity pertaining to distribution 
# of the software without specific, written prior permission. 
# VINAY SAJIP DISCLAIMS ALL WARRANTIES WITH REGARD TO THIS SOFTWARE, INCLUDING 
# ALL IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL 
# VINAY SAJIP BE LIABLE FOR ANY SPECIAL, INDIRECT OR CONSEQUENTIAL DAMAGES OR 
# ANY DAMAGES WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER 
# IN AN ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT 
# OF OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE. 
# 
# This file is part of the standalone Python logging distribution. See 
# http://www.red-dove.com/python_logging.html 
# 
""" 
A test harness for the logging module. An example handler - DBHandler - 
which writes to an Python DB API 2.0 data source. You'll need to set this 
source up before you run the test. 

Copyright (C) 2001-2009 Vinay Sajip. All Rights Reserved. 
""" 
import sys, string, time, logging 

class DBHandler(logging.Handler): 
    def __init__(self, dsn, uid='', pwd=''): 
     logging.Handler.__init__(self) 
     import mx.ODBC.Windows 
     self.dsn = dsn 
     self.uid = uid 
     self.pwd = pwd 
     self.conn = mx.ODBC.Windows.connect(self.dsn, self.uid, self.pwd) 
     self.SQL = """INSERT INTO Events (
         Created, 
         RelativeCreated, 
         Name, 
         LogLevel, 
         LevelText, 
         Message, 
         Filename, 
         Pathname, 
         Lineno, 
         Milliseconds, 
         Exception, 
         Thread 
        ) 
        VALUES (
         %(dbtime)s, 
         %(relativeCreated)d, 
         '%(name)s', 
         %(levelno)d, 
         '%(levelname)s', 
         '%(message)s', 
         '%(filename)s', 
         '%(pathname)s', 
         %(lineno)d, 
         %(msecs)d, 
         '%(exc_text)s', 
         '%(thread)s' 
        ); 
        """ 
     self.cursor = self.conn.cursor() 

    def formatDBTime(self, record): 
     record.dbtime = time.strftime("#%m/%d/%Y#", time.localtime(record.created)) 

    def emit(self, record): 
     try: 
      #use default formatting 
      self.format(record) 
      #now set the database time up 
      self.formatDBTime(record) 
      if record.exc_info: 
       record.exc_text = logging._defaultFormatter.formatException(record.exc_info) 
      else: 
       record.exc_text = "" 
      sql = self.SQL % record.__dict__ 
      self.cursor.execute(sql) 
      self.conn.commit() 
     except: 
      import traceback 
      ei = sys.exc_info() 
      traceback.print_exception(ei[0], ei[1], ei[2], None, sys.stderr) 
      del ei 

    def close(self): 
     self.cursor.close() 
     self.conn.close() 
     logging.Handler.close(self) 

dh = DBHandler('Logging') 
logger = logging.getLogger("") 
logger.setLevel(logging.DEBUG) 
logger.addHandler(dh) 
logger.info("Jackdaws love my big %s of %s", "sphinx", "quartz") 
logger.debug("Pack my %s with five dozen %s", "box", "liquor jugs") 
try: 
    import math 
    math.exp(1000) 
except: 
    logger.exception("Problem with %s", "math.exp")