6

在我的代码中，记录器以某种方式打印了两次事件，但常规print显示了正确的事件数量。

select 1,2
select 1,2
2013-04-19 18:37:30,618:4561354752 - SQLLogger - DEBUG - select 1,2
2013-04-19 18:37:30,618:4561354752 - SQLLogger - DEBUG - select 1,2
2013-04-19 18:37:30,618:4565561344 - SQLLogger - DEBUG - select 1,2
2013-04-19 18:37:30,618:4565561344 - SQLLogger - DEBUG - select 1,2

我不清楚为什么在多线程情况下多次发布相同的消息。

import logging
from threading import Thread

class SQLEngine(object):
    def __init__(self, DB_PATH):
        ch = logging.StreamHandler()
        ch.setLevel(logging.DEBUG)
        formatter = logging.Formatter('%(asctime)s:%(thread)d - %(name)s - %(levelname)s - %(message)s')
        ch.setFormatter(formatter)
        self.logger = logging.getLogger('SQLLogger')
        self.logger.setLevel(logging.DEBUG)
        self.logger.addHandler(ch)

    def execute(self,SQL,):
            self.logger.debug(SQL)
            print SQL

class DBWorker(Thread):
    def __init__(self, name):
        Thread.__init__(self)
        self.name = name

    def run(self):
        db = SQLEngine('')
        db.execute('select 1,2')

if __name__ == '__main__':
    DBWorker('thread 1').start()
    DBWorker('thread 2').start()
4

2 回答 2

6

查看记录器文档：

记录器永远不会直接实例化，而是始终通过模块级函数 logging.getLogger(name)。多次调用具有相同名称的 getLogger() 将始终返回对同一 Logger 对象的引用。

现在您的构造函数正在调用以下代码：

ch = logging.StreamHandler()
self.logger = logging.getLogger('SQLLogger')
self.logger.addHandler(ch)

请注意，您不会为每个SQLEngine对象都创建一个新的记录器，而是始终获得对同一个记录器实例的引用。这意味着您总是将处理程序添加到同一个记录器，因此在创建第二个对象后，您的记录器有两个处理程序，每个处理程序都打印到屏幕上。

您我们将只需要注册一个处理程序（例如在构造函数之外）或为每个实例SQLEngine调用不同getLogger的名称。__init__SQLEngine

于 2013-04-19T23:06:57.930 回答
0

您已经启动了两个线程，每个线程都有自己的 SQLEngine 属性对象，这些对象在各自的线程运行时被执行。如果您想在多个线程之间共享记录器，那么创建一个可以传递的单个记录器对象将是一个更好的选择。GIL 将负责其余的工作。

import logging
from threading import Thread

class SQLEngine(object):
    def __init__(self, DB_PATH):
        ch = logging.StreamHandler()
        ch.setLevel(logging.DEBUG)
        formatter = logging.Formatter('%(asctime)s:%(thread)d - %(name)s - %(levelname)s - %(message)s')
        ch.setFormatter(formatter)
        self.logger = logging.getLogger('SQLLogger')
        self.logger.setLevel(logging.DEBUG)
        self.logger.addHandler(ch) 

    def execute(self,SQL,): 
        self.logger.debug(SQL)
        print (SQL)

class DBWorker(Thread):
    def __init__(self, name, logengine):
        Thread.__init__(self)
        self.name = name
        self.logger = logengine

    def run(self):
        #db = SQLEngine('')
        self.logger.execute('select 1,2')

if __name__ == '__main__':
    logger = SQLEngine('')
    DBWorker('thread 1', logger).start()
    DBWorker('thread 2', logger).start()

这只是一个例子。正如@tomasz 提到的，您可以根据您的要求处理此记录器对象

于 2013-04-19T23:09:34.920 回答