イベントハンドラを追加する方法は、sqlalchemyでコミットされたトランザクションの後に1回だけ発生します。

Question

sqlalchemyを使用していくつかの関数を書いています。これらの関数は、

def create_order(session, *arg, **kw): 
    # create order object 
    order = Order(xxxx=xxx) 
    session.add(order) 

    # order extra operations 
    order_extra_data = OrderExtraData(yyyy=yyyy) 
    session.add(order_extra_data) 

    # more operations 
    .... 

    # email should be sent to the order's owner 

のような内部取引と呼ばれ、注文が成功した後、ユーザーに電子メールを送信する必要があります。しかし、create_orderの最後では、トランザクションはまだコミットされておらず、後のコードで中止される可能性があります。したがって、この関数は直接メールを送信すべきではありません。その代わりに、セッションがコミットされた後にのみ起動されるワンタイムイベントハンドラを登録する必要があります（トランザクションがロールバックまたはクローズの場合は起動せずクリアしないでください）。これをどのように実装できますか？

Answer 1

あなたはonce=Trueとのセッションafter_commitイベントをリッスンすることができます

def create_order(session, ...): 
    ... 
    @event.listens_for(session, "after_commit", once=True) 
    def _send_email_after_commit(session): 
     send_email() 

あなたがロールバックし、道のセッションを再利用（およびロールバック後に発射するリスナーない）予想される場合は、あなたの」ロールバックが発生した場合でもイベントを削除する必要があります。

def create_order(session, ...): 
    ... 
    @event.listens_for(session, "after_commit", once=True) 
    def _send_email_after_commit(session): 
     send_email() 

    @event.listens_for(session, "after_soft_rollback", once=True) 
    def _remove_event_listener_on_rollback(session, prev_transaction): 
     event.remove(session, "after_commit", _send_email_after_commit)