Python 中的多处理日志记录:一个强大的解决方案
当使用 Python 的多处理模块时,由于缺乏进程,日志记录变得更加复杂 -多处理感知记录器的共享锁,可能会导致 sys.stderr 输出混乱。
为了解决这一挑战,另一种方法是创建一个自定义日志处理程序,通过管道将输出定向到父进程。此方法依赖队列来处理并发并从错误中恢复。提供的实现可确保生产环境中的稳定日志记录。
自定义处理程序 MultiProcessingLog 扩展了logging.Handler 类并利用 RotatingFileHandler 来处理基于文件的日志记录。它在父进程和子进程之间建立管道,允许集中存储日志。
实现细节:
MultiProcessingLog 处理程序使用单独的线程来接收日志记录来自子进程并将它们转发到父进程中的 RotatingFileHandler。这可确保日志消息的格式正确并写入预期目的地。
要发送日志记录,请使用 send 方法,而接收线程会持续监视管道中的新记录并将其转发到 _handler。
为了最大限度地降低不可拾取的对象导致问题的风险,处理程序在通过管道发送日志记录之前将 exc_info 和 args 值字符串化。
emit 方法被重写以包装 _format_record 调用
这个自定义日志处理程序为管理多处理应用程序中的日志提供了可靠的解决方案,提供集中式日志存储和错误恢复功能。
免责声明: 提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发到邮箱:[email protected] 我们会第一时间内为您处理。
Copyright© 2022 湘ICP备2022001581号-3