AIOHTTP:无限流,等待时间长

aiohttp: infinite streaming with long wait periods

提问人:Daniel Mühlbachler-P. 提问时间:11/18/2023 最后编辑:Daniel Mühlbachler-P. 更新时间:11/18/2023 访问量:15

问:

我正在尝试连接到一个 REST API,当事件发生时,它将无限地流式传输数据。同时,不会通过 API 发送任何数据。

我有以下代码:

async with self.client_session.get(
  self._url(path),
  headers=self._headers,
  timeout=aiohttp.ClientTimeout(total=0, connect=0, sock_connect=0, sock_read=0),
) as response:
  async for message in response.content:
    # do something

每隔 ~10 分钟,我就会收到来自 的错误。Unexpected exception: ClientPayloadError('Response payload is not completed')aiohttp

有没有可能做到这一点?是的,我还有一段时间可以重新启动整个过程;但是,每 ~10 分钟执行此操作效率不太高。

python-asyncio aiohttp

评论


答: 暂无答案