Добавление значения в пандас-фрейм данных с помощью многопроцессорной обработки - PullRequest
0 голосов
/ 02 мая 2018
import pandas as pd
import numpy as np
import multiprocessing
d = {'col1': [1, 2], 'col2': [3, 4]}
df = pandas.DataFrame(data = d)
list = [(0,3,1,5), ...]
def function(x):
    df.loc[x[0],"col1"] = x[1]
    df.loc[x[2],"col2"] = x[3]
pool = multiprocessing.Pool()
pool.map(function, list)
df.to_csv("tset.csv")

Наконец, выходные данные кадра данных пусты. Я знаю, что для словаря мы можем использовать multiprocessing.Manager (). Dict для совместного использования памяти. Но это не может быть применено к пандам. Есть ли простой способ поместить фрейм данных в разделяемую память?

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