保存.wav文件时出现随机系统错误

Question

我有一个脚本，可以加载、重新采样、重命名音频数据并将其保存到新的（或相同的）位置

在过去的两天里，我一直在尝试在谷歌云上运行这个脚本。对于8CPU，此操作大约需要8小时。我今天花了6个小时，结果变成了梨形

不幸的是，我在过程中的某个随机点不断遇到系统错误：

RemoteTraceback: 
"""
Traceback (most recent call last):
  File "/opt/conda/lib/python3.7/multiprocessing/pool.py", line 121, in worker
    result = (True, func(*args, **kwds))
  File "/opt/conda/lib/python3.7/multiprocessing/pool.py", line 47, in starmapstar
    return list(itertools.starmap(args[0], args[1]))
  File "/home/jupyter/jn-kaggle/birdsong/who-said-what/wsw/preprocessing.py", line 27, in write_audio
    with sf.SoundFile(path, 'w', sr, channels=1, format='WAV') as f:
  File "/opt/conda/lib/python3.7/site-packages/soundfile.py", line 629, in __init__
    self._file = self._open(file, mode_int, closefd)
  File "/opt/conda/lib/python3.7/site-packages/soundfile.py", line 1184, in _open
    "Error opening {0!r}: ".format(self.name))
  File "/opt/conda/lib/python3.7/site-packages/soundfile.py", line 1357, in _error_check
    raise RuntimeError(prefix + _ffi.string(err_str).decode('utf-8', 'replace'))
RuntimeError: Error opening '/home/jupyter/jn-kaggle/birdsong/data/resampled/solsan/XC448920.wav': System error.
"""

现在，我读到这个系统错误通常是因为文件路径不存在。但是，由于我在尝试打开文件之前创建了该文件，我认为这是不可能的：

    os.makedirs(os.path.dirname(path), exist_ok=True)
    with sf.SoundFile(path, 'w', sr, channels=1, format=format) as f:
        f.write(audio)

因此，我不认为这是一个错误的路径问题，因为它是定义和创建的

以下是完整的脚本：

def resample_all(old_path, new_path, sr):
 # Get every folder in a directory
 folders = [d for d in os.scandir(old_path) if os.path.isdir(d.path)]
    n_folders = len(folders)
     
    # for each folder, get each file 
    for i, folder in enumerate(folders):
        dirname = folder.name
        
        # get every file from  
        files = [f.name for f in os.scandir(folder) if os.path.isfile(f.path)]

        # rename name file with .wav extension
        renamed = map(rename, files)
        
        # get original path of every file
        r_paths = [f.path for f in os.scandir(folder)]

        # get path to write to for every file.
        w_paths = [os.path.join(new_path, dirname, f) for f in renamed]

        
        with Pool(os.cpu_count()) as p:
            # resample audio
            data = p.starmap(read_audio, zip(r_paths, [sr] * len(r_paths)))
            # save audio
            aud, srs = zip(*data)
            p.starmap(write_audio, zip(w_paths, aud, srs))

传递给multiprocessing.Pool的三个助手函数是：

def read_audio(file_path, sr=22050):
    with warnings.catch_warnings():
        warnings.simplefilter("ignore", UserWarning)
        return librosa.load(file_path, sr=sr)

def write_audio(path, audio, sr, format='WAV'):
    os.makedirs(os.path.dirname(path), exist_ok=True)
    with sf.SoundFile(path, 'w', sr, channels=1, format=format) as f:
        f.write(audio)

def rename(file_path, ext='.wav'):
    return os.path.splitext(file_path)[0] + ext