"coroutine 'listen' was never awaited" — Как исправить?

Question

[Closename]

Есть сайт с финансовой информацией, которая может обновляться несколько раз в секунду.
Взаимодействие с сайтом происходит через websocket. API сайт не предоставляет.
Хочу написать программу на python, которая бы читала информацию из websocket с этого сайта.

Нашёл один ролик на ютубе, но он не помог: https://youtu.be/tgtb9iucOts.
Много раз перепроверил - ошибок нет.

import websockets
import asyncio

async def listen():
    url = "ws://simple-websocket-server-echo.glitch.me/"

    async with websockets.connect(url) as ws:
        while True:
            msg = await ws.recv()
            print(msg) 

asyncio.get_event_loop().run_until_complete
(listen())

Не понятно, почему пишем

url = "ws://simple-websocket-server-echo. glitch.me/"

.
А в ролике взаимодействие идёт с сайтом: "sync-chasing-ball.glitch.me"
И не понятно, почему надо (listen()) с новой строки писать, иначе не компилируется с ошибкой:

partially initialized module 'websockets' from 'program.py' has no attribute 'connect' (most likely due to a circular import)

Comments

[Алан Гибизов]

Мне кажется, в url не должно быть пробела после точки.

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

У вас случайно файла websockets.py в том же каталоге не лежит?

[Влад Григорьев]

Много раз перепроверил - ошибок нет.

- сильное утверждение

Для начала надо подтянуть базовые знания по питону, а не пытаться угадывать
должно быть

asyncio.get_event_loop().run_until_complete(listen())

а правильнее уже

if __name__ == '__main__':
    asyncio.run(listen())

С ошибками надо разбираться а не избегать их

[Closename]

Сергей Горностаев, в директории с программой создано виртуальное окружение (папка venv) и выбран интерпретатор в VScode (venv\Scripts\python.exe).
Скопировал websockets.py из вложенной директории venv\Lib\site-packages в корневую с программой и заработало. Спасибо.
Но понятнее мне не стало, к сожалению :(
Неправильно я создал окружение или должен свою программу в папку site-packages "пихать"?

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

Closename, судя по ошибке, ваш скрипт импортировал не библиотечный модуль websockets, а какой-то посторонний скрипт.

[Closename]

Сергей Горностаев, моя программа тоже же называется websocket.py
Поэтому она себя и импортировала. Я сейчас пробовал переименовать/удалить websockets.py и видел что снова и снова эта программа появлялась в папке. Потом понял в чём дело)

Answer 1

[Константин Фещук]

import websockets
import asyncio
import logging

# Настройка логирования
logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(levelname)s - %(message)s')

async def listen():
    url = "ws://simple-websocket-server-echo.glitch.me/"
    
    logging.info("Подключение к серверу WebSocket...")
    async with websockets.connect(url) as ws:
        logging.info("Успешно подключено к серверу.")
        
        while True:
            msg = await ws.recv()  # Ожидаем получение сообщения
            logging.info(f"Получено сообщение: {msg}")  # Логируем сообщение

async def main():
    # Создание задачи для прослушивания
    listener_task = asyncio.create_task(listen())
    
    # Здесь вы можете добавить другие задачи параллельно, если необходимо
    await listener_task  # Ожидаем завершения задачи, чтобы программа не завершилась

# Запуск основной функции
asyncio.run(main())