비동기를 지원하지 않는 라이브러리로 작업하는 방법은 무엇입니까?

Question

플라스크에서 aiohttp로 이동 중이며 비동기를 지원하지 않는 Oracle 데이터베이스에서 일부 쿼리를 실행해야합니다. 그래서 어떻게 그 일을 할 수 있는지 궁금하네요?

어때요?

http://pastebin.com/nbWABbvK

또는 그렇게 다른 (오른쪽) 방법이?

미리 감사드립니다.

Answer 1

loop.run_in_executor 코 루틴은 정확히 작업을 수행합니다

result = await loop.run_in_executor(executor, sync_fn, *args) 

귀하의 예제를 사용 :

executor = ThreadPoolExecutor(max_workers=1) 

async def hello(request): 
    param1, param2 = get_params(request) 
    result = await app.loop.run_in_executor(executor, sync_fn, param1, param2) 
    return web.Response(text=result)