Почему этот код Python завершается за 2 минуты, когда он не может подключиться к программному обеспечению OBS?

Question

Я новичок в Python, и я не знаю много об asyncio.Я хочу запустить этот сценарий, и если программное обеспечение OBS, к которому оно пытается подключиться 10.11.0.124, не работает для выхода из кода.Код делает это, но для выхода требуется 2 минуты.Я не могу понять, почему он не завершает работу немедленно, когда не может подключиться к программному обеспечению OBS, которое не работает на 10.11.0.124.

#! /usr/bin/python3

import asyncio
import urllib.request
import sys 
import datetime

from obswsrc import OBSWS
from obswsrc.requests import StartStopStreamingRequest

def logger(logmessage):
    f = open("log.txt", "a")
    f.write(str(datetime.datetime.now()) + " " + logmessage + "\n")
    f.close

async def main():

   try:
        async with OBSWS('10.11.0.124', 4444, "password") as obsws:

            logger("Connection established.")

            while True:

                event = await obsws.event()

                logger(str(format(event.type_name)))

                if(format(event.type_name) == "StreamStarting"):
                    HitURLToLoadAsset = urllib.request.urlopen("http://10.11.0.159/api/v1/assets/control/asset&b0983c0918b94856900040d9a9e8bdbf").read()
                    logger(str(HitURLToLoadAsset))

                if(format(event.type_name) == "StreamStopped"):
                    HitURLToLoadAsset = urllib.request.urlopen("http://10.11.0.159/api/v1/assets/control/asset&3b2fb67002364b269d0c2674a628533c").read()
                    logger(str(HitURLToLoadAsset))

            logger("Connection terminated.")

    except OSError:
        logger("OBS IS NOT RUNNING")

    except:
        logger(str(sys.exc_info()[1]))


loop = asyncio.get_event_loop()
loop.run_until_complete(main())
loop.close()

Answer 1

Спасибо за помощь user4815162342 и wizzwizz4!Вот мое окончательное решение.

Я закончил тем, что согласился с предложением wizzwizz4 разорвать строку подключения, чтобы я мог использовать asyncio.wait_for для него.

Если кому-то все равно, сам код должен смотреть OBS и когда начинается потоковая передачаперейдите изменить актив на Screenly OSE для отображения потока RTMP.Когда потоковая передача остановлена, переключитесь на другой ресурс в Screenly OSE.

#! /usr/bin/python3

import asyncio
import urllib.request
import sys
import datetime

from obswsrc import OBSWS
from obswsrc.requests import StartStopStreamingRequest

def logger(logmessage):
    f = open("log.txt", "a")
    f.write(str(datetime.datetime.now()) + " " + logmessage + "\n")
    f.close


async def main():

    try:
        obsws = OBSWS('10.11.0.124', 4444, "password")
        # if no response from OBS in 30 seconds EXIT
        await asyncio.wait_for(obsws.connect(), timeout=30)

        logger("Connection established.")

        while True:

            event = await obsws.event()

            logger(str(format(event.type_name)))

            if(format(event.type_name) == "StreamStarting"):
                HitURLToLoadAsset = urllib.request.urlopen("http://10.11.0.159/api/v1/assets/control/asset&b0983c0918b94856900040d9a9e8bdbf").read()
                logger(str(HitURLToLoadAsset))

            if(format(event.type_name) == "StreamStopped"):
                HitURLToLoadAsset = urllib.request.urlopen("http://10.11.0.159/api/v1/assets/control/asset&3b2fb67002364b269d0c2674a628533c").read()
                logger(str(HitURLToLoadAsset))

    except asyncio.TimeoutError:
        logger("OBS NOT RUNNING-- TIMEOUT!")

    except OSError:
        logger("OBS IS NOT RUNNING")

    except:
        logger(str(sys.exc_info()[1]))

    finally:
        await obsws.close()
        logger("Connection terminated.")



loop = asyncio.get_event_loop()  
loop.run_until_complete(main())
loop.close()

Answer 2

Функция OBSWS имеет тайм-аут в две минуты, поскольку она использует модуль websockets для внутреннего использования и имеет тайм-аут по умолчанию, равный двум минутам.

Подробная разбивка:

• async with OBSWS(...): звонки OBSWS.__init__, а затем await s OBSWS.__aenter__.
• OBSWS.__init__ ничего интересного не делает, но OBSWS.__aenter__ await с OBSWS.connect
• OBSWS.connect await с websocket.connect.
• websockets.connect имеет несколько различных таймаутов, определенных с помощью аргументов ключевых слов.Он также ждет нескольких вещей.Это:
  • self._creating_connection, определено здесь
    • При этом используется loop.create_connection с 60 секунд по умолчанию .
    • Затем он вызывает factory, который вызывает create_protocol, который по умолчанию равен klass, который по умолчанию равен WebSocketClientProtocol, которые подклассы WebSocketCommonProtocol, что, вероятно, не добавляет дальнейших задержек.
  • protocol.handshake(...)
  • protocol.fail_connection() в случае возникновения какого-либо исключения, которое имеет место.

Донне понимаю asyncio, поэтому я просто остановился здесь;возможно, где-то еще 60 секунд задержки, но если нет ... возможно, компьютер просто работал медленно.