Flask asyncio 异步处理请求

from flask import Flask, jsonify, has_request_context, copy_current_request_context, requestfrom functools import wrapsfrom concurrent.futures import Future, ThreadPoolExecutorimport asyncio def run_async(func):    @wraps(func)    def _wrapper(*args, **kwargs):        call_result = Future()        def _run():            loop = asyncio.new_event_loop()            try:                result = loop.run_until_complete(func(*args, **kwargs))            except Exception as error:                call_result.set_exception(error)            else:                call_result.set_result(result)            finally:                loop.close()         loop_executor = ThreadPoolExecutor(max_workers=1)        if has_request_context():            _run = copy_current_request_context(_run)        loop_future = loop_executor.submit(_run)        loop_future.result()        return call_result.result()     return _wrapper   @app.route("/process/report/success/", methods=["POST"])@run_asyncasync def report_result_success():    account = request.json    print(request.json)    debug('>> 注册成功: ' + str(account))    write_csv(account, '成功.csv')    return Result.ok()