为啥这段 Python 代码在无法连接 OBS 软件时需要 2 分钟才能退出？

Posted 2023-02-16

【中文标题】为啥这段 Python 代码在无法连接 OBS 软件时需要 2 分钟才能退出？

【英文标题】：Why does this Python code take 2 minutes to exit when it cannot connect to OBS software?为什么这段 Python 代码在无法连接 OBS 软件时需要 2 分钟才能退出？

【发布时间】：2018-09-29 20:15:56

【问题描述】：

我是 Python 新手，对 asyncio 了解不多。我想运行这个脚本，如果它试图在 10.11.0.124 上连接的 OBS 软件没有运行以退出代码。代码执行此操作，但需要 2 分钟才能退出。我不明白为什么当它无法连接到不在 10.11.0.124 上运行的 OBS 软件时它没有立即退出。

#! /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()

【参考方案1】：

OBSWS 函数的超时时间为 2 分钟，因为它在内部使用 websockets 模块，并且默认超时时间为 2 分钟。

详细分类：

async with OBSWS(...): 调用OBSWS.__init__ 然后awaits OBSWS.__aenter__。 OBSWS.__init__ 没有做任何有趣的事情，但是 OBSWS.__aenter__ awaits OBSWS.connect OBSWS.connectawaitswebsocket.connect. websockets.connect 有几个通过关键字参数定义的不同超时。它还等待多种事情。这些都是： self._creating_connection, defined here 这使用loop.create_connection，默认情况下有

60秒超时

。 然后它调用factory 调用create_protocol 哪个defaults to klass 哪个defaults to WebSocketClientProtocol，哪个子类WebSocketCommonProtocol 这可能不会增加任何进一步的延迟。 protocol.handshake(...) protocol.fail_connection() 在引发任何异常的情况下，这确实发生了。

我不明白asyncio 所以我就停在这里；某处可能还有 60 秒的延迟，但如果不是……也许计算机速度很慢。

【讨论】：

有什么办法可以减少这个超时时间？

@ChadGray 您可以使用asyncio.wait_for 强制任何异步任务超时。

@ChadGray 我不知道你是否可以使用with 语法来做到这一点，但如果你用this version 替换它，将await obsws.connect() 行包装在asyncio.wait_for 中并捕获超时错误（在asyncio 中定义，不记得叫什么了）它会起作用。

@ChadGray 将整个async with OBWS(...): ... 移动到一个单独的async def xxx(): ... 中，并从main() 作为await asyncio.wait_for(xxx(), 1) 调用它。这将使xxx() 有1 秒的时间运行，否则它将被取消，您将获得asyncio.TimeoutError（您可以捕捉到）。有关示例，请参见 the documentation。

@ChadGray 将其作为答案发布；请不要将其编辑到您的问题中。

【参考方案2】：

感谢 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()

【讨论】：

如果finally 中有except 子句，则不需要obsws.close()。无论是否发生异常，finally 都会执行。

@user4815162342 谢谢！我需要开始阅读更多关于 python 的内容。这是一种与我习惯不同的语言。

阅读总是一个好主意，但 Python 中的 finally 与其他语言（例如 Java）中的工作方式相同。 :)