带有烧瓶和烧瓶的芹菜无法更新数据库记录

Question

我正在使用Flask和Flask-SQLAlchemy创建一个后台芹菜任务来更新数据库记录的属性。我正在使用推荐的芹菜配置文档，这是我代码的简化版本：

from flask import Flask
from celery import Celery
def make_celery(app):
celery = Celery(app.import_name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)
TaskBase = celery.Task
class ContextTask(TaskBase):
abstract = True
def __call__(self, *args, **kwargs):
with app.app_context():
return TaskBase.__call__(self, *args, **kwargs)
celery.Task = ContextTask
return celery

app = Flask(__name__)
celery = make_celery(app)
class Stuff(db.Model):
id = db.Column(db.Integer, primary_key=True)
processed = db.Column(db.Boolean)

@celery.task()
def process_stuff(stuff_id):
stuff = Stuff.query.get(stuff_id)
print("stuff.processed 1: {}".format(stuff.processed))
stuff.processed = True
print("stuff.processed 2: {}".format(stuff.processed))
db.session.add(stuff)
db.session.commit()
print("stuff.processed 3: {}".format(stuff.processed))
@app.route("/process_stuff/<id>")
def do_process_stuff(id):
stuff = Stuff.query.get_or_404(id)
process_stuff.delay(stuff.id)
return redirect(url_for("now_wait"))

这是打印语句的输出：

[2017-07-11 07:32:01,281: WARNING/PoolWorker-4] stuff.processed 1: False
[2017-07-11 07:32:01,282: WARNING/PoolWorker-4] stuff.processed 2: False
[2017-07-11 07:32:01,285: WARNING/PoolWorker-4] stuff.processed 3: False

我可以在我的芹菜工作日志中看到该任务正在被拾取并完成; 但是，print 语句显示stuff.processed属性始终为 False - 即使我手动更新它，print 语句也永远不会显示 True(我已经在芹菜之外对此进行了测试，我可以很好地更新属性(。

这里有一个非常相似的问题，但该解决方案不适用于我的情况

库版本

• 烧瓶 0.12.2
• SQLAlchemy 1.1.11
• 芹菜 4.0.2
• Flask-SQLAlchemy 2.2

更新

其他测试表明我可以创建新创建的对象并将其保存到数据库 - 更新预先存在的对象继续失败。

Answer 1

在我的问题中，我大大简化了代码，这样做时我将reserved属性更改为processed。我的实际模型看起来更像这样：

class Stuff(db.Model):
id = db.Column(db.Integer, primary_key=True)
reserved = db.Column(db.Boolean)

事实证明，保留是芹菜中的一个函数，这就是为什么无法从我的芹菜任务更新该属性的原因。解决方案是重命名模型上的reserved属性。