embedded_monitor.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-
"""
内嵌文件监控脚本 - 用于打包环境
"""

import os
import time
import sys
import codecs
from pathlib import Path

def optimized_monitor(file_path, task_name):
    """高效的文件监控函数"""
    print(f"开始监控文件: {file_path}")
    print(f"任务名称: {task_name}")
    print("=" * 60)

    # 等待文件创建
    while not os.path.exists(file_path):
        print("等待文件创建...")
        time.sleep(1)
    
    print(f"文件已创建: {file_path}")

    try:
        decoder = codecs.getincrementaldecoder('utf-8')('ignore')
        with open(file_path, 'rb') as f:
            f.seek(0, os.SEEK_END)
            leftover = ''
            while True:
                chunk = f.read(65536)
                if chunk:
                    text = decoder.decode(chunk)
                    if text:
                        buf = leftover + text
                        lines = buf.splitlines(True)
                        if lines and not (lines[-1].endswith('\n') or lines[-1].endswith('\r')):
                            leftover = lines.pop()
                        else:
                            leftover = ''
                        for line in lines:
                            print(f"[{time.strftime('%H:%M:%S')}] {line.rstrip()}")
                        sys.stdout.flush()
                else:
                    time.sleep(0.05)
    except KeyboardInterrupt:
        print("\n监控已停止")
    except Exception as e:
        print(f"监控出错: {e}")
        time.sleep(1)

def main():
    """主函数 - 用于独立运行"""
    if len(sys.argv) != 3:
        print("用法: python embedded_monitor.py <文件路径> <任务名称>")
        sys.exit(1)
    
    file_path = sys.argv[1]
    task_name = sys.argv[2]
    
    try:
        optimized_monitor(file_path, task_name)
    except Exception as e:
        print(f"监控出错: {e}")

if __name__ == "__main__":
    main()