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を使用する実用的な例を次に示します。

✅基本接続プールの例

psycopg2をインポートします
psycopg2から輸入プールから

＃接続プールを作成してみてください：
    connection_pool = psycopg2.pool.simpleconnectionpool（
        1、＃接続の最小数10、＃接続の最大数host = "localhost"、
        データベース= "your_db_name"、
        user = "your_username"、
        パスワード= "your_password"、
        port = "5432"
    ））

    connection_poolの場合：
        print（ "接続プールの作成に正常に"）

eとしての例外を除く：
    print（ "接続プールの作成が失敗しました："、e）

＃接続から接続を取得conn = connection_pool.getConn（）

conn：
    試す：
        cursor = conn.cursor（）
        cursor.execute（ "Selectバージョン（）;"）
        db_version = cursor.fetchone（）
        print（ "データベースバージョン："、db_version）

        ＃トランザクションを送信する（書き込み操作の場合）
        conn.commit（）

    eとしての例外を除く：
        print（ "データベース操作エラー："、e）
        conn.rollback（）
    ついに：
        cursor.close（）
        ＃接続を接続プールConnection_pool.putconn（conn）に返す
それ以外：
    print（ "接続プールから接続を取得できない"）

＃プログラムの最後にすべての接続を閉じます＃connection_pool.closeall（）

？キーポイント説明

SimpleConnectionPoolパラメーター

• Minconn ：接続の最小数（起動時に作成された接続の数）
• Maxconn ：接続の最大数（接続プールが拡張できる接続の数）
• 残りのパラメーターは、標準のpsycopg2.connect()パラメーター（ホスト、ユーザー、パスワードなど）です。

2。接続を取得してリリースします

• getconn()を使用して接続を取得します（自動的に作成または再利用されます）
• putconn(conn)を使用して、プールへの接続を返します（閉じていません！）
• conn.close()手動で呼び出さないでください。そうしないと、接続が本当に閉じられ、接続プールが失敗します。

3。スレッドの安全

• SimpleConnectionPoolはスレッドセーフで、マルチスレッド環境に適しています
• 各スレッドは、接続を個別に取得して返す必要があります

？より安全な使用法（コンテキストマネージャーと）

コンテキストマネージャーをカプセル化して、接続が自動的に返されることを確認できます。

 ContextLibインポートContextManagerから

@contextmanager
def get_db_connection（）：
    conn = connection_pool.getConn（）
    試す：
        収量conn
    ついに：
        connection_pool.putconn（conn）

＃get_db_connection（）でconnを使用して例を使用します。
    cursor = conn.cursor（）
    cursor.execute（ "select current_user;"）
    print（cursor.fetchone（））
    cursor.close（）

このようにして、例外が発生したとしても、接続は正しく返されます。

⚠⚠きメモ

• 接続プールオブジェクトはグローバルまたはシングルトンである必要があります、繰り返し作成を避けてください
• アプリケーションが終了してすべての接続をリリースしたときにconnection_pool.closeall()を呼び出す
• 高い並行シナリオでは、データベース接続の制限を超えないように、合理的なmaxconnを設定することに注意してください。
• Flask/Djangoなどのフレームワークを使用する場合は、アプリケーションライフサイクルと組み合わせて接続プールを管理することをお勧めします

？最後に：接続プールを閉じます

＃connection_pool.closeall（）プログラムが終了する前
print（ "すべての接続が閉じた"）

基本的にそれだけです。この例は、中小規模のアプリケーションに適しています。大規模なサービスの場合は、 SQLAlchemy psycopg2接続プーリング、またはasyncpgなどの非同期ソリューションの使用を検討することをお勧めします。

以上がPython psycopg2接続プールの例の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。