用sqlalchemy构建Django连接池的实例
都知道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:
importMySQLdbasDatabase
exceptImportErrorase:
fromdjango.core.exceptionsimportImproperlyConfigured
raiseImproperlyConfigured("ErrorloadingMySQLdbmodule:%s"%e)
这段代码，在下面添加：
fromsqlalchemyimportpool Database=pool.manage(Database[,recycle=DATABASE_WAIT_TIMEOUT-1]) #其中DATABASE_WAIT_TIMEOUT为你定义的连接超时时间，必须小于等于mysql里面的wait_timeout（）
结果如下
try:
importMySQLdbasDatabase
exceptImportErrorase:
fromdjango.core.exceptionsimportImproperlyConfigured
raiseImproperlyConfigured("ErrorloadingMySQLdbmodule:%s"%e)
fromsqlalchemyimportpool
Database=pool.manage(Database)
然后找到get_connection_params(self)函数代码：
defget_connection_params(self):
kwargs={
'conv':django_conversions,
'charset':utf8
}
...
修改为：
defget_connection_params(self):
kwargs={
'charset':utf8
}
...
注意：如果不改变此处的kwargs，将会出现：TypeError:unhashabletype:'dict'的错误。
原样用kwargs传的话，sqlalchemy的pool会报unhashable错误，那是因为kwargs中有个key（conv）对应的value（django_conversions）是个字典，在pool中会把（key,value）组成元组作为新的key保存在pool中，但是因为value（django_conversions）是dict，不允许作为key的
在mysql里使用showstatus或showprocesslist查看连接情况
方法2
直接在settings.py同级目录下的init.py文件中添加如下代码
fromdjango.confimportsettings
fromdjango.db.utilsimportload_backend
importsqlalchemy.poolaspool
importlogging
pool_initialized=False
definit_pool():
ifnotglobals().get('pool_initialized',False):
globalpool_initialized
pool_initialized=True
try:
backendname=settings.DATABASES['default']['ENGINE']
backend=load_backend(backendname)
#replacethedatabaseobjectwithaproxy.
backend.Database=pool.manage(backend.Database)
backend.DatabaseError=backend.Database.DatabaseError
backend.IntegrityError=backend.Database.IntegrityError
logging.info("ConnectionPoolinitialized")
except:
logging.exception("ConnectionPoolinitializationerror")
init_pool()
然后修改django/db/backends/mysql/base.py文件
找到get_connection_params(self)函数代码：
修改为：
defget_connection_params(self):
kwargs={
'charset':utf8
}
...
同理，不修改kwargs将会出现：TypeError:unhashabletype:'dict'的错误。
以上两种方法都要改变django的代码，有一定入侵性，第二种方法改变要小一点
django1.7
python2.7
sqlalchemy1.0
这篇用sqlalchemy构建Django连接池的实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。