python Невозможно получить возвращаемые значения из асинхронной функции, используя HTTP-запросы - PullRequest
Новая
       40

python Невозможно получить возвращаемые значения из асинхронной функции, используя HTTP-запросы

0 голосов
/ 27 сентября 2019

Я пытаюсь переписать мое приложение фляги на FastAPI, которое использует uvloop в качестве базы.Когда я выполняю код без маршрутов, я не вижу проблем и выполняется как ожидалось.Но выдает ошибку после того, как я добавляю маршруты и нажимаю на запрос с помощью Почтальона. 

> INFO: ('172.17.0.1', 42352) - "GET /api/v1/getpass HTTP/1.1" 500
> ERROR: Exception in ASGI application Traceback (most recent call
> last):   File
> "/usr/local/lib/python3.6/site-packages/uvicorn/protocols/http/httptools_impl.py",
> line 375, in run_asgi
>     result = await app(self.scope, self.receive, self.send)   File "/usr/local/lib/python3.6/site-packages/starlette/applications.py",
> line 133, in __call__
>     await self.error_middleware(scope, receive, send)   File "/usr/local/lib/python3.6/site-packages/starlette/middleware/errors.py",
> line 177, in __call__
>     raise exc from None   File "/usr/local/lib/python3.6/site-packages/starlette/middleware/errors.py",
> line 155, in __call__
>     await self.app(scope, receive, _send)   File "/usr/local/lib/python3.6/site-packages/starlette/exceptions.py", line
> 73, in __call__
>     raise exc from None   File "/usr/local/lib/python3.6/site-packages/starlette/exceptions.py", line
> 62, in __call__
>     await self.app(scope, receive, sender)   File "/usr/local/lib/python3.6/site-packages/starlette/routing.py", line
> 590, in __call__
>     await route(scope, receive, send)   File "/usr/local/lib/python3.6/site-packages/starlette/routing.py", line
> 208, in __call__
>     await self.app(scope, receive, send)   File "/usr/local/lib/python3.6/site-packages/starlette/routing.py", line
> 41, in app
>     response = await func(request)   File "/usr/local/lib/python3.6/site-packages/fastapi/routing.py", line 111,
> in app
>     raw_response = await dependant.call(**values)   File "./iowait.py", line 51, in get_pvt
>     print(kpair) UnboundLocalError: local variable 'kpair' referenced before assignment

Мой код: 

import random
import asyncio as aio

from fastapi import FastAPI
from pydantic import BaseModel


get_id = '/api/v1/getid'
get_pass = '/api/v1/getpass'
app = FastAPI()
key_pass_list = [
    {
        'uid' : 'uid1',
        'pass' : 'pass1'
    },
    {
        'uid' : 'uid2',
        'pass' : 'pass2'
    },
    {
        'uid' : 'uid3',
        'pass' : 'pass3'
    },
]
id_list = [_['uid'] for _ in key_pass_list]


class KeyDoc(BaseModel):
    uid : str


async def key_pass(uid):
    for keypair in key_pass_list:
        if keypair['uid'] == uid:
            return keypair
    return {uid: 'Key not Found'}


@app.get(get_pass)
async def get_pvt(key_doc: KeyDoc):
    uid = key_doc.uid
    print('uid :' + uid)

    try:
        myloop = aio.get_event_loop()
        kpair = myloop.run_until_complete(aio.wait([key_pass(uid)]))
        await kpair
    except Exception as err:
        print(err)

    print(kpair)
    return None


@app.get(get_id)
async def get_pub():
    return random.choice(id_list)


@app.get("/")
async def root():
    return {"message": "Test-AIO"}

NOTE
get_idи / маршрут работает в любое время, потому что нет логики, он терпит неудачу с get_pass запросами.
Любая помощь или указатели на это очень ценятся.
Спасибо

...