scoped_session from sqlalchemy.orm import sessionmaker from sqlalchemy import create_engine from sqlalchemy.orm import scoped_session engine = create_engine( "mysql+pymysql://root:123@47.93.4.198:3306/s6?charset=utf8", max_overflow=0, # 超过链接池大小外最多建立的链接 pool_size=5, # 链接池大小 pool_timeout=30, # 池中没有线程最多等待的时间,不然报错 pool_recycle=-1 # 多久以后对线程池中的线程进行一次链接的回收(重置) ) SessionFactory = sessionmaker(bind=engine) # 方式一:因为没法提供线程共享功能,全部在开发时要注意,在每一个线程中本身建立 session。 # from sqlalchemy.orm.session import Session # 本身具备操做数据库的:'close', 'commit', 'connection', 'delete', 'execute', 'expire',..... session = SessionFactory() # print('原生session',session) # 操做 session.close() # 方式二:支持线程安全,为每一个线程建立一个session # 实现1:- threading.Local # 实现2:- 惟一标识(能够是线程的,或者协程的) # ScopedSession对象 # self.registry(), 加括号 建立session #协程建立惟一标识(引入线程的惟一标识便可为线程建立) #from greenlet import getcurrent as get_ident #session = scoped_session(SessionFactory,get_ident) #本地线程建立惟一标识 session = scoped_session(SessionFactory) # 操做 session.remove()