pyodbc:如何重试从瞬态错误中恢复?

pyodbc: How to retry to recover from Transient errors?(pyodbc:如何重试从瞬态错误中恢复?)
本文介绍了pyodbc:如何重试从瞬态错误中恢复?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

我在 Flask 上托管了一个 API.它在 Tornado 服务器后面运行.发生的情况是有时对 UI 所做的更改未反映在数据库中.此外,我运行的一些脚本会出现以下 3 个错误中的任何一个:

I've an API hosted on Flask. It runs behind a Tornado server. What is happening is that sometimes changes made on the UI are not reflected in the database. Also a few of the scripts I have running gives any of the 3 following errors:

  1. pyodbc.Error: ('08S01', '[08S01] [Microsoft][ODBC SQL Server Driver]通信链接失败 (0) (SQLExecDirectW)')
  2. pyodbc.Error: ('01000', '[01000] [Microsoft][ODBC SQL Server Driver][DBNETLIB]ConnectionWrite (send()).(10054) (SQLExecDirectW)')
  3. pyodbc.Error: ('01000', '[01000] [Microsoft][ODBC SQL Server Driver][DBNETLIB]ConnectionRead (recv()).(10054) (SQLExecDirectW)')

这是我的 Flask API 代码片段:

This is the snippet of my Flask API code:

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')

是否可以在 cursor.execute 行中添加任何重试逻辑?我不知道如何使用 python 处理瞬时错误.请帮忙.

Is there any retry logic I can add on the cursor.execute line? I've no idea how to deal with transient errors with python. Please help.

推荐答案

根据我的经验,我觉得可能你可以尝试使用下面的代码来实现重试逻辑.

Per my experience, I think may be you can try to use the code below to implement the retry logic.

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)

希望有帮助.

这篇关于pyodbc:如何重试从瞬态错误中恢复?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!

本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!

相关文档推荐

Execute complex raw SQL query in EF6(在EF6中执行复杂的原始SQL查询)
Flask + PyMySQL giving error no attribute #39;settimeout#39;(FlASK+PyMySQL给出错误,没有属性#39;setTimeout#39;)
SSIS: Model design issue causing duplications - can two fact tables be connected?(SSIS:模型设计问题导致重复-两个事实表可以连接吗?)
SQL Server Graph Database - shortest path using multiple edge types(SQL Server图形数据库-使用多种边类型的最短路径)
Invalid column name when using EF Core filtered includes(使用EF核心过滤包括时无效的列名)
How should make faster SQL Server filtering procedure with many parameters(如何让多参数的SQL Server过滤程序更快)