SQLAlchemy + Tornado: SQLAlchemy's ScopedSession için scopefunc nasıl oluşturulur?

Question

Kasırga kullanarak, SQLAlchemy oturumlarımın düzgün bir şekilde kapatılıp temizlenmesini ve böylece nesnelerin bir istekten diğerine paylaşılmamasını sağlamak için biraz ara yazılım büyüsü oluşturmak istiyorum. İşin sırrı, bazı kasırga işleyicilerim eşzamansız olduğundan, her istek için yalnızca bir oturum paylaşamıyorum.

Her istek için nasıl yeni bir oturum oluşturulacağını bilen bir Kapsamlı Oturum oluşturmaya çalışıyorum. Tek yapmam gereken, şu anda yürütme isteğini bir tür benzersiz anahtar haline dönüştürebilen kodum için bir scopefunc tanımlamaktır, ancak şu andaki isteği herhangi bir noktada 'a nasıl aldığımı anlayamıyorum (işlevimin her ikisine de erişemediği geçerli RequestHandler kapsamı dışında).

Bu işi yapmak için yapabileceğim bir şey var mı?

Answer 1

Session isteği ile ilişkilendirmek isteyebilirsiniz (yani, uygun değilse scopedsession kullanmayın). O zaman sadece request.session deyin. Kurulum/yıpranma için başlangıç ​​/ bitişte kancalar hala olmalıdır.

düzenleme: Özel kapsam fonksiyonu

def get_current_tornado_request(): 
    # TODO: ask on the Tornado mailing list how 
    # to acquire the request currently being invoked 

Session = scoped_session(sessionmaker(), scopefunc=get_current_tornado_request) 

Answer 2

(Bu 2011 soruya 2017 cevaptır) @Stefano Borini belirttiği gibi, Tornado 4'te kolay yolu sadece RequestHandler örtülü pass the session around izin vermektir. eşyordam dekoratör kalıplarını kullanırken Tornado işleyicisi örneği durumunu izler: Gerçekten gerçekten uyumsuz bunu beri bir anti-desen ele alacak bir declarative_base (iç SQL Simya oturumu başvurmak gerekiyorsa

import logging 

_logger = logging.getLogger(__name__) 

from sqlalchemy import create_engine, exc as sqla_exc 
from sqlalchemy.orm import sessionmaker, exc as orm_exc 

from tornado import gen 
from tornado.web import RequestHandler 

from my_models import SQLA_Class 

Session = sessionmaker(bind=create_engine(...)) 

class BaseHandler(RequestHandler): 

    @gen.coroutine 
    def prepare(): 
     self.db_session = Session() 

    def on_finish(): 
     self.db_session.close() 

class MyHander(BaseHandler): 

    @gen.coroutine 
    def post(): 
     SQLA_Object = self.db_session.query(SQLA_Class)... 
     SQLA_Object.attribute = ... 

     try: 
      db_session.commit() 
     except sqla_exc.SQLAlchemyError: 
      _logger.exception("Couldn't commit") 
      db_session.rollback() 

aşırı çiftler Uygulamaya model), Amit Matani olmayan bir çalışma örneği var here.