MoviePy接收SIGINT/SIGTERM触发Broken Pipe Error如何解决？

BrokenPipe错误的触发有两个核心原因：

1. SIGINT、SIGTERM信号会广播给整个进程组，MoviePy内部调用的FFmpeg子进程会和主进程同时收到信号并提前终止，导致主进程往FFmpeg标准输入写入帧的管道断裂。
2. 现有信号处理逻辑仅简单阻塞主线程，既没有阻止信号传递给FFmpeg子进程，也没有正确感知写入线程的执行状态。

1. 隔离FFmpeg子进程的信号接收 #

调用write_videofile时传入preexec_fn参数，让FFmpeg子进程归属独立进程组，避免接收主进程的信号：

import os

video_file_name = '{}/{}'.format(tempfile.mkdtemp(), 'somefile.mp4')
clip.write_videofile(
    video_file_name, 
    audio = False, 
    threads =4,
    logger = None,
    preexec_fn = os.setpgrp
)

2. 优化信号处理逻辑 #

用线程等待替代固定时长sleep，确保写入线程执行完成后再退出程序。首先在代码中初始化事件标记和写入线程引用：

import threading

self.stop_event = threading.Event()
self.write_thread = None

启动写入线程时保存线程实例：

self.write_thread = threading.Thread(target=你的视频写入函数)
self.write_thread.start()

修改信号处理函数实现：

import signal
import os

signal.signal(signal.SIGINT, self.exit_gracefully)
signal.signal(signal.SIGTERM, self.exit_gracefully)

def exit_gracefully(self, signum, frame):
    self.stop_event.set()
    # 等待写入线程执行完成
    if self.write_thread and self.write_thread.is_alive():
        self.write_thread.join()
    os._exit(0)

3. 异常兜底 #

在写入逻辑外层加异常捕获，避免偶发异常导致线程意外终止：

def 你的视频写入函数():
    try:
        # 原有write_videofile调用逻辑
        clip.write_videofile(...)
    except OSError as e:
        if e.errno == 32:
            # 验证视频文件有效则忽略该错误
            if os.path.exists(video_file_name) and os.path.getsize(video_file_name) > 1024:
                pass

内容的提问来源于stack exchange，提问作者Pablo Estrada