पाइथन थ्रेड

Question

पर mysql कनेक्शन पास करते समय टूटी हुई पाइप प्राप्त करना मैं अजगर में एक थ्रेड से एक MySQL कनेक्शन पास करने का प्रयास कर रहा हूं। यदि मैं कार्यकर्ता वर्ग के अंदर mysql का प्रारंभिकरण करता हूं, तो कोई त्रुटि नहीं है।

हालांकि, यह कनेक्शन तो मैं बस फोन करने वाले समारोह से mysql कनेक्शन गुजर कोशिश के लिए महंगा हो सकता है (नीचे दिए गए कोड को देखें)। लेकिन यह इस त्रुटि को फेंकता रहता है:

(2006, "MySQL server has gone away (BrokenPipeError(32, 'Broken pipe'))

कोई विचार क्यों? मुझे लगता है कि इसकी वजह से जिस तरह से हम mysql संबंध में उत्तीर्ण होने की

इसके बजाय mysql कनेक्शन

def worker(db): 
""" Distributes the workload for a thread 
""" 
while True: 
    item = queue_handler.get() 
    perform_insert(item, db) 
    queue_handler.task_done() 

def insert_bulk(params): 
""" Handles the insert 
""" 
    cntr = 0 
    res = [] 
    cannot_read = [] 
    (data, cms, report_id) = params 

    db = nmi_mysql.DB(CONFIG['earnings_db'], True) 

    for i in range(10): 
     thrd = threading.Thread(target=worker, args=(db,)) 
     thrd.deamon = True 
     thrd.start() 

    for row in data: 
     split_files = row.split(',') 

     if len(split_files) != 34: 
      cannot_read.append(split_files) 
      continue 

     now = datetime.datetime.now() 

     res.append(<some data to insert>) 

     if len(res) == 750 or cntr == len(data): 
      queue_handler.put([res, cms, report_id]) 
      res = [] 

     cntr += 1 

    queue_handler.join() 

    db.close() 

    return [len(res), cms] 

अद्यतन गुजरती हैं, हम एक कनेक्शन पूल बनाया है और धागे में है कि पूल का उपयोग करें। इस तरह, हम थ्रेड स्तर पर पूल से कनेक्शन प्राप्त करते हैं।

Answer 1

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

यह related answer डेटाबेस कनेक्शन की थ्रेड सुरक्षा पर कुछ उपयोगी लिंक है।