pyodbc: как повторить попытку восстановления после временных ошибок?

У меня есть API, размещенный на колбе. Он работает за сервером Торнадо. Происходит то, что иногда изменения, внесенные в пользовательский интерфейс, не отражаются в базе данных. Также несколько скриптов, которые я запускаю, дают любую из 3 следующих ошибок:

  1. pyodbc.Ошибка: ('08S01', ' [08S01] [Microsoft][драйвер ODBC SQL Server]сбой канала связи (0) (SQLExecDirectW)')
  2. pyodbc.Ошибка: ('01000', '[01000] [Microsoft][ODBC SQL Server Драйвер] [DBNETLIB]ConnectionWrite (send()). (10054) (SQLExecDirectW)')
  3. pyodbc.Ошибка: ('01000', '[01000] [Microsoft] [драйвер ODBC SQL Server] [DBNETLIB]ConnectionRead (recv()). (10054) (SQLExecDirectW)')

Это фрагмент моего кода API колбы:

class Type(Resource):

    def put(self):
        parser = reqparse.RequestParser()
        parser.add_argument('id', type = int)
        parser.add_argument('type', type = int)
        args = parser.parse_args()

        query = """
        UPDATE myDb SET Type = ? WHERE Id = ?
        """

        connection = pyodbc.connect(connectionString)
        cursor = connection.cursor()
        cursor.execute(query, [args['type'], args['id']])
        connection.commit()
        cursor.close()
        connection.close()

api.add_resource(Type, '/type')

есть ли логика повтора, я могу добавить на курсор.выполнить строку? Я понятия не имею, как бороться с временными ошибками с python. Пожалуйста помочь.

1 ответ:

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

import time

retry_flag = True
retry_count = 0
while retry_flag and retry_count < 5:
  try:
    cursor.execute(query, [args['type'], args['id']])
    retry_flag = False
  except:
    print "Retry after 1 sec"
    retry_count = retry_count + 1
    time.sleep(1)

надеюсь, что это помогает.