python - 在长时间运行的过程中，Flask 会不会对新请求不敏感？

Question

我的 Flask 项目接受订单为 POST来自多个在线商店的请求，将这些订单保存到数据库中，并将购买信息转发给提供产品的服务。有时，产品未在最终服务中设置，并且请求以“未解决”状态存在于我的服务的数据库中。
在最终服务中设置产品时，我想启动一个长时间运行(可能是一分钟)的过程，将所有“未解决”的订单发送到最终服务。在此过程中，Flask 是否仍能从商店接收订单并继续正常处理？如果没有，我是否需要将其卸载到像 rq 这样的任务运行器？ ?
我并不像担心一致性那样担心速度。所购买的商品是现场事件的门票，因此只要在事件开始之前传递订单信息，就不会对客户产生影响。

Answer 1

有几种不同的答案，它们在不同情况下都有效。快速回答是，像 RQ 这样的作业队列通常是正确的解决方案，尤其是从长远来看，随着项目的增长。
只要 WSGI 服务器有可用的工作线程，就可以处理另一个请求。每个工作人员一次处理一个请求。开发服务器使用线程，因此可用的工作线程数量不受限制(受 Python 中线程的性能限制)。像 Gunicorn 这样的生产服务器可以使用多个 worker，以及不同类型的 worker，例如线程、进程或 eventlet。如果您想运行任务以响应 HTTP 请求并等到任务完成发送响应，您将需要足够的工作人员来阻止这些任务以及处理常规请求。

@app.route("/admin/send-purchases")
def send_purchases():
    ...  # do stuff, wait for it to finish
    return "success"

但是，您所描述的任务似乎是一个清理任务，无论来自用户的 HTTP 请求如何，都应该运行。在这种情况下，您应该编写 Flask CLI 命令并使用 cron 或其他调度系统调用它。

@app.cli.command()
def send_purchases():
    ...
    click.echo("done")

# crontab hourly job
0 * * * * env FLASK_APP=myapp /path/to/venv/bin/flask send-purchases

如果您确实希望用户启动任务，但不想阻止等待任务完成的工作人员，那么您需要一个任务队列，例如 RQ 或 Celery。您也可以创建一个提交作业的 CLI 命令，以便能够根据请求和计划触发它。

@rq.job
def send_purchases():
    ...

@app.route("/admin/send-purchases", endpoint="send_purchases")
def send_purchases_view():
    send_purchases.queue()
    return "started"

@app.cli.command("send-purchases")
def send_purchases_command():
    send_purchases.queue()
    click.echo("started")