打开各种csv文件，通过multiprocessing处理然后保存?

Question

我是多处理新手。这里我只是尝试打开多个csv文件，然后再次通过多处理保存它们。

def opening_file(x):
print(x)
url = 'D:\Tanmay\Market\Data\Processed GFDL_options\Bank Nifty\Intraday\'
d = pd.read_csv(url+x)
d.to_csv('D:\Tanmay\trial\'+x)
all_files = os.listdir('D:\Tanmay\Market\Data\Processed GFDL_options\Bank Nifty\Intraday\')
processes = []
for i in all_files:

p = multiprocessing.Process(target=opening_file(i),args=(i,))
pid = os.getpid()
print(pid)
p.start()
processes.append(p)


for y in processes:
y.join()

这里的问题是，我只得到一个进程id，这意味着只有一个进程正在运行。请协助

Answer 1

你应该传递一个函数给multiprocessing.Process，而不是它的结果:

p = multiprocessing.Process(target=opening_file, args=(i,))