如何在python Flask（而不是Django）上完成芹菜工作后重定向

Question

我有意的完整代码是一个网站从youtube视频获取并转换成mp3，保存到S3，然后将S3链接返回给用户。在

因为我想在低性能的EC2上使用（省钱），而且也不阻止很多人同时使用它，所以我使用celeri来异步执行。在

在芹菜完成工作后，我可以执行回调函数。但是它只显示在终端上，我如何（显示它来替换）重定向等待屏幕？在

from flask import Flask, render_template, request
from celery import Celery
import youtube_dl

app = Flask(__name__)
app.config['CELERY_BROKER_URL'] = 'redis://:password@redis-YYYY.cloud.redislabs.com:YYYY/0'
app.config['CELERY_RESULT_BACKEND'] = 'redis://:password@redis-YYYY.cloud.redislabs.com:YYYY/0'

celery = Celery(app.name, broker=app.config['CELERY_BROKER_URL'])
celery.conf.update(app.config)


def done_download_hook(d):
    if d['status'] == 'finished':
        print('Done downloading, now converting ...')


ydl_opts = {
    'format': 'bestaudio/best',
    'outtmpl': '%(id)s.%(ext)s',
    'postprocessors': [{
        'key': 'FFmpegExtractAudio',
        'preferredcodec': 'mp3',
        'preferredquality': '192',
    }],
    'progress_hooks': [done_download_hook],
}


@celery.task(bind=True)
def download_task(self, link, ydl_opts):
    # some long running task here
    with youtube_dl.YoutubeDL(ydl_opts) as ydl:
        ydl.download([link])
    # and copy converted file to S3, return/get S3 link
    # I could handle the process from EC2 to S3.

@app.route('/')
def my_form():
    return render_template('hello.html')

# I try some decorators @app.XXXXX but no success.
def test_callback():
    print('it worked and run until here')
    # should redirect user to S3 link, or redirect the page with link to click
    # How can I do that ?
    return 'http://...'


@app.route('/', methods=['POST'])
def my_form_post():
    download_link = request.form['text']
    # download_task.delay(download_link, ydl_opts)
    download_task.apply_async((download_link, ydl_opts),link=test_callback())
    return "please waiting, after done converting, we would redirect you to the link"

Answer 1

因为celery运行一个单独的进程（或者多个，如果你运行celery的多个实例），并且你选择让体验异步，以确定任务何时完成，浏览器上的一个页面将不得不轮询（即通过AJAX）。这意味着它需要一些可以用来查询任务状态/结果的id。最简单的id是在.delay()执行任务时返回的对象。在呈现页面时将其传递给您，以便可以进行AJAX调用。在

然后处理调用的view方法将执行如下操作

from celery.result import AsyncResult

@app.route('/taskstatus')
def taskstatus(uuid):
    result = AsyncResult(uuid)
    return HttpResponse(json.dumps({'done': result.ready()}),
                        content_type='application/json')

当页面看到done: true时，它可以做任何事情（重定向、更改元素的文本或颜色…）