Я пишу кусок кода для параллельного редактирования данных, но не могу передать данные подфункции. Я использую ноутбук Jupyter.
Ниже приведен простой код.
%%writefile workers.py
import requests
import pandas as pd
global data
def geocode(i):
global data
city = data.loc[i,"city"]
base = 'https://.xxx.com/' + city
response = requests.get(base, parameters, timeout=1)
data.loc[i,'data'] = response.json()
from multiprocessing import Pool
import workers
import pandas as pd
global data
if __name__ == '__main__':
global data
data = pd.read_csv('D:data.csv')
num_processors = 40
p=Pool(processes = num_processors)
output = p.map(workers.geocode,[i for i in range(0,len(data))])