Flask-SQLAlchemy 什么都不做

Question

我正在学习使用 Python、Flask 和 SQLAlchemy 构建 API。当我开始将 SQLAlchemy 集成到我的代码中时，任何尝试使用 SQLAchemy 的请求都不会执行任何操作。没有错误代码，它只是坐在那里旋转。这是我的代码的主要部分：

应用程序.py

from flask import Flask
from flask_restful import Api
from flask_jwt import JWT

from security import authenticate, identity
from Resources.user import UserRegister
from Resources.item import Item, ItemList


app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = "postgresql://postgres:mypassword@localhost:5000/mydatabase"
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
app.config['PROPAGATE_EXCEPTIONS'] = True
app.secret_key = 'jose'
api = Api(app)


jwt = JWT(app, authenticate, identity)

api.add_resource(Item, '/item/<string:name>')
api.add_resource(ItemList, '/items')
api.add_resource(UserRegister, '/register')

if __name__ == '__main__':
    from db import db
    db.init_app(app)
    app.run(port = 5000, debug = True)

db.py

from flask_sqlalchemy import SQLAlchemy 

db = SQLAlchemy()

item.py-模型

from db import db

class ItemModel(db.Model):
    __tablename__ = 'parts'

    partid  = db.Column(db.Integer, primary_key = True)
    partdescript = db.Column(db.String(80))
    lastcost = db.Column(db.Float(precision=2))


    def __init__(self, partid, partdescript, _price):
        self.partid = partid
        self.partdescript = partdescript
        self.price = price


    def json(self):
        return {'name': self.partid, 'partdescript': self.partdescript, 'price':self.price}

    @classmethod
    def find_by_name(cls, partid):
        print("find_by_name")
        #print(partid)
        #print(cls.query.filter_by(partid = partid))

        qry = cls.query.filter_by(partid = partid).first()  # this is where it is getting stuck

        return qry

    def save_to_db(self):

        db.session.add(self)
        db.session.commit()


    def delete_from_db(self):
        db.session.delete(self)
        db.session.commit()

item.py-资源

from flask_restful import Resource, reqparse
from flask_jwt import jwt_required
from Models.item import ItemModel

class Item(Resource):
    parser = reqparse.RequestParser()

    parser.add_argument(
        'partdescript',
        type = str,
        required = False,
        help = "This field cannot be left blank!"
    )

    parser.add_argument(
        'lastcost',
        type = float,
        required = True,
        help = "This field cannot be left blank!"
    )

    #@jwt_required()
    def get(self, name):
        #print("get")
        part = ItemModel.find_by_name(name)
        #print(part)

        if part:
            #print("get if statement")
            return part.json(), 201
        return {'message': 'Part not found'}, 404

    @jwt_required()
    def post(self, name): #need to have the parser.add_argument for each field
        if ItemModel.find_by_name(name):
            return {'message': "An item with name '{}' already exists.".format(name)}, 400

        data = Item.parser.parse_args()

        item = ItemModel(name, data['partdescript'], data['lastcost'])

        try:
            item.save_to_db()
        except:
            return {"message": "An error occurred inserting the item."}, 500

        return item.json(), 201

    @jwt_required()
    def delete(self, name):
        item = ItemModel.find_by_name(name)
        if item:
            item.delete_from_db()

        return {'message': 'Item deleted'}

    @jwt_required()
    def put(self, name):
        data = Item.parser.parse_args()

        item = ItemModel.find_by_name(name)
        updated_item = ItemModel(name, "",data['lastcost']) #might need to put item descript in

        if item is None:
            item = ItemModel(name, data['lastcost'])
        else:
            item.lastcost = data['lastcost']

        item.save_to_db()

        return item.json()


class ItemList(Resource):
    @jwt_required()
    def get(self):
        return {'items': [item.json() for item in ItemModel.query.all()]}

如果我只是使用 python 来正确访问我的数据库，那么请求功能就可以了。只有当我尝试使用 SQLAlchemy 时。我得到帮助的人认为这可能是因为我的代码中既有 SQLAlchemy 又有直接访问权限。我将所有内容都转换为 SQLAlchemy，现在所有的请求都只是坐着旋转。我不使用 SQLAlchemy 的旧代码仍然有效。

我尝试过的事情： 重启系统 卸载并重新安装 SQLAlchemy 使用 cURL 而不是 Postman 发送请求 将错误的数据库名称连接起来，看看我是否会收到错误。 以管理员身份运行所有应用程序

我输入了几个打印语句来找出它失败的地方。如果我删除 .first() 或 .all() ，那么我的代码将继续运行，我可以打印查询应该是什么，但这也使得查询根本不会发送。

知道为什么 SQLAchemy 会坐下来旋转吗？

Answer 1

我不确定这是否是代码，但您的数据库连接 URI 似乎指向您的烧瓶应用程序。

app.config['SQLALCHEMY_DATABASE_URI']="postgresql://postgres:mypassword@localhost:5000/mydatabase"

5000 是烧瓶应用的默认端口。

5432 是 postgres 的默认端口。

我的第一个建议是确保您提供给 SQLAlchemy 的连接 URI 是正确的。

当烧瓶应用程序启动时，SQLAlchemy 不会尝试连接到数据库；它只会在执行第一个查询时尝试连接到数据库。

您可能遇到了死锁，您的应用正尝试连接到端口 5000 上的数据库，但端口 5000（您的烧瓶应用）没有响应，因为它当前正忙于尝试连接到数据库。

参见this answer，它指出使用带有默认选项的烧瓶开发服务器一次只能处理一个请求。