日志处理器，用于将日志消息发送到 LogBroker。
| 148 | |
| 149 | |
| 150 | class LogQueueHandler(logging.Handler): |
| 151 | """日志处理器，用于将日志消息发送到 LogBroker。""" |
| 152 | |
| 153 | def __init__(self, log_broker: LogBroker) -> None: |
| 154 | super().__init__() |
| 155 | self.log_broker = log_broker |
| 156 | |
| 157 | def emit(self, record: logging.LogRecord) -> None: |
| 158 | log_entry = self.format(record) |
| 159 | self.log_broker.publish( |
| 160 | { |
| 161 | "level": record.levelname, |
| 162 | "time": time.time(), |
| 163 | "data": log_entry, |
| 164 | }, |
| 165 | ) |
| 166 | |
| 167 | |
| 168 | class LogManager: |