1. 程式人生 > 資料庫 >Python django使用多程序連線mysql錯誤的解決方法

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查詢。

我測試了下不實用多程序的情況沒有問題,使用多程序就會出現這個問題。

對照上面的文件,其實不難想到,錯誤應該是這樣的

  1. 父程序和mysql建立的連線A,迴圈中fork出一個子程序
  2. 子程序保持了父程序的變數,也就是擁有mysql連線A
  3. 子程序去用連線A查詢mysql,父程序這個時候也併發的使用連線A訪問mysql
  4. 這樣很容易出現了上面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 連線。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支援我們。