我正在尝试实现一个自定义日志处理程序，它应该发布到rabbitmq server1。
这个的基本设置看起来像这样：

class RabbitMQHandler(logging.Handler):

    def __init__(self, host: str, port: int, queue: str,  level: int = 0) -> None:
        self.host = host
        self.port = port
        self.queue = queue

        super().__init__(level)

    def emit(self, record: logging.LogRecord) -> None:
        try:
            msg = self.format(record)
            with pika.BlockingConnection(pika.ConnectionParameters(
                host=self.host,
                port=self.port
            )) as connection:
                channel = connection.channel()
                channel.queue_declare(queue=self.queue)
                channel.basic_publish(
                    exchange='',
                    routing_key=self.queue,
                    body=msg
                )
            self.flush()
        except (KeyboardInterrupt, SystemExit):
            raise
        except Exception:
            self.handleError(record)

字符串
这里的问题似乎是，pika模块试图在建立连接后立即记录自己，因此永远递归地调用emit()函数。
我的问题是，是否应该在发出函数期间简单地禁用日志记录（如何禁用？），或者这是完全错误的方法？

**编辑：**将上面的处理程序放入一个单独的记录器是一种方法，但是我想知道这个问题的一般解决方案。

1我知道有pip packages，但对于这个项目，我必须尽可能避免依赖。