tornado ,sqlalchemy 怎么做数据库的读写分离

网站框架用的是 tornado ,与数据库的连接用的是 sqlalchemy,现在访问量有点大，加上有些查询语句效率不是很高，导致访问速度有点下降，现在想做读写分离来缓解下主数据库的压力。
之前的写法是在一次请求前建立一个 session,然后请求结束后结束这个 session ，那如果做读写分离是不是就要在一次请求时维护两个 session,一个负责读，一个负责写，请问大家有谁做过这个呢，有什么比较好的方法呢，请指点一下啊～～

Session

SQLAlchemy

Tornado

数据库

6 条回复 • 2016-03-07 14:06:12 +08:00

jixiangqd

2016-02-29 17:10:20 +08:00

mycat 、 oneproxy 可以试试这种对应用层透明的中间件。。。

MasterYoda

2016-02-29 20:35:16 +08:00

http://stackoverflow.com/questions/8947918/read-slave-read-write-master-setup
作者自己的答案。
他博客里还写过别的方法，判断 is_flush 的，在底层做读写分离。

wdg8106

2016-03-01 16:46:36 +08:00

@MasterYoda 太感谢了，困扰了好长时间，终于有解决思路了

wdg8106

2016-03-01 16:47:55 +08:00

@jixiangqd 只试过 mysql-proxy ，跟 sqlalchemy 结合使用效果不是很好，你说的这两个中间件是类似的吗，我再自己看看

SlipStupig

2016-03-02 13:52:57 +08:00

@wdg8106 mysql-proxy 是神坑，可以用一下 360 的 atlas

siteshen

2016-03-07 14:06:12 +08:00

继承实现 Session.get_bind 方法就行：

def get_bind(self, mapper=None, clause=None):
# 增强版，支持 User.use_master().get(1024)
# 当然还需要实现 Query._execute_and_instances ，增加 Query.use_master 方法
# if use_master:
# return bind['master']

if not self._flushing and bind['slaves']:
return random.choice(bind['slaves'])
else:
return bind['master']