Предположим, у меня есть pandas df с 2 столбцами, содержащими URL.Я хотел бы добавить 2 дополнительных столбца, где я извлекаю их содержимое.
col1 | col2
url url
url url
url url
Поскольку эта задача требует много серверов, я хотел бы выполнить эту задачу в 2 отдельных потоках, по одному для каждого столбца, так:
df['col1_content'] = df['col1_content'].apply(getcontent) #on thread 1
df['col2_content'] = df['col2_content'].apply(getcontent) #on thread 2
Как я могувыполнить эту задачу, имея 2 потока записи и чтения из моего dataframe?Куда бы мне добавить threading.lock.acquire()
и .release