Python：为什么它向 Stackdriver 发送重复的日志？

Question

我将从我的数据管道生成的日志发送到 GCP 上的 Stackdriver。但由于某种原因，它发送了相同事件日志的多个副本。在我的ensure_stackdriver_logging 函数中，我检查处理程序是否已经存在，以防止如果重新运行task，处理程序将不会被多次添加。有谁知道是什么问题？

def ensure_stackdriver_logging():
    logger = get_logger()
    lg_client = google.cloud.logging.Client()
    lg_handler = CloudLoggingHandler(lg_client, 'thinknum_etl_logging')
    if lg_handler not in logger.handlers:
        formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
        lg_handler.setFormatter(formatter)
        logger.setLevel(logging.INFO)
        logger.addHandler(lg_handler)


def task():
    ensure_stackdriver_logging()
    ...

更新：

我也试过了--

def ensure_stackdriver_logging():
    logger = get_logger()

    if hasattr(logger, 'initialized'):
        return logger
    else:
        setattr(logger, 'initialized', True)

    lg_client = google.cloud.logging.Client()
    lg_handler = CloudLoggingHandler(lg_client, 'thinknum_etl_logging')
    formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
    lg_handler.setFormatter(formatter)
    logger.setLevel(logging.INFO)
    logger.addHandler(lg_handler)

但是没有用。

Answer 1

如果您在其他地方调用 ensure_stackdriver_logging() 方法，甚至之前添加了一个记录器处理程序，它会发生两次（或更多），因为您的 if 检查没有按预期工作。

当您进行if lg_handler not in logger.handlers: 检查时，比较发生在lg_handler 对象ID 和列表中的其他对象之间，但是因为您刚刚在列表之前的行中创建了lg_handler，它不会在列表中。

以此为例：

class Foo():
    pass

l = [Foo()]
b = Foo()
print(b in l)
>>> False

b 不在列表中，因为b 指向的对象不在列表中，而是具有相同值的Foo 对象。