@apiwi

Как исправить ошибку WinError 10054 pyMySql?

Есть телеграмм бот с базой данных, получает количество пользователей в базе и делает операции над каждым из них.
Задача функции разослать уведомления юсерам с определенными критериями
База данных стоит на платном хостинге
Каждые 10 минут выскакивает такая ошибка:
Traceback (most recent call last):
  File "d:\Python\TG\InvestBot\golibaks.py", line 47, in notified
    cursor.execute("SELECT COUNT(*) FROM old_users WHERE status = '+' AND notified = '-'")
  File "C:\Users\apiwi\AppData\Local\Programs\Python\Python39\lib\site-packages\pymysql\cursors.py", line 148, in execute
    result = self._query(query)
  File "C:\Users\apiwi\AppData\Local\Programs\Python\Python39\lib\site-packages\pymysql\cursors.py", line 310, in _query
    conn.query(q)
  File "C:\Users\apiwi\AppData\Local\Programs\Python\Python39\lib\site-packages\pymysql\connections.py", line 548, in query
    self._affected_rows = self._read_query_result(unbuffered=unbuffered)
  File "C:\Users\apiwi\AppData\Local\Programs\Python\Python39\lib\site-packages\pymysql\connections.py", line 775, in _read_query_result
    result.read()
  File "C:\Users\apiwi\AppData\Local\Programs\Python\Python39\lib\site-packages\pymysql\connections.py", line 1156, in read
    first_packet = self.connection._read_packet()
  File "C:\Users\apiwi\AppData\Local\Programs\Python\Python39\lib\site-packages\pymysql\connections.py", line 692, in _read_packet
    packet_header = self._read_bytes(4)
  File "C:\Users\apiwi\AppData\Local\Programs\Python\Python39\lib\site-packages\pymysql\connections.py", line 738, in _read_bytes
    raise err.OperationalError(
pymysql.err.OperationalError: (2013, 'Lost connection to MySQL server during query ([WinError 10054] Удаленный хост принудительно разорвал существующее подключение)')


Конекты все закрываю, ничем не помогает. Мускул последней версии
Вот кусок кода:
def notified():
    threading.Timer(500, notified).start()
    try:
        if config.allow_kick == False: print("Kick disallowed")
        else: print("Kick allowed")

        with connection.cursor() as cursor:
            cursor.execute("SELECT COUNT(*) FROM old_users WHERE status = '+' AND notified = '-'")
            summ = list(cursor)[0]["COUNT(*)"]  
            count = 0
            connection.commit()
            
            while summ != count:
                with connection.cursor() as cursor:
                    cursor.execute("SELECT * FROM old_users WHERE status = '+' AND notified = '-'")
                    for row in cursor:
                        user_id = row['user_id']
                        end_date = row['end_date']
                        now_date = datetime.datetime.now()

                        #print(f"{user_id} {now_date} {end_date}")
                        if end_date == "0000-00-00 00:00:00":
                            pass
                        else:
                            if now_date >= (end_date - timedelta(config.day_notify)):
                                cursor.execute(f"UPDATE old_users SET notified = '+' WHERE user_id = {user_id}")
                                bot.send_message(user_id, txs.sub_ender, reply_markup=kb.payment3)
                                connection.commit()
                                print(f"{user_id} (old) notified")
                            
                            else:
                                pass
                            
                        count = count+1
        connection.commit()
  • Вопрос задан
  • 87 просмотров
Решения вопроса 1
@apiwi Автор вопроса
Проблема была в пуле
bot.polling(none_stop=True, interval=0, timeout=20)
Ответ написан
Комментировать
Пригласить эксперта
Ответы на вопрос 1
BojackHorseman
@BojackHorseman Куратор тега MySQL
...в творческом отпуске...
ответ легко ищется поисковиком
Ответ написан
Ваш ответ на вопрос

Войдите, чтобы написать ответ

Войти через центр авторизации
Похожие вопросы