用sqlalchemy構(gòu)建Django連接池的實(shí)例
都知道django每次請求都會(huì)連接數(shù)據(jù)庫和釋放數(shù)據(jù)庫連接。Django為每個(gè)請求使用新的數(shù)據(jù)庫連接。一開始這個(gè)方法行得通。然而隨著服務(wù)器上的負(fù)載的增加,創(chuàng)建/銷毀連接數(shù)據(jù)庫開始花大量的時(shí)間。要避免這個(gè),你可以使用數(shù)據(jù)庫連接池,這里使用SQLAlchemy的連接池。使Django持久化數(shù)據(jù)庫連接。
但這種方法會(huì)改變django的代碼。對框架有侵入
方法 1
實(shí)現(xiàn)方法如下:
把django/db/backends/mysql文件夾全部拷貝出來,放在項(xiàng)目的一個(gè)libs/mysql下面,然后修改base.py文件。
或者把django/db/backends/mysql文件夾在django/db/backends/下面復(fù)制為mysql_pool文件夾,將base.py中所以import中的mysql替換為mysql_pool,這樣可以直接在settings.py中設(shè)置'ENGINE':'django.db.backends.mysql_pool'
找到
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[,recycle=DATABASE_WAIT_TIMEOUT-1]) #其中DATABASE_WAIT_TIMEOUT為你定義的連接超時(shí)時(shí)間,必須小于等于mysql里面的wait_timeout()
結(jié)果如下
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)函數(shù)代碼:
def get_connection_params(self): kwargs = { 'conv':django_conversions, 'charset':utf8 } ...
修改為:
def get_connection_params(self): kwargs = { 'charset':utf8 } ...
注意:如果不改變此處的kwargs,將會(huì)出現(xiàn):TypeError:unhashable type:'dict' 的錯(cuò)誤。
原樣用kwargs傳的話,sqlalchemy的pool會(huì)報(bào)unhashable錯(cuò)誤,那是因?yàn)閗wargs中有個(gè)key(conv)對應(yīng)的value(django_conversions)是個(gè)字典,在pool中會(huì)把(key,value)組成元組作為新的key保存在pool中,但是因?yàn)関alue(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 sqlalchemy.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("Connection Pool initialized") except: logging.exception("Connection Pool initialization error") init_pool()
然后修改django/db/backends/mysql/base.py文件
找到get_connection_params(self)函數(shù)代碼:
修改為:
def get_connection_params(self): kwargs = { 'charset':utf8 } ...
同理,不修改kwargs將會(huì)出現(xiàn):TypeError:unhashable type:'dict' 的錯(cuò)誤。
以上兩種方法都要改變django的代碼,有一定入侵性,第二種方法改變要小一點(diǎn)
django 1.7
python 2.7
sqlalchemy 1.0
這篇用sqlalchemy構(gòu)建Django連接池的實(shí)例就是小編分享給大家的全部內(nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
Numpy創(chuàng)建數(shù)組和隨機(jī)數(shù)組的方法小結(jié)
這篇文章主要為大家詳細(xì)介紹了Numpy創(chuàng)建數(shù)組和隨機(jī)數(shù)組的方法小結(jié),文中的示例代碼講解詳細(xì),對我們學(xué)習(xí)Python有一定幫助,具有一定的參考價(jià)值,需要的可以參考一下2023-11-11python數(shù)據(jù)結(jié)構(gòu)之鏈表詳解
這篇文章主要為大家詳細(xì)介紹了python數(shù)據(jù)結(jié)構(gòu)之鏈表的相關(guān)資料,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-09-09matplotlib部件之矩形選區(qū)(RectangleSelector)的實(shí)現(xiàn)
這篇文章主要介紹了matplotlib部件之矩形選區(qū)(RectangleSelector)的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2021-02-02關(guān)于tf.TFRecordReader()函數(shù)的用法解析
今天小編就為大家分享一篇關(guān)于tf.TFRecordReader()函數(shù)的用法解析,具有很好的參考價(jià)值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-02-02python連接FTP服務(wù)器的實(shí)現(xiàn)方法
本文主要介紹了python連接FTP服務(wù)器的實(shí)現(xiàn)方法,主要使用ftp操作進(jìn)行連接FTP服務(wù)器、獲取當(dāng)前目錄文件清單、上傳文件等操作,具有一定的參考價(jià)值,感興趣的可以了解一下2022-06-06Python實(shí)現(xiàn)SSH遠(yuǎn)程登陸,并執(zhí)行命令的方法(分享)
下面小編就為大家?guī)硪黄狿ython實(shí)現(xiàn)SSH遠(yuǎn)程登陸,并執(zhí)行命令的方法(分享)。小編覺得挺不錯(cuò)的,現(xiàn)在就分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2017-05-05python 實(shí)現(xiàn)的車牌識(shí)別項(xiàng)目
這篇文章主要介紹了python 實(shí)現(xiàn)的車牌識(shí)別項(xiàng)目,幫助大家更好的理解和使用python,感興趣的朋友可以了解下2021-01-01pycharm通過ssh連接遠(yuǎn)程服務(wù)器教程
今天小編就為大家分享一篇pycharm通過ssh連接遠(yuǎn)程服務(wù)器教程,具有很好的參考價(jià)值,希望對大家有所幫助。一起跟隨小編過來看看吧2020-02-02