在Flask中进行异步任务

在Flask中进行异步任务

我将使用Celery为你处理异步任务。你需要安装代理以充当任务队列（建议使用RabbitMQ和Redis）。

app.py：

from flask import Flaskfrom celery import Celerybroker_url = 'amqp://guest@localhost'          # Broker URL for RabbitMQ task queueapp = Flask(__name__)    celery = Celery(app.name, broker=broker_url)celery.config_from_object('celeryconfig')      # Your celery configurations in a celeryconfig.py@celery.task(bind=True)def some_long_task(self, x, y):    # Do some long task    ...@app.route('/render/<id>', methods=['POST'])def render_script(id=None):    ...    data = json.loads(request.data)    text_list = data.get('text_list')    final_file = audio_class.render_audio(data=text_list)    some_long_task.delay(x, y)      # Call your async task and pass whatever necessary variables    return Response(        mimetype='application/json',        status=200    )

运行你的Flask应用，然后启动另一个过程来运行你的Celery工作者。

$ celery worker -A app.celery --loglevel=debug