0

Как я могу реализовать асинхронную отправку ответов на пинг запросы чтобы они не зависели от отправки основных запросов?

Из документации по работе с этим вебсокетом:

В приведенном ниже коде я пытался сделать ввод из консоли, чтобы как только я введу в консоль "LG" он отправит запрос на аутентификацию, но сервер не дает этого сделать. Т.к. input блокирующий оператор, я пропускаю пинг запросы и соответственно не могу на них ответить. Как я могу на них отвечать параллельно независимо от моих собственных запросов к серверу?

import websockets
import asyncio
import json


async def main():
    url = 'wss://***'
    async with websockets.connect(url) as ws:
        while True:
            command_counter += 1
            recv = await ws.recv()
            response = json.loads(recv)
            print(f'{command_counter} RECV: {response}')

            if response['Type'] == 1:
                msg = response['Msg']
                data = {
                    "Type": 2,
                    "Msg": msg
                }
                print(f"{command_counter} SEND: {data}")
                await ws.send(json.dumps(data))

            command = input('>>> ')

            if command == 'LG':
                data = {
                    "RequestId": 2,
                    "OriginalRequestId": 2,
                    "RequestType": "LoginRequest",
                    "Message": {
                        "UserName": "***",
                        "Password": "***"
                    }
                }
                print(f"{command_counter} SEND: {data}")
                await ws.send(json.dumps(data))


asyncio.get_event_loop().run_until_complete(main())
7
  • 1
  • просто не блокируй инпут и будет тебе счастье
    – eri
    2 июн 2021 в 23:33
  • @eri да вроде бы специально не блокирую
    – RoyalGoose
    3 июн 2021 в 8:58
  • @RoyalGoose тут же написал input - вот и заблокировался
    – eri
    3 июн 2021 в 9:23
  • 1
    @RoyalGoose или в потоке отдельном +asyncio.Queue
    – eri
    3 июн 2021 в 10:53

1 ответ 1

0

Для асинхронного ввода используется библиотека aioconsole

Пример: line = await aioconsole.ainput('Ввод >>>')

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.