Как реализовать асинхронный клиент с двумя корутинами?

Question

[Xymis]

Здравствуйте!
Никак не получается реализовать следующую задумку:
Есть две корутины
1. Ждет сообщения от сервера и печатает ответ

async def handler(ws):
        response = await ws.recv()
        print(response)

2. Пингует сервер раз в 3 секунды

async def ping(ws):
        await asyncio.sleep(3)
        await ws.send(b'ping')

async def main():

    loop = asyncio.new_event_loop()

    async with websockets.connect('ws://127.0.0.1:8080/ws') as ws:
        await ws.send('hello'.encode())

        while True:
            await handler(ws)
            await ping(ws)

asyncio.run(main())

Проблема реализации в том, что ping берет весь контроль, и когда я отправляю сообщения handler их не обрабатывает до завершения asyncio.sleep внутри ping

Подскажите, как правильно реализовать такую логику. Заранее спасибо!

Answer 1

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

https://docs.python.org/3/library/asyncio-task.htm...

Comments

[Xymis]

Спасибо, Сергей! Как раз шерстил докуменатцию в этот момент и подумал, что мне это поможет, так что когда вы отправили ответ уже накидал шаблон - вы его подтвердили
Спасибо!

async def handler(ws):
    while True:
        response = await ws.recv()
        print(response)

async def ping(ws):
    while True:
        await asyncio.sleep(10)
        await ws.send(b'ping')


async def main():

    async with websockets.connect('ws://127.0.0.1:8080/ws') as ws:
        await ws.send('hello'.encode())

        await asyncio.gather(
            handler(ws), ping(ws)
        )

asyncio.run(main())