实时读取多个日志文件

import threading

def read_log_file(file_path):
    with open(file_path, 'r') as file:
        while True:
            line = file.readline()
            if not line:
                continue
            # 处理日志行
            process_log_line(line)

log_files = ['log1.txt', 'log2.txt', 'log3.txt']
threads = []

for file in log_files:
    thread = threading.Thread(target=read_log_file, args=(file,))
    thread.start()
    threads.append(thread)

for thread in threads:
    thread.join()

import fcntl

def read_log_file(file_path):
    with open(file_path, 'r') as file:
        fcntl.flock(file, fcntl.LOCK_SH)
        while True:
            line = file.readline()
            if not line:
                continue
            # 处理日志行
            process_log_line(line)
        fcntl.flock(file, fcntl.LOCK_UN)

# 其他代码保持不变

import re

def process_log_line(line):
    if re.match(r'^\d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}', line):
        # 处理一种格式的日志
        pass
    elif re.match(r'^\[ERROR\]', line):
        # 处理另一种格式的日志
        pass
    else:
        # 处理未知格式的日志
        pass

# 其他代码保持不变