forked from OlaWod/FreeVC
-
Notifications
You must be signed in to change notification settings - Fork 0
/
downsample.py
55 lines (48 loc) · 2.16 KB
/
downsample.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
import os
import argparse
import librosa
import numpy as np
from multiprocessing import Pool, cpu_count
from scipy.io import wavfile
from tqdm import tqdm
def process(wav_name):
# speaker 's5', 'p280', 'p315' are excluded,
speaker = wav_name[:4]
wav_path = os.path.join(args.in_dir, speaker, wav_name)
if os.path.exists(wav_path) and '_mic2.flac' in wav_path:
os.makedirs(os.path.join(args.out_dir1, speaker), exist_ok=True)
os.makedirs(os.path.join(args.out_dir2, speaker), exist_ok=True)
wav, sr = librosa.load(wav_path)
wav, _ = librosa.effects.trim(wav, top_db=20)
peak = np.abs(wav).max()
if peak > 1.0:
wav = 0.98 * wav / peak
wav1 = librosa.resample(wav, orig_sr=sr, target_sr=args.sr1)
wav2 = librosa.resample(wav, orig_sr=sr, target_sr=args.sr2)
save_name = wav_name.replace("_mic2.flac", ".wav")
save_path1 = os.path.join(args.out_dir1, speaker, save_name)
save_path2 = os.path.join(args.out_dir2, speaker, save_name)
wavfile.write(
save_path1,
args.sr1,
(wav1 * np.iinfo(np.int16).max).astype(np.int16)
)
wavfile.write(
save_path2,
args.sr2,
(wav2 * np.iinfo(np.int16).max).astype(np.int16)
)
if __name__ == "__main__":
parser = argparse.ArgumentParser()
parser.add_argument("--sr1", type=int, default=16000, help="sampling rate")
parser.add_argument("--sr2", type=int, default=22050, help="sampling rate")
parser.add_argument("--in_dir", type=str, default="/home/Datasets/lijingyi/data/vctk/wav48_silence_trimmed/", help="path to source dir")
parser.add_argument("--out_dir1", type=str, default="./dataset/vctk-16k", help="path to target dir")
parser.add_argument("--out_dir2", type=str, default="./dataset/vctk-22k", help="path to target dir")
args = parser.parse_args()
pool = Pool(processes=cpu_count()-2)
for speaker in os.listdir(args.in_dir):
spk_dir = os.path.join(args.in_dir, speaker)
if os.path.isdir(spk_dir):
for _ in tqdm(pool.imap_unordered(process, os.listdir(spk_dir))):
pass