Python psycopg2 연결 풀 예제

psycopg2.pool.simpleconnectionpool을 사용하여 데이터베이스 연결을 효과적으로 관리하고 빈번한 연결 생성 및 파괴로 인한 성능 오버 헤드를 피하십시오. 1. 연결 풀을 만들 때 연결 풀이 성공적으로 초기화되도록 최소 및 최대 연결 및 데이터베이스 연결 매개 변수를 지정하십시오. 2. getConn ()을 통해 연결을 가져 와서 putconn ()을 사용하여 데이터베이스 작업을 실행 한 후 풀에 연결을 반환하십시오. 끊임없이 Conn.Close () 호출 금지됩니다. 3. SimpleConnectionPool은 스레드 안전이며 다중 스레드 환경에 적합합니다. 4. 컨텍스트 관리자와 함께 컨텍스트 관리자를 구현하여 예외적으로 연결을 올바르게 반환 할 수 있는지 확인하는 것이 좋습니다. 5. 연결 풀은 글로벌 싱글 톤으로 사용되어야하며 프로그램이 종료되기 전에 CloseAll ()을 호출해야합니다. 이 솔루션은 중소형 응용 분야에 적합하며 대형 서비스는 SQLALCHEMY 또는 ASYNCPG를 고려할 수 있습니다.

psycopg2 의 연결 풀을 사용하면 데이터베이스 연결을 효과적으로 관리하고 빈번한 연결 생성 및 파괴로 인한 성능 오버 헤드를 피할 수 있습니다. psycopg2 자체는 연결 풀링 기능을 제공하지 않지만 공식적으로 권장되는 psycopg2.pool 모듈 (실제로 psycopg2 패키지의 pool 하위 모듈)은 threading 에 따라 연결 풀링을 안전하게 관리 할 수 있습니다.

다음은 psycopg2.pool.SimpleConnectionPool 사용하는 실질적인 예입니다.

connection 기본 연결 풀 예제

 psycopg2를 가져옵니다
psycopg2 가져 오기 풀에서

# 연결 풀 만들기 시도 :
    Connection_pool = psycopg2.pool.simpleconnectionpool (
        1, # 최소 연결 수 10, # 최대 연결 수 호스트 = "LocalHost",
        Database = "Your_db_name",
        user = "your_username",
        password = "your_password",
        포트 = "5432"
    ))

    Connection_pool 인 경우 :
        Print ( "연결 풀 생성 성공")

E로 예외를 제외하고 :
    print ( "연결 풀 생성 실패 :", e)

# 연결 풀에서 연결 받기 Conn = Connection_Pool.getConn ()

Conn :
    노력하다:
        커서 = conn.cursor ()
        cursor.execute ( "select version ();")
        db_version = cursor.fetchone ()
        print ( "데이터베이스 버전 :", db_version)

        # 거래 제출 (쓰기 작업 인 경우)
        conn.commit ()

    E로 예외를 제외하고 :
        print ( "데이터베이스 작동 오류 :", e)
        conn.rollback ()
    마지막으로:
        cursor.close ()
        # 연결 풀에 연결을 반환합니다. Connection_POOL.PUTCONN (CONN)
또 다른:
    인쇄 ( "연결 풀에서 연결을 얻을 수 없음")

# 프로그램 끝에서 모든 연결을 닫습니다 # connection_pool.closeall () # 일반적으로 응용 프로그램이 종료 될 때 호출됩니다.

? 키 포인트 설명

1. SimpleConnectionPool 매개 변수

• MinConn : 최소 연결 수 (스타트 업에서 생성 된 연결 수)
• MaxConn : 최대 연결 수 (연결 풀이 확장 할 수있는 연결 수)
• 나머지 매개 변수는 표준 psycopg2.connect() 매개 변수 (예 : 호스트, 사용자, 암호 등)입니다.

2. 연결을 얻고 해제하십시오

• getconn() 사용하여 연결을 얻습니다 (자동으로 작성 또는 재사용)
• putconn(conn) 사용하여 수영장에 연결을 반환하십시오 (폐쇄되지 않음!)
• conn.close() 수동으로 호출하지 마십시오. 그렇지 않으면 연결이 진정으로 닫히면 연결 풀이 실패하게됩니다.

3. 스레드 안전

• SimpleConnectionPool 은 스레드 안전이며 다중 스레드 환경에 적합합니다
• 각 스레드는 연결을 독립적으로 얻고 반환해야합니다

? 안전한 사용법 (컨텍스트 관리자와 함께)

컨텍스트 관리자를 캡슐화하여 연결이 자동으로 반환되도록 할 수 있습니다.

 ContextLib import ContextManager에서

@contextManager
def get_db_connection () :
    conn = connection_pool.getConn ()
    노력하다:
        CONT를 산출하십시오
    마지막으로:
        Connection_Pool.putConn (Conn)

# get_db_connection ()과 함께 Conn으로 예제를 사용하십시오.
    커서 = conn.cursor ()
    cursor.execute ( "current_user;")
    print (cursor.fetchone ())
    cursor.close ()

이러한 방식으로 예외가 발생하더라도 연결이 올바르게 반환됩니다.

⚠️ notes

• 연결 풀 객체는 글로벌 또는 싱글 톤이어야합니다. 반복적 인 생성을 피하십시오.
• 응용 프로그램이 종료되어 모든 연결을 출시 할 때 connection_pool.closeall() 호출하십시오.
• 동시성이 높은 시나리오에서는 데이터베이스 연결의 한계를 초과하지 않도록 합리적인 maxconn 설정하는 데주의를 기울이십시오.
• Flask/Django와 같은 프레임 워크를 사용하는 경우 응용 프로그램 라이프 사이클과 함께 연결 풀을 관리하는 것이 좋습니다.

? 마지막으로 : 연결 풀을 닫으십시오

 # connection_pool.closeall () 프로그램이 종료되기 전에
인쇄 ( "모든 연결이 닫힌")

기본적으로 그게 다야. 이 예제는 중소형 응용 프로그램에 적합합니다. 대규모 서비스 인 경우 SQLAlchemy psycopg2 연결 풀링 또는 asyncpg 와 같은 비동기 솔루션을 사용하는 것이 좋습니다.

위 내용은 Python psycopg2 연결 풀 예제의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!