Как запустить Websocket паралельно с ботом телеграм aiogram?

Question

[cartiology]

У меня возникла ошибка при попытке скрестить паралельно WebSocket и телеграм бота написанный на Aiogram. У меня была жалкая попытка сделать всё через threading, но ожидаемо ничего не сработало. Вот код который должен запускать оба процесса:

if __name__ == '__main__':
    #бот
    executor.start_polling(dp, skip_updates=True)
    #websocket
    event_loop = asyncio.get_event_loop()
    event_loop.run_until_complete(start_server())
    event_loop.run_forever()

Насколько я могу предпологать это происходит потому что оба процесса после запуска не оканчиваются и действуют далее, по этой причине код не доходит до запуска и прослушивания сокета

Ниже код сокета

async def new_client_connected(client_socket,path):
  print("New Client")
  while True:
    new_message = await client_socket.recv()
    print(new_message)

async def start_server():
  print("Server Started")
  await websockets.serve(new_client_connected, "localhost",1234)

А тут инициализация бота

bot = Bot(token=TOKEN)
storage = MemoryStorage()
dp = Dispatcher(bot=bot, storage=storage)
logging.basicConfig(level=logging.INFO)

Answer 1

[AlbertForest]

async def start_bot():
    event_loop.create_task(dp.start_polling())
    
if __name__ == '__main__':
    event_loop = asyncio.get_event_loop()
    event_loop.run_until_complete(start_server())
    event_loop.run_until_complete(start_bot())
    event_loop.run_forever()

Comments

[cartiology]

Что то не то

Server Started
Traceback (most recent call last):
  File "C:\Users\babal\Desktop\telegramBot\truebot.py", line 296, in <module>
    event_loop.run_until_complete(start_server())
  File "C:\Users\babal\AppData\Local\Programs\Python\Python310\lib\asyncio\base_events.py", line 646, in run_until_complete
    return future.result()
  File "C:\Users\babal\Desktop\telegramBot\truebot.py", line 261, in start_server
    await websockets.serve(new_client_connected, "localhost",1234)
  File "C:\Users\babal\Desktop\telegramBot\venv\lib\site-packages\websockets\legacy\server.py", line 1117, in __await_impl__
    server = await self._create_server()
  File "C:\Users\babal\AppData\Local\Programs\Python\Python310\lib\asyncio\base_events.py", line 1505, in create_server
    raise OSError(err.errno, 'error while attempting '
OSError: [Errno 10048] error while attempting to bind on address ('127.0.0.1', 1234): обычно разрешается только одно использование адреса сокета (протокол/сетевой адрес/порт)

я где то уже использую порт или что

[cartiology]

cartiology, всё верно, я поменял порт на 80 и вроде всё гуд, спасибо!

[AlbertForest]

cartiology, Где то запущенный сервер не закрыл

[AlbertForest]

cartiology, Отмечай решением тогда))