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

如何解决保存.wav文件时出现随机系统错误

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

在过去的两天里，我一直试图在Google Cloud上运行此脚本。对于8个CPU，此操作大约需要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,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,format='WAV'):
    os.makedirs(os.path.dirname(path),format=format) as f:
        f.write(audio)

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