Python django使用多進程連接mysql錯誤的解決方法
問題
mysql 查詢出現(xiàn)錯誤
error: (2014, "Commands out of sync; you can't run this command now")1
查詢
mysql文檔中的解釋
If you get Commands out of sync; you can't run this command now in your client code, you are calling client functions in the wrong order.
This can happen, for example, if you are using mysql_use_result() and try to execute a new query before you have called mysql_free_result(). It can also happen if you try to execute two queries that return data without calling mysql_use_result() or mysql_store_result() in between.
調(diào)用順序錯誤,同一個連接,發(fā)出2個查詢請求,第一個請求發(fā)出之后沒有等到mysql返回就發(fā)出第二個請求
背景 思考
我這里的程序是這樣的,在django框架中起了一個定時任務(wù),這個任務(wù)中有個循環(huán),主線程循環(huán)查詢mysql然后在循環(huán)體中生成了子進程,子進程中也有mysql查詢。
我測試了下不實用多進程的情況沒有問題,使用多進程就會出現(xiàn)這個問題。
對照上面的文檔,其實不難想到,錯誤應該是這樣的
- 父進程和mysql建立的連接A,循環(huán)中fork出一個子進程
- 子進程保持了父進程的變量,也就是擁有mysql連接A
- 子進程去用連接A查詢mysql,父進程這個時候也并發(fā)的使用連接A訪問mysql
- 這樣很容易出現(xiàn)了上面Mysql提到的情況,結(jié)果就報錯了

解決
解決的方案其實很容易想到,就是當我們fork一個進程之后,讓他從新獲取一個和mysql的連接C或者D就好了嘛,
結(jié)果幾個測試,得到如下的方案。
在父進程的loop中,創(chuàng)建子進程之前關(guān)閉mysql連接,這樣子進程中就會重新連接mysql。
from django import db db.close_connection() p = Process(target=ap5mintes_scan, args=(ac, details, mtime)) p.start()
其實就是狀態(tài)copy的問題,本來多個線程同時并發(fā)調(diào)用一個connection也不對.
后面做了個測試 ,多進程的情況下查看mysql processlist,的確使用建立多個mysql 連接。
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Python數(shù)據(jù)類型之Number數(shù)字操作實例詳解
這篇文章主要介紹了Python數(shù)據(jù)類型之Number數(shù)字操作,結(jié)合實例形式詳細分析了Python數(shù)字類型的概念、功能、分類及常用數(shù)學函數(shù)相關(guān)使用技巧,需要的朋友可以參考下2019-05-05
使用XML庫的方式,實現(xiàn)RPC通信的方法(推薦)
下面小編就為大家?guī)硪黄褂肵ML庫的方式,實現(xiàn)RPC通信的方法(推薦)。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-06-06
三行代碼使用Python將視頻轉(zhuǎn)Gif的方法示例
本文主要介紹了三行代碼使用Python將視頻轉(zhuǎn)Gif的方法示例,文中通過示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2021-10-10

