Как обработать соединение клиентского сокета в asyncio?

Question

[AlexBoss]

День добрый. Во всех мануалах соединение делается через open_connection, но в случае проблем с подключением падает error. Какие есть варианты аналоги socket.connect_ex из стандартной библиотеки, которые возвращают коды?

async def test(message):
    reader, writer = await asyncio.open_connection(
        '127.0.0.1', 8888)

Comments

[javedimka]

asyncio и так дёргает connect_ex проверяет коды и рэйзит соответствующий exception. Тебе остается только интересующий эксепшен ловить

[AlexBoss]

javedimka, где можно список эксепшенов глянуть, пока только ConnectionRefusedError видел. Или проще через except все отсекать?

[javedimka]

AlexBoss, Хрен его знает. Отлавливать можно ConnectionRefused, очевидно asyncio.Timeout, потом, таска может быть отменена, значит asyncio.CancelledError, а всё остальное под одну гребёнку - except Exception

Кстати, про подкапотный connect_ex я тебе наврал.

[AlexBoss]

Кстати, про подкапотный connect_ex я тебе наврал.
javedimka, вот я тоже начал тестить и не похоже) Там много всяких экспевшенов вылетает.

Answer 1

[Руслан]

Можно отлавливать во-первых те исключения, что логично для asyncio, таймаут, отмену.
И дополнительно базовое типа OSError, для возможных проблем с соединением.

Comments

[AlexBoss]

Так и поступил с самого начала. Но по таймауту open_connection не отваливается, пришлось обернуть в wait и поставить таймаут. К тому же в самом open_connection вылетает какая-то ошибка из concurrent.futures, когда невозможно подключится.
Странно другое, что в доке эти моменты не прописаны.