Python django使用多進(jìn)程連接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)體中生成了子進(jìn)程，子進(jìn)程中也有mysql查詢。

我測試了下不實用多進(jìn)程的情況沒有問題，使用多進(jìn)程就會出現(xiàn)這個問題。

對照上面的文檔，其實不難想到，錯誤應(yīng)該是這樣的

1. 父進(jìn)程和mysql建立的連接A，循環(huán)中fork出一個子進(jìn)程
2. 子進(jìn)程保持了父進(jìn)程的變量，也就是擁有mysql連接A
3. 子進(jìn)程去用連接A查詢mysql，父進(jìn)程這個時候也并發(fā)的使用連接A訪問mysql
4. 這樣很容易出現(xiàn)了上面Mysql提到的情況，結(jié)果就報錯了

解決

解決的方案其實很容易想到，就是當(dāng)我們fork一個進(jìn)程之后，讓他從新獲取一個和mysql的連接C或者D就好了嘛，
結(jié)果幾個測試，得到如下的方案。

在父進(jìn)程的loop中，創(chuàng)建子進(jìn)程之前關(guān)閉mysql連接，這樣子進(jìn)程中就會重新連接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也不對.

后面做了個測試 ，多進(jìn)程的情況下查看mysql processlist，的確使用建立多個mysql 連接。

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持億速云。