| 18 | |
| 19 | |
| 20 | class StreamToLogger: |
| 21 | def __init__(self, logger, log_level): |
| 22 | self.logger = logger |
| 23 | self.log_level = log_level |
| 24 | self.linebuf = "" |
| 25 | |
| 26 | def write(self, buf): |
| 27 | for line in buf.rstrip().splitlines(): |
| 28 | self.logger.log(self.log_level, line.rstrip()) |
| 29 | |
| 30 | def flush(self): |
| 31 | pass |
| 32 | |
| 33 | |
| 34 | def setup_logger(): |