都知道django每次請求都會連線資料庫和釋放資料庫連線。django為每個請求使用新的資料庫連線。一開始這個方法行得通。然而隨著伺服器上的負載的增加,建立/銷毀連線資料庫開始花大量的時間。要避免這個,你可以使用資料庫連線池,這裡使用sqlalchemy的連線池。使django持久化資料庫連線。
但這種方法會改變django的**。對框架有侵入
方法 1
實現方法如下:
把django/db/backends/mysql資料夾全部拷貝出來,放在專案的乙個libs/mysql下面,然後修改base.py檔案。
或者把django/db/backends/mysql資料夾在django/db/backends/下面複製為mysql_pool資料夾,將base.py中所以import中的mysql替換為mysql_pool,這樣可以直接在settings.py中設定'engine':'django.db.backends.mysql_pool'
找到try:
import mysqldb as databas程式設計客棧e
except importerror as e:
from django.core.exceptions import improperlyconfigured
raise improperlyconfigured("error loading mysqldb module: %s" % e)
這段**,在下面新增:
from sqlalchemy import pool
database = pool.manage(database[,recycle=databas
#其中database_wait_timeout為你定義的連線超時時間,必須小於等於mysql裡面的wait_timeout()
結果如下
try:
import mysqldb as database
except importerror as e:
from django.core.exceptions import improperlyconfigured
raise improperlyconfigured("error loading mysqldb module: %s" % e)
from sqlalchemy import pool
database = pool.manage(database)
然後找到get_connection_params(self)函式**:
def get_connection_params(self):
kwargs =
...修改為:
def get_connection_params(self):
kwargs =
...注意:如果不改變此處的kwargs,將會出現:typeerror:unhashable type:'dict' 的錯誤。
原樣用kwargs傳的話,sqlalchemy的pool會報unhashable錯誤,那是因為kwargs中有個key(conv)對應的value(django_conversions)是個字典,在pool中會把(key,value)組成元組作為新的key儲存在pool中,但是因為value(django_conversions)是dict,不允許作為key的
在mysql裡使用 show status 或 show processlist檢視連線情況
方法 2
直接在settings.py同級目錄下的init.py檔案中新增如下**
from django.conf import settings
from django.db.utils import load_backend
import sqlalc程式設計客棧hemy.pool as pool
import logging
pool_initialized=false
def init_pool():
if not globals().get('pool_initialized', false):
global pool_initialized
pool_initialized = true
try:
backendname = settings.databases['default']['engine']
backend = load_backend(backendname)
#replace the database object with a proxy.
backend.database = pool.manage(backend.database)
backend.databaseerror = backend.database.databaseerror
backend.integrityerror = backend.database.integrityerror
logging.info("connect pool initialized")
except:
logging.exception("connection pool initialization error")
init_pool()
然後修改django/db/backends/mysql/base.py檔案
找到get_connection_params(self)函式**:
修改為:
def get_connection_params(self):
kwargs =
...同理,不修改kwargs將會出現:typeerror:unhashable type:'dict' 的錯誤。
以上兩種方法都要改變django的**,有一定入侵性,第二種方法改變要小一點
django 1.7
python 2.7
sqlalchemy 1.0
本文標題: 用sqlalchemy構建django連線池的例項
本文位址:
使用SQLAlchemy來構建表
from datetime import datetime from flask sqlalchemy import sqlalchemy from sqlalchemy.dialects.mysql import tinyint,bigint,varchar,char,datetime,integ...
用mod wsgi在Apache上部署Django
1.安裝和配置apache 2.安裝mod wsgi 1 解壓縮 sudo tar xvf mod wsgi 3.4.tar.gz 2 配置mod wsgi cd mod wsgi 3.4 configure enable shared with apxs usr server apache2 bi...
用mod wsgi在apache中使用django
利用 mod wsgi和apache來部署django現在比較流行,也被認為是最好的方式。django框架,python,apache2這些 以及 dev 的安裝配置都是基本的,這裡就不說了。mod wsgi支援任何滿足python wsgi介面的apache模組。你要做的第一件事情就是安裝mod ...