Ereignis-Listener in Bereichssitzung

Question

Ich versuche, einen Ereignis-Listener zum before_commit Ereignis einer SQLAlchemy Sitzung innerhalb einer Flask-Anwendung hinzuzufügen. Wenn Sie die folgenden Schritte

def before_commit(session): 
    for item in session: 
     if hasattr(item, 'on_save'): 
      item.on_save(session) 

event.listen(db.session, 'before_commit', before_commit) 

ich

Traceback (most recent call last): 
    File "<stdin>", line 1, in <module> 
    File "app.py", line 60, in <module> 
    event.listen(db.session, 'before_commit', before_commit) 
    File "C:\Python27\lib\site-packages\sqlalchemy\event\api.py", line 49, in listen 
    _event_key(target, identifier, fn).listen(*args, **kw) 
    File "C:\Python27\lib\site-packages\sqlalchemy\event\api.py", line 22, in _event_key 
    tgt = evt_cls._accept_with(target) 
    File "C:\Python27\lib\site-packages\sqlalchemy\orm\events.py", line 1142, in _accept_with 
    "Session event listen on a scoped_session " 
sqlalchemy.exc.ArgumentError: Session event listen on a scoped_session requires that its creation callable is associated with the Session class. 

Ich kann nicht den richtigen Weg finden, den Ereignis-Listener zu registrieren. Die Dokumentation besagt, dass event.listen() auch eine scoped_session akzeptiert, aber es scheint, als ob es nicht ?!

---

http://docs.sqlalchemy.org/en/latest/orm/events.html#sqlalchemy.orm.events.SessionEvents

Die Funktion listen() wird Session-Objekte übernehmen sowie das Rückergebnis von sessionmaker() und scoped_session().

Zusätzlich wird die Session-Klasse akzeptiert, die Listener global auf alle Instanzen der Session anwendet.

Answer 1

es bedeutet, dass die Fabrik Sie scoped_session bestanden haben() eine sessionmaker sein muss():

from sqlalchemy.orm import scoped_session, sessionmaker, sessionmaker 
from sqlalchemy import event 

# good 

ss1 = scoped_session(sessionmaker()) 

@event.listens_for(ss1, "before_flush") 
def evt(*arg, **kw): 
    pass 

# bad 

ss2 = scoped_session(lambda: Session) 

@event.listens_for(ss2, "before_flush") 
def evt(*arg, **kw): 
    pass 

Answer 2

ein anderes Beispiel zu geben, diese Code-Basis wird nicht funktionieren: https://sourceforge.net/p/turbogears1/code/HEAD/tree/branches/1.5/turbogears/database.py

# bad 

def create_session(): 
    """Create a session that uses the engine from thread-local metadata. 

    The session by default does not begin a transaction, and requires that 
    flush() be called explicitly in order to persist results to the database. 

    """ 
    if not metadata.is_bound(): 
     bind_metadata() 
    return sqlalchemy.orm.create_session() 

session = sqlalchemy.orm.scoped_session(create_session) 

Stattdessen braucht es so etwas wie die folgenden sein:

# good 

class SessionMakerAndBind(sqlalchemy.orm.sessionmaker): 
    def __call__(self, **kw): 
     if not metadata.is_bound(): 
      bind_metadata() 
     return super(SessionMakerAndBind, self).__call__(**kw) 

sessionmaker = SessionMakerAndBind(autoflush=False, 
        autocommit=True, expire_on_commit=False) 
session = sqlalchemy.orm.scoped_session(sessionmaker)