Python django使用多程序連線mysql錯誤的解決方法
問題
mysql 查詢出現錯誤
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.
呼叫順序錯誤,同一個連線,發出2個查詢請求,第一個請求發出之後沒有等到mysql返回就發出第二個請求
背景 思考
我這裡的程式是這樣的,在django框架中起了一個定時任務,這個任務中有個迴圈,主執行緒迴圈查詢mysql然後在迴圈體中生成了子程序,子程序中也有mysql查詢。
我測試了下不實用多程序的情況沒有問題,使用多程序就會出現這個問題。
對照上面的文件,其實不難想到,錯誤應該是這樣的
- 父程序和mysql建立的連線A,迴圈中fork出一個子程序
- 子程序保持了父程序的變數,也就是擁有mysql連線A
- 子程序去用連線A查詢mysql,父程序這個時候也併發的使用連線A訪問mysql
- 這樣很容易出現了上面Mysql提到的情況,結果就報錯了
解決
解決的方案其實很容易想到,就是當我們fork一個程序之後,讓他從新獲取一個和mysql的連線C或者D就好了嘛,
結果幾個測試,得到如下的方案。
在父程序的loop中,建立子程序之前關閉mysql連線,這樣子程序中就會重新連線mysql。
from django import db db.close_connection() p = Process(target=ap5mintes_scan,args=(ac,details,mtime)) p.start()
其實就是狀態copy的問題,本來多個執行緒同時併發呼叫一個connection也不對.
後面做了個測試 ,多程序的情況下檢視mysql processlist,的確使用建立多個mysql 連線。
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。