Python中如何通过tail -f监控文件变化并实时交给Python -c处理？

这个问题挺有意思，在Linux环境下想用tail -f和Python -c联动处理实时日志。直接管道传递是行不通的，因为tail -f会持续输出，而python -c执行完就退出了。

核心思路是让Python脚本自己来充当tail -f的角色，持续读取文件新增内容。用subprocess模块调用tail -f并捕获其标准输出流是最直接的办法。

给你一个即拿即用的代码示例：

import subprocess
import sys

def process_line(line):
    """在这里定义你的处理逻辑"""
    # 示例：打印行并添加前缀
    print(f"[处理]: {line}", end='')
    # 你可以在这里进行任何字符串处理、匹配、写入数据库等操作

def tail_and_process(filename):
    try:
        # 启动tail -f进程
        proc = subprocess.Popen(
            ['tail', '-f', filename],
            stdout=subprocess.PIPE,
            stderr=subprocess.PIPE,
            text=True,
            bufsize=1  # 行缓冲
        )
        
        print(f"开始监控文件: {filename}")
        print("按 Ctrl+C 停止")
        
        # 持续读取输出
        for line in proc.stdout:
            process_line(line)
            
    except KeyboardInterrupt:
        print("\n监控已停止")
    except FileNotFoundError:
        print(f"错误: 文件 '{filename}' 不存在或tail命令不可用")
    except Exception as e:
        print(f"发生错误: {e}")
    finally:
        if 'proc' in locals():
            proc.terminate()

if __name__ == "__main__":
    if len(sys.argv) != 2:
        print("用法: python script.py <filename>")
        sys.exit(1)
    
    tail_and_process(sys.argv[1])

如果你想用一行命令搞定，可以这样封装：

python -c "
import subprocess, sys
with subprocess.Popen(['tail', '-f', sys.argv[1]], stdout=subprocess.PIPE, text=True) as proc:
    for line in proc.stdout:
        print(f'[处理]: {line}', end='')
" your_logfile.log

不过说实话，这种复杂逻辑还是写成独立的.py文件更清晰。上面那个脚本保存为log_monitor.py，然后直接python log_monitor.py /path/to/logfile就行。

简单说就是别指望python -c能持续运行，得用脚本来循环读取。