| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- import argparse
- import logging
- import glob
- import os
- from tqdm import tqdm
- logger = logging.getLogger()
- def main():
- wavs = list(glob.glob('{}/*/*/*wav'.format(args.src_dir)))
- utt2wav, utt2text, utt2spk, spk2utt = {}, {}, {}, {}
- for wav in tqdm(wavs):
- txt = wav.replace('.wav', '.normalized.txt')
- if not os.path.exists(txt):
- logger.warning('{} do not exsist'.format(txt))
- continue
- with open(txt) as f:
- content = ''.join(l.replace('\n', '') for l in f.readline())
- utt = os.path.basename(wav).replace('.wav', '')
- spk = utt.split('_')[0]
- utt2wav[utt] = wav
- utt2text[utt] = content
- utt2spk[utt] = spk
- if spk not in spk2utt:
- spk2utt[spk] = []
- spk2utt[spk].append(utt)
- with open('{}/wav.scp'.format(args.des_dir), 'w') as f:
- for k, v in utt2wav.items():
- f.write('{} {}\n'.format(k, v))
- with open('{}/text'.format(args.des_dir), 'w') as f:
- for k, v in utt2text.items():
- f.write('{} {}\n'.format(k, v))
- with open('{}/utt2spk'.format(args.des_dir), 'w') as f:
- for k, v in utt2spk.items():
- f.write('{} {}\n'.format(k, v))
- with open('{}/spk2utt'.format(args.des_dir), 'w') as f:
- for k, v in spk2utt.items():
- f.write('{} {}\n'.format(k, ' '.join(v)))
- return
- if __name__ == "__main__":
- parser = argparse.ArgumentParser()
- parser.add_argument('--src_dir',
- type=str)
- parser.add_argument('--des_dir',
- type=str)
- parser.add_argument('--ref_model',
- type=str)
- args = parser.parse_args()
- main()
|