使用数据库连接处理多线程

问题描述

为了提高性能，我尝试一次处理多条记录，因此首选多线程。每个线程都涉及数据库连接，我收到类似 pyMysqL.err.InternalError: Packet sequence number wrong - got 48 expected 1

之类的错误

我在这里附上了我的代码示例。任何建议或真实答案都会有所帮助

        items = items_array
        if(items):
            print(items);
            listofProcesses = []
            number_of_items = len(items)
            processors = 20 # n of processors you want to use
            parts = [items[i:i + processors] for i in range(0,len(items),processors)]

            for part in parts:
                for f in part:
                    p = Process(target=self.parallel_print,args=(f,))
                    p.start()
                    listofProcesses.append(p)
                for p in listofProcesses:
                    p.join()

def parallel_print(self,item_code):
    frappe.get_doc("Item",item_code)

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）