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()