[python] SQLAlchemy : 세션 생성 vs. 재사용

Program / 글쓴이

그냥 빨리 질문 : SQLAlchemy의의 에 대해 이야기 를 호출 sessionmaker()하면 있지만 결과 호출 Session()클래스 당신이 DB 얘기해야 할 때마다. 나에게 그것은 두 번째로 첫 번째 session.add(x)또는 비슷한 것을 할 것임을 의미합니다.

from project import Session
session = Session()

지금까지 내가 한 일은 session = Session()내 모델에서 한 번 호출 한 다음 항상 내 애플리케이션의 어느 곳에서나 동일한 세션을 가져 오는 것이 었습니다. 이것은 웹 응용 프로그램이기 때문에 일반적으로 동일한 것을 의미합니다 (하나의 뷰가 실행 됨).

그러나 차이점은 무엇입니까? 내 기능이 완료 될 때까지 데이터베이스 작업에 사용하고 다음에 내 DB와 대화하고 싶을 때 새 세션을 생성하는 것에 비해 항상 하나의 세션을 사용하는 것의 단점은 무엇입니까?

여러 스레드를 사용하는 경우 각 스레드가 자체 세션을 가져야합니다. 하지만을 사용하여 scoped_session()이미 문제가 존재하지 않는지 확인했습니다.

내 가정 중 잘못된 것이 있는지 명확히하십시오.

답변

sessionmaker()Session하나의 위치에 새 개체 를 만들기위한 구성 옵션을 배치하도록 장려하기 위해 있습니다 . 이는 선택 사항입니다 Session(bind=engine, expire_on_commit=False). 새를 필요 로 할 때마다 쉽게 전화를 걸 수 Session있다는 점에서 장황하고 중복 적이라는 점을 제외하고는 각각이이 중복 문제에 접근 한 소규모 “도우미”의 확산을 막고 싶었습니다. 더 혼란스러운 방법입니다.

그래서 sessionmaker()당신이 만들 수 있도록 단지 도구입니다 Session당신이 그들을 필요로 할 때 객체.

다음 부분. 질문은 Session()여러 지점에서 새로 만드는 것과 끝까지 사용 하는 것의 차이점이 무엇이라고 생각합니다 . 대답은 그리 많지 않습니다. Session그것은 당신이 그 안에 넣은 모든 객체의 컨테이너이며, 또한 열린 트랜잭션을 추적합니다. 지금이 순간 당신은 전화 rollback()또는 commit()트랜잭션이 끝난하고는 Session그것을 다시 SQL을 방출하도록 요청 될 때까지 데이터베이스로의 연결이 없습니다. 매핑 된 개체에 대한 링크는 개체에 보류중인 변경 사항이없는 경우 약한 참조이므로 Session응용 프로그램이 매핑 된 개체에 대한 모든 참조를 잃어 버리면 완전히 새로운 상태로 다시 비워집니다. 기본값으로두면"expire_on_commit"설정하면 커밋 후 모든 개체가 만료됩니다. 이것이 Session5 분 또는 20 분 동안 지속되고 다음에 사용할 때 데이터베이스에서 모든 종류의 사항이 변경된 경우 다음에 해당 개체에 액세스 할 때 모든 새로운 상태가로드됩니다. 20 분 동안.

웹 응용 프로그램에서 우리는 일반적으로 Session동일한 것을 반복해서 사용하는 대신 각 요청에 대해 새로운 것을 만드는 것이 어떻습니까 ? 이렇게하면 새 요청이 “정리”로 시작됩니다. 이전 요청의 일부 객체가 아직 가비지 수집되지 않았고 꺼져 있다면 "expire_on_commit"이전 요청의 일부 상태가 여전히 남아있을 수 있으며 해당 상태가 꽤 오래되었을 수도 있습니다. 전원 expire_on_commit을 켜놓고 확실히 전화를 commit()하거나 rollback()요청이 끝날 때 조심한다면 괜찮습니다.하지만 새로운으로 Session시작하면 깨끗하게 시작하고 있다는 질문조차 없습니다. 따라서 각 요청을 새로운Sessionexpire_on_commit이 플래그는 commit()일련의 작업 중간에 호출하는 작업에 대해 많은 추가 SQL을 발생시킬 수 있기 때문에 새로 시작하고 있는지 확인하고 거의 선택 사항을 사용하는 가장 간단한 방법 입니다 . 이것이 귀하의 질문에 대한 답변인지 확실하지 않습니다.

다음 라운드는 스레딩에 대해 언급 한 것입니다. 앱이 다중 스레드 인 경우 사용중인 앱이 Session로컬에 있는지 확인하는 것이 좋습니다 . scoped_session()기본적으로 현재 스레드에 로컬로 만듭니다. 웹 앱에서는 요청에 로컬이 더 좋습니다. Flask-SQLAlchemy는 실제로 사용자 지정 “범위 함수”를 전송 scoped_session()하여 요청 범위 세션을 얻습니다. 평균적인 Pyramid 응용 프로그램은 “요청”레지스트리에 세션을 고정합니다. 이와 같은 체계를 사용할 때 “요청 시작시 새 세션 만들기”아이디어는 계속해서 일을 똑바로 유지하는 가장 간단한 방법처럼 보입니다.

답변

뛰어난 zzzeek의 답변 외에도 다음은 일회용, 자체 폐쇄 형 세션을 빠르게 생성하는 간단한 방법입니다.

from contextlib import contextmanager

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

@contextmanager
def db_session(db_url):
    """ Creates a context with an open SQLAlchemy session.
    """
    engine = create_engine(db_url, convert_unicode=True)
    connection = engine.connect()
    db_session = scoped_session(sessionmaker(autocommit=False, autoflush=True, bind=engine))
    yield db_session
    db_session.close()
    connection.close()

용법:

from mymodels import Foo

with db_session("sqlite://") as db:
    foos = db.query(Foo).all()

답변