Flask炼金术什么都不做

Question

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

在应用程序副本在

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)

在数据库在

^{pr2}$

在项目.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()

在项目.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似乎指向了您的flask应用程序。在

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

5000是flask应用程序的默认端口。在

5432是postgres的默认端口。在

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

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

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

请参阅this answer，它指出使用flask development server和默认选项一次只能处理一个请求。在