Python如何实现自定义读写分离-创新互联
这篇文章将为大家详细讲解有关Python如何实现自定义读写分离,小编觉得挺实用的,因此分享给大家做个参考,希望大家阅读完这篇文章后可以有所收获。
我们注重客户提出的每个要求,我们充分考虑每一个细节,我们积极的做好成都做网站、网站设计、外贸营销网站建设服务,我们努力开拓更好的视野,通过不懈的努力,创新互联建站赢得了业内的良好声誉,这一切,也不断的激励着我们更好的服务客户。 主要业务:网站建设,网站制作,网站设计,微信小程序,网站开发,技术开发实力,DIV+CSS,PHP及ASP,ASP.Net,SQL数据库的技术开发工程师。思路
自定义Session类
重写get_bind方法
根据self._flushing判断读写操作, 选择对应的数据库
自定义SQLAlchemy类
重写create_session, 在其中使用自定义的Session类
from flask import Flask from flask_sqlalchemy import SQLAlchemy, SignallingSession, get_state from sqlalchemy import orm class RoutingSession(SignallingSession): def get_bind(self, mapper=None, clause=None): state = get_state(self.app) # 判断读写操作 if self._flushing: # 写操作 ,使用主数据库 print("写入数据") return state.db.get_engine(self.app, bind='master') else: # 读操作, 使用从数据库 print('读取数据') return state.db.get_engine(self.app, bind='slave') class RoutingSQLAlchemy(SQLAlchemy): def create_session(self, options): return orm.sessionmaker(class_=RoutingSession, db=self, **options) app = Flask(__name__) # 设置数据库的连接地址 app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql://root:mysql@192.168.105.134:3306/demo' # 设置数据库的绑定地址 app.config['SQLALCHEMY_BINDS'] = { 'master': "mysql://root:mysql@192.168.105.134:3306/demo", 'slave': "mysql://root:mysql@192.168.105.134:8306/demo" } # 设置是否追踪数据库变化 一般不会开启, 影响性能 app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False # 设置是否打印底层执行的SQL语句 app.config['SQLALCHEMY_ECHO'] = False # 创建数据库连接对象 db = RoutingSQLAlchemy(app) # 用户表 一 class User(db.Model): __tablename__ = 't_user' id = db.Column(db.Integer, primary_key=True) name = db.Column(db.String(20), unique=True) @app.route('/') def index(): # 增加数据 user1 = User(name='zs') db.session.add(user1) db.session.commit() # 查询数据 users = User.query.all() print(users) return "index" if __name__ == '__main__': # 删除所有继承自db.Model的表 db.drop_all() # 创建所有继承自db.Model的表 db.create_all() app.run(debug=True)
关于“Python如何实现自定义读写分离”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,使各位可以学到更多知识,如果觉得文章不错,请把它分享出去让更多的人看到。
文章题目:Python如何实现自定义读写分离-创新互联
分享网址:http://myzitong.com/article/dpsoec.html