1

我有以下 Sanic 路线：

md = Markdown()

@app.route('/md_file')
async def md_file(request):
    async with aiofiles.open('./file.md')) as f:
        content = await f.read()

    content = md.convert(content)
    return html(content)

这工作得很好，但转换需要很长时间并阻塞端点。基准测试时，端点每秒只能处理 4 个请求。

由于没有 asyncio markdown 库，我想我会将转换卸载到一个单独的线程中以释放阻塞代码：

loop = asyncio.get_event_loop()
content = await loop.run_in_executor(ThreadPoolExecutor(), md.convert(content))

但是，这会引发回溯：

2017-07-22 12:02:24 - (sanic)[ERROR]: Traceback (most recent call last):
  File "/home/user/app/venv/lib64/python3.5/site-packages/sanic/app.py", line 471, in handle_request
    response = await response
  File "app.py", line 127, in blog_posts
    content = await loop.run_in_executor(ThreadPoolExecutor(), md.convert(content))
  File "uvloop/future.pyx", line 241, in __await__ (uvloop/loop.c:110786)
  File "uvloop/future.pyx", line 432, in uvloop.loop.BaseTask._fast_wakeup (uvloop/loop.c:113980)
  File "uvloop/future.pyx", line 101, in uvloop.loop.BaseFuture._result_impl (uvloop/loop.c:108900)
  File "/opt/rh/rh-python35/root/usr/lib64/python3.5/concurrent/futures/thread.py", line 55, in run
    result = self.fn(*self.args, **self.kwargs)
TypeError: 'str' object is not callable

不能在 Sanic 中使用事件循环吗？是否有任何其他选项可以使转换成为非阻塞？

4

1 回答 1

2

md.convert(content) 实际运行函数。这：

content = await loop.run_in_executor(ThreadPoolExecutor(), md.convert(content))

与此相同：

content = await loop.run_in_executor(ThreadPoolExecutor(), "some HTML")

这显然是错误的。您不想运行该功能。你想传递函数；执行者将处理运行它。的签名run_in_executor是

coroutine AbstractEventLoop.run_in_executor(executor, func, *args)

所以改用这个

content = await loop.run_in_executor(ThreadPoolExecutor(), md.convert, content)
于 2017-07-22T11:43:49.423 回答