पायथन: मानचित्र और मल्टीप्रोसेसिंग का उपयोग

Question

मैं एक ऐसा फ़ंक्शन लिखने की कोशिश कर रहा हूं जो दो तर्क ले सकता है और फिर इसे multiprocessing.Pool पर जोड़ सकता है और इसे समानांतर करता है। जब मैंने इस सरल कार्य को लिखने की कोशिश की तो मुझे कुछ जटिलताएं थीं।

df = pd.DataFrame() 
df['ind'] = [111, 222, 333, 444, 555, 666, 777, 888] 
df['ind1'] = [111, 444, 222, 555, 777, 333, 666, 777] 

def mult(elem1, elem2): 
    return elem1 * elem2 

if __name__ == '__main__': 
    pool = Pool(processes=4) 
    print(pool.map(mult, df.ind.astype(int).values.tolist(), df.ind1.astype(int).values.tolist())) 
    pool.terminate() 

यह एक त्रुटि लौटा रहा है:

TypeError: unsupported operand type(s) for //: 'int' and 'list' 

मैं नहीं समझ सकता कि क्या गलत है। क्या कोई यह समझा सकता है कि इस त्रुटि का अर्थ क्या है और मैं इसे कैसे ठीक कर सकता हूं?

Answer 1

बहु-प्रक्रिया पूल मॉड्यूल उन तर्कों की एक सूची में लेता है जिन्हें आप बहु-प्रक्रिया करना चाहते हैं, और केवल एक तर्क लेने में सहायता करता है। आप निम्न कार्य करके इसे ठीक कर सकते हैं:

from multiprocessing import Pool 
import pandas as pd 

df = pd.DataFrame() 
df['ind'] = [111, 222, 333, 444, 555, 666, 777, 888] 
df['ind1'] = [111, 444, 222, 555, 777, 333, 666, 777] 

def mult(elements): 
    elem1,elem2 = elements 
    return elem1 * elem2 

if __name__ == '__main__': 
    pool = Pool(processes=4) 
    inputs = zip(df.ind.astype(int).values.tolist(), df.ind1.astype(int).values.tolist()) 
    print(pool.map(mult, inputs)) 
    pool.terminate() 

मैं यहाँ क्या किया है प्रत्येक तत्व दो तर्क है कि आप इनपुट करना चाहता था होने के साथ एक सूची में अपने दो iterables ज़िप है। अब, मैं उन तर्कों को अनपैक करने के लिए आपके फ़ंक्शन का इनपुट बदलता हूं ताकि उन्हें संसाधित किया जा सके।