import torch from multiprocessing import Pool import commons import utils from tqdm import tqdm from text import check_bert_models, cleaned_text_to_sequence, get_bert import argparse import torch.multiprocessing as mp from config import config def process_line(x): line, add_blank = x device = config.bert_gen_config.device if config.bert_gen_config.use_multi_device: rank = mp.current_process()._identity rank = rank[0] if len(rank) > 0 else 0 if torch.cuda.is_available(): gpu_id = rank % torch.cuda.device_count() device = torch.device(f"cuda:{gpu_id}") else: device = torch.device("cpu") wav_path, _, language_str, text, phones, tone, word2ph = line.strip().split("|") phone = phones.split(" ") tone = [int(i) for i in tone.split(" ")] word2ph = [int(i) for i in word2ph.split(" ")] word2ph = [i for i in word2ph] phone, tone, language = cleaned_text_to_sequence(phone, tone, language_str) if add_blank: phone = commons.intersperse(phone, 0) tone = commons.intersperse(tone, 0) language = commons.intersperse(language, 0) for i in range(len(word2ph)): word2ph[i] = word2ph[i] * 2 word2ph[0] += 1 bert_path = wav_path.replace(".WAV", ".wav").replace(".wav", ".bert.pt") try: bert = torch.load(bert_path) assert bert.shape[0] == 2048 except Exception: try: bert = get_bert(text, word2ph, language_str, device) assert bert.shape[-1] == len(phone) torch.save(bert, bert_path) except Exception as e: print(f"Error: {text=}") print(f"Error: {phone=}") print(f"Error: {tone=}") print(f"Error: {word2ph=}") print(f"Error: {language_str=}") print(f"Error: {device=}") print(f"Error: {add_blank=}") print(line.strip().split("|")) raise e preprocess_text_config = config.preprocess_text_config if __name__ == "__main__": parser = argparse.ArgumentParser() parser.add_argument( "-c", "--config", type=str, default=config.bert_gen_config.config_path ) parser.add_argument( "--num_processes", type=int, default=config.bert_gen_config.num_processes ) args, _ = parser.parse_known_args() config_path = args.config hps = utils.get_hparams_from_file(config_path) check_bert_models() lines = [] with open(hps.data.training_files, encoding="utf-8") as f: lines.extend(f.readlines()) with open(hps.data.validation_files, encoding="utf-8") as f: lines.extend(f.readlines()) add_blank = [hps.data.add_blank] * len(lines) if len(lines) != 0: num_processes = args.num_processes with Pool(processes=num_processes) as pool: for _ in tqdm( pool.imap_unordered(process_line, zip(lines, add_blank)), total=len(lines), ): # 这里是缩进的代码块,表示循环体 pass # 使用pass语句作为占位符 print(f"bert生成完毕!, 共有{len(lines)}个bert.pt生成!")