api/monitoring/db.py

import psycopg2

from src.config import (
    POSTGRES_HOST,
    POSTGRES_PORT,
    POSTGRES_DB,
    POSTGRES_USER,
    POSTGRES_PASSWORD,
    POSTGRES_SSLMODE,
)


def get_connection():
    """Établit une connexion à la base de données PostgreSQL et la retourne.
    Returns:
        psycopg2.extensions.connection: Un objet de connexion à la base de données.
    """
    return psycopg2.connect(
        host=POSTGRES_HOST,
        port=POSTGRES_PORT,
        dbname=POSTGRES_DB,
        user=POSTGRES_USER,
        password=POSTGRES_PASSWORD,
        sslmode=POSTGRES_SSLMODE,
    )