Блог

Итак, я разрабатываю эту онлайн-игру, похожую на telnet, и она не очень популярна (кто знает, когда-нибудь), поэтому подключение к базе данных моего игрового движка не используется в течение нескольких часов ночью. Это один скрипт, который ожидает событий, поэтому он продолжает выполняться.

При первом выполнении запроса после нескольких часов бездействия я получаю ошибку mariadb.DatabaseError при попытке запустить курсор. Если я повторю запрос, он снова заработает. Таким образом, хотя функция выдает исключение о том, что соединение потеряно, она восстанавливает его.

Мой вопрос: как мне с этим справиться?

Это вещи, которые я рассматриваю как возможные решения, но, на мой взгляд, они не очень хороши:

• перенос каждого запроса в структуру, исключающую попытки, делает код громоздким из-за большей части ненужного и повторяющегося кода
• пишу свою собственную функцию ‘decorator’ для выполнения запроса, который затем повторно инициализирует базу данных, когда я получу mariadb.DatabaseError, что кажется лучше, но заставляет меня писать функции-оболочки вокруг (почти) идеально работающих библиотечных функций
• выполнение в основном бессмысленного запроса «ping» каждые N минут, что нагружает базу данных, которая бесполезна в 99,9% случаев.

Вот некоторый код для иллюстрации:

 import mariadb
class Db:
  ...
  def __init__(self):
    self.conn = mariadb.connect(user=self.__db_user, password=self.__db_pass, host=self.__db_host, port=self.__db_port, database=self.__db_name)

  def one_of_many_functions(self, ...):
    cur = self.conn.cursor()
    cur.execute('SELECT ...') # Here is where the mariadb.DatabaseError happens after long inactivity, and otherwise runs fine
    ...
  

Я на самом деле действительно не понимаю, почему реализация mariadb в python не обрабатывает это. Когда соединение потеряно, cur.execute выдаст ошибку mariadb.DatabaseError, но никаких действий предпринимать не нужно, потому что, если я запрашиваю с тем же подключением к базе данных, оно снова работает. Таким образом, соединение само восстанавливается. Почему компонент вызывает у меня запрос, в то время как он «восстанавливает» само соединение и может запрашивать снова?

Но поскольку это то, что есть, мой вопрос: каков наилучший способ справиться с этим?

Если вы установите значение long time out, даже нет гарантии, что соединение будет прервано по другим причинам (тайм-аут клиента, отключение на 24 часа, …)

Одним из вариантов было бы установить auto_reconnect, как в следующем примере:

 import mariadb

conn1= mariadb.connect()
conn2= mariadb.connect()

# Force MariaDB/Connector Python to reconnect
conn2.auto_reconnect= True

cursor1= conn1.cursor()

print("Connid of connection 2: %s" % conn2.connection_id);

# Since we don't want to wait, we kill the conn2 intentionally
cursor1.execute("KILL %s" % conn2.connection_id)

cursor2= conn2.cursor()
cursor2.execute("select connection_id()")
row= cursor2.fetchall()
print("Connid of connection 2: %s" % conn2.connection_id);
print(row)
  

Вывод:

 Connid of connection 2: 174
Connid of connection 2: 175
[(175,)]
  

Таким образом, после того, как соединение 2 было прервано, next cursor.execute установит новое соединение перед выполнением инструкции. Это решение не будет работать, если вы используете существующий открытый курсор, поскольку дескриптор внутренней инструкции становится недействительным.

Используете ли вы сокет или TCP / IP для подключения?

Соединения TCP / IP предназначены для очистки после периода отсутствия трафика. Вы можете сказать, что это идиотизм, но на самом деле нет лучшего способа узнать, происходит ли сбой программы.

По той же причине базы данных имеют свой собственный механизм ожидания. Для MySQL это называется wait_timeout.

Обычно объект соединения (или его оболочка) позаботится о выполнении некоторого запроса без операции, если с соединением больше ничего не происходит, что-то вроде select 1 . Это стандартная практика. Проверьте документацию для вашего объекта connection — возможно, он уже есть, вам просто нужно его настроить. Используйте что-то вроде 30-60 секунд.

Если нет, вам придется реализовать это самостоятельно. Не имеет значения, как, дело в том, что вы не можете ожидать, что соединения будут оставаться открытыми вечно. Либо сделайте соединения недолговечными (открывайте их только тогда, когда вам это нужно, и закрывайте их впоследствии), либо реализуйте таймер, который будет периодически вставлять какой-либо запрос без операции. В последнем случае обратите внимание, что вам нужно будет реализовать механизм синхронизации, чтобы убедиться, что запрос вашего приложения никогда не выполняется одновременно с запросом без операции.

Рассматривали ли вы возможность использования пула соединений.

 # Create Connection Pool
pool = mariadb.ConnectionPool(
      #...,
      pool_size=1
   )

  

Затем в вашем методе подключения.

 try:
    pconn = pool.get_connection()

except mariadb.PoolError as e:
   # Report Error
   print(f"Error opening connection from pool: {e}")
  

В документации не говорится, что происходит, когда соединения закрыты или разорваны. Я ожидаю, что он позаботится об этом и всегда пытается обеспечить действительное соединение (до тех пор, пока вы не запрашиваете больше соединений, чем в пуле.)

Я получил код из их документов