用sqlalchemy構建Django連線池的例項

2022-09-26 12:21:26 字數 2921 閱讀 2641

都知道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 ...