Уважаемые коллеги, назрел вопрос!
Есть код
Если коротко, то получаю в пандас большой датафрейм, извлекаю из него все уникальные значения из одного столбца и потом многопоточно извлекаю из этого датафрейма данные с сохранением в файл. Вот псевдо код.
import pandas
import multiprocessing
def function_name(index):
global result
делаю выборку из result
if name == '__main__':
result = pandas.DataFrame...
list_index = result.Field.unique()
pool = multiprocessing.Pool(count_of_processes)
for res in pool.imap(function_name, list_index, 1):
pass