python - 带后台线程的flask应用程序

Question

我正在创建一个flask应用程序，对于一个请求，我需要运行一些长时间运行的作业，而无需在UI上等待。我将创建一个线程并将消息发送到UI。该线程将计算并更新数据库。但是，UI在提交后会看到一条消息。
下面是我的实现，但是它正在运行线程，然后将输出发送到我不喜欢的UI。如何在后台运行该线程？

@app.route('/someJob')
def index():
    t1 = threading.Thread(target=long_running_job)
    t1.start()
    return 'Scheduled a job'

def long_running_job
    #some long running processing here

如何使线程t1运行后台并立即发送消息作为返回？

Answer 1

对于这种事情，最好的办法是使用消息代理。 python世界中有一些出色的软件可以做到这一点:

celery (http://www.celeryproject.org/)和

RQ(http://python-rq.org/)。

两者都是绝佳的选择。

生成线程几乎不是一个好主意，因为这可能会导致处理传入请求等问题。

如果您查看celery或RQ入门指南，他们将引导您正确地进行操作!