Как реализовать for с использованием Asyncio?

Question

[AlexBoss]

День добрый. Никак не могу понять, как реализовать цикл с использованием Asyncio.
Есть допустим 5 запросов, для которых сначала нужно сделать первый запрос и получить код авторизации, потом с его использованием сделать второй запрос. Хочу чтобы это было реализовано через Asyncio, чтобы не ждать ответов. Как это сделать, подскажите.

Comments

[javedimka]

Как ты собираешься сделать второй запрос не получив ответ на первый?

[AlexBoss]

javedimka, внизу посмотри и поймешь о чем я)

Answer 1

[Сергей Горностаев]

Чтобы дать наиболее правильный ответ, желательно знать детали задачи. Но в наиболее общем случае это решается цепочкой сопрограмм:

async def third_task():
    # Какие-то асинхронные действия
    return something

async def second_task():
    r = await third_task()
    # Какие-то действия с результатом в переменной r
    return processed_r

async def first_task():
    r = await second_task()
    # Какие-то действия с результатом в переменной r

asyncio.run(first_task())

Comments

[AlexBoss]

Прошу прощения, что сразу не написал. Но там уже сам разберусь, спасибо.
Грубо говоря, просто 2 запроса post и get, где мы используем ответ из первого post.
def f1():
r = requests.post(site.ru)
return r.text
def f2(param):
r = requests.post(site.ru, params=param)
return r.text

Единственно, лучше использовать aiohttp или можно обойтись requests?

[Сергей Горностаев]

AlexBoss, не выйдет, библиотека requests синхронная и просто поставит колом цикл событий. Придётся использовать асинхронные библиотеки, вроде aiohttp.

[AlexBoss]

Сергей Горностаев, большое спасибо. Лучше всего по офф доке осваивать или есть нормальный материал?

[Сергей Горностаев]

AlexBoss, официальная документация хорошая - простая и доходчивая.

[AlexBoss]

Сергей Горностаев, спасибо

[AlexBoss]

Сергей Горностаев, прощу прощения еще за один глупый вопрос. Никак не возьму в толк, как организовать на aiohttp данную тему. Как описано выше, мне нужно делать параллельно один и тот же сценарий, который состроит из первого запроса и второго, который использует ответ от первого.

[AlexBoss]

Сергей Горностаев,

async def get_token():
    async with aiohttp.ClientSession() as session:
        async with session.post(site, data=payload, headers=headers, ssl=sslcontext) as resp:
            text = await resp.text()
    return text

async def get_data(number):
    access_token = await get_token()
    async with aiohttp.ClientSession() as session:
        async with session.get(site2, params=payload1, headers=headers1, ssl=sslcontext) as resp:
            text = await resp.text()
            print('{:.70}...{}'.format(text, number))
    return number, text

Хотел спросить, правильно ли я делаю, что 2 раза использую async with aiohttp.ClientSession() as session в каждой функции?

[Сергей Горностаев]

AlexBoss, это допустимо, но лучше сессию передавать из стартовой сопрограммы в вызываемые:

async def get_token(session):
    async with session.post(site, data=payload, headers=headers, ssl=sslcontext) as resp:
        ....

async def get_data(number):
    async with aiohttp.ClientSession() as session:
        access_token = await get_token(session)
        ...

[AlexBoss]

Сергей Горностаев, как раз недавно нашел этот вариант. спасибо)