Как исправить ошибку psycopg2.InterfaceError: connection already closed?

Question

[Dmitry]

У меня была проблема, в моем приложении написанном на flask, было подключение к БД и все работало корректно, но я потерял доступ к таблице задавая sql запросы через python или через pgadmin, т.е ошибок никаких не выдавало, а была просто бесконечная загрузка(при любых запросах).

Выполняя запрос "select * from pg_stat_activity;" я увидел что некоторые сессии висят в состоянии idle in transaction.

Далее я решил выполнить такой запрос

SELECT pg_terminate_backend(pid)
FROM pg_stat_activity 
WHERE datname = 'dbname'
  AND pid <> pg_backend_pid()
  AND state = 'idle in transaction' 
  AND state_change < current_timestamp - INTERVAL '5' MINUTE;

Теперь я могу выполнять запросы из pgadmin/python и в целом подключаться к данной таблице, но при открытии моего приложения появилась такая ошибка.

psycopg2.InterfaceError: connection already closed

Traceback (most recent call last)
File "/usr/local/lib/python3.11/site-packages/flask/app.py", line 2213, in __call__
return self.wsgi_app(environ, start_response)
       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.11/site-packages/flask/app.py", line 2193, in wsgi_app
response = self.handle_exception(e)
           ^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.11/site-packages/flask/app.py", line 2190, in wsgi_app
response = self.full_dispatch_request()
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.11/site-packages/flask/app.py", line 1486, in full_dispatch_request
rv = self.handle_user_exception(e)
     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.11/site-packages/flask/app.py", line 1484, in full_dispatch_request
rv = self.dispatch_request()
     ^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/local/lib/python3.11/site-packages/flask/app.py", line 1469, in dispatch_request
return self.ensure_sync(self.view_functions[rule.endpoint])(**view_args)
       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/T2app/./app.py", line 27, in index
cur = conn.cursor()
      ^^^^^^^^^^^^^
psycopg2.InterfaceError: connection already closed

Подскажите, пожалуйста, как мне исправить это?

Answer 1

[AUser0]

Перезапустите приложение, что бы оно переподключилось к базе данных.

И впишите в приложение проверку/реакцию на разрыв соединения с базой данных, как произошло из-за pg_terminate_backend(pid).

Comments

[Dmitry]

Не подскажите как добавить проверку/реакцию на разрыв соединения с базой данных?
или может быть в целом в моем коде подключение и запрос выполнены некорректно, т.к появляются idle in transaction?

Так в моем коде реализовано подключение и сам запрос.

def index():
    # соединение с БД
    with psycopg2.connect(**params) as conn:
        # создание объекта курсора для запуска команд PostgreSQL в базе данных
        cur = conn.cursor()
        cur.execute("SELECT * FROM fact_table;") 
        rows = cur.fetchall()
        cur.close()
    
    if request.method == "POST":
        with psycopg2.connect(**params) as conn:
            # создание объекта курсора для запуска команд PostgreSQL в базе данных
            cur = conn.cursor()
            cur.execute("SELECT {} FROM fact_table WHERE year = ANY(%s) AND indicators = ANY(%s) AND station_name = ANY(%s);"
                        .format(",".join(["\"{}\"".format(c) for c in columns])),(selected_years, selected_indicators, selected_stations))
            # Для получения доступа к сформированной выборке используем cur.fetchall()
            rows = cur.fetchall()
            cur.close()

[AUser0]

Dmitry, я в Python-е ни в зуб ногой, поэтому вот вам полезная информация...

[Dmitry]

Justa Gain, Я понимаю, что код связанный с БД реализован не лучшим образом, можете подсказать как написать это правильно/лучше? У меня, к сожалению, пока не хватает знаний..

[Dmitry]

Justa Gain, хорошо, спасибо!