Создание словаря с многопроцессорностью - PullRequest
0 голосов
/ 05 октября 2018

Я пытаюсь сделать словарь с фреймом данных в качестве значений, используя многопроцессорный модуль.Я использую инструкцию, которая была предоставлена ​​ здесь .Тем не менее, он выводит пустой словарь.Любая помощь высоко ценится.

def parallel_main(summary_res_all_type,st,df_x,df_y,max_number):
   res_all 
   =modified_mlr.do_mlr(df_x,df_y,soil_type=st,max_namber=max_number)    
   summary_res_all_type[st]=pd.DataFrame(index=pars_keys_all,columns=[st] )
   summary_res_all_type[st]=res_all['dict_cor_par'].values()

if __name__ == '__main__':
   manager = Manager() 
   summary_res_all_type = manager.dict() 
   job = [Process(target=parallel_main, args=(summary_res_all_type, 
   i,df_x,df_y,max_number))  for i in set(df_x["soil_type"])] 
   _ = [p.start() for p in job]
   _ = [p.join() for p in job]
   print(summary_res_all_type)

1 Ответ

0 голосов
/ 06 октября 2018

Вот снимок в темноте, но следующая строка:

res_all = modified_mlr.do_mlr(df_x,df_y,soil_type=st,max_namber=max_number)

выглядит так, как будто он содержит опечатку max_namber=max_number.Это приведет к сбою всех процессов со скрытыми исключениями.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...