logger.py 文件源码

def flush_queue(self):
        # check number of messages in queue
        num_log_entries = self.log_queue.qsize()

        if num_log_entries > 0:

            # open the log file
            with open(self.log_full_filename, 'ab') as log_file:

                for i in range(num_log_entries):
                    log_entry = self.log_queue.get()

                    # append extra log information
                    current_time = log_entry['time']
                    current_time_str = time.asctime(time.localtime(current_time))
                    log_entry['localtime'] = current_time_str

                    # log the message as a JSON string
                    if isPython3:
                        log_file.write(bytes(json.dumps(log_entry) + "\n", 'UTF-8'))
                    else:
                        log_file.write(json.dumps(log_entry) + "\n")