我有以下代码:

import sqlite3
from flask import Flask

app = Flask(__name__)
db = sqlite3.connect('/etc/db.sqlite')

@app.route('/')
def handle():
    # run a query and return a response

if __name__ == '__main__':
    app.run('0.0.0.0', 8080, debug=True)

但是,当我尝试在请求处理程序中对数据库对象执行某些操作时,我从 sqlite3 收到以下异常,因为它不是线程安全库,并且查询是从 Flask 生成的不同线程运行的,而不是从主线程:
sqlite3.ProgrammingError: SQLite objects created in a thread can only be used in that same thread.The object was created in thread id 139886422697792 and this is thread id 139886332843776

我知道执行此操作的“正确”方法是使用一个函数来创建 sqlite3.Connection 对象的实例并将其存储在 Flask g 全局中,如下所述: http://flask.pocoo.org/docs/1.0/patterns/sqlite3/ 。但是,在生产环境中运行此应用程序时,我使用 gunicorn -w 4 -b 0.0.0.0:8080 app:app ,它运行良好,因为在这种情况下,线程是在开始时产生的。

虽然 Flask g 全局方法适用于所有情况,但我真的希望避免每次请求时创建和销毁 sqlite3.Connection 对象的开销。所以,我想在 Flask 中禁用线程,以便上面的代码可以运行而不会引起问题。

但是,即使将上述代码的最后一行更改为 app.run(..., threaded=False) ,也无法避免此错误。似乎 Flask 仍然会产生一个线程来处理请求。

那么,如何使用 Flask 禁用线程?

最佳答案

不要直接在 flask 中使用 sqlite3 模块。使用 Flask_sqlalchemy如果没有它,我在尝试在 sqlite 上设置数据库时遇到了很多麻烦。一旦我进行了切换,它就变得容易多了。您也可以连接到多种类型的 SQL 数据库!

flask sqlalchemy:

http://flask-sqlalchemy.pocoo.org/2.3/

真的是 flask 的最佳指南:

https://blog.miguelgrinberg.com/post/the-flask-mega-tutorial-part-iv-database

关于python - 如何在 Flask 中禁用线程?,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/52429434/

10-16 12:22