asyncio.create_subprocess_shell 错误：从未检索到未来异常 - BrokenPipeError

如何解决asyncio.create_subprocess_shell 错误：从未检索到未来异常 - BrokenPipeError

每当我将 asyncio.create_subprocess_shell() 与 sp.communicate() 结合使用时，我都会在程序结束时收到此错误。

如果我使用 asyncio 运行多个 suprocesses，则会在最后为每个进程打印错误。

虽然它不影响我的程序，但我想找到源并解决问题。感谢您的帮助！

追溯：

Future exception was never retrieved
future: <Future finished exception=brokenPipeError(32,'The pipe has been ended',None,109,None)>
Traceback (most recent call last):
  File "C:\Users\user\AppData\Local\Programs\Python\python39\lib\asyncio\subprocess.py",line 153,in _Feed_stdin
    await self.stdin.drain()
  File "C:\Users\user\AppData\Local\Programs\Python\python39\lib\asyncio\streams.py",line 387,in drain
    await self._protocol._drain_helper()
  File "C:\Users\user\AppData\Local\Programs\Python\python39\lib\asyncio\streams.py",line 197,in _drain_helper
    await waiter
  File "C:\Users\user\AppData\Local\Programs\Python\python39\lib\asyncio\proactor_events.py",line 379,in _loop_writing
    f.result()
  File "C:\Users\user\AppData\Local\Programs\Python\python39\lib\asyncio\windows_events.py",line 812,in _poll
    value = callback(transferred,key,ov)
  File "C:\Users\user\AppData\Local\Programs\Python\python39\lib\asyncio\windows_events.py",line 538,in finish_send
    return ov.getresult()
brokenPipeError: [WinError 109] The pipe has been ended

代码：

async def get(cs,url):
    async with cs.get(url) as r:
        b = b''
        while True:
            chunk = await r.content.read(4000000)
            b += chunk
            if not chunk:
                break
        
        if int(r.headers['content-length']) < 8000000:
            result = BytesIO(b)
            return [result,'full']
        else:
            command = f"ffmpeg -y -i - -c:v copy -fs 8000000 -f matroska -"
            sp = await asyncio.create_subprocess_shell(command,stdin=asyncio.subprocess.PIPE,stdout=asyncio.subprocess.PIPE,stderr=asyncio.subprocess.PIPE)
            stdout,stderr = await sp.communicate(b)
            sp.wait()

            print(stderr.decode())
            print(len(stdout))
            output = str(stderr)
            index_d = output.find('Duration: ')
            index_t = output.rfind('time=')
            duration = await get_sec(output[index_d + 10:].split(",")[0])
            time_ = await get_sec(output[index_t + 5:].split(" ")[0])
            percentage = f"{round((time_ / duration) * 100)}%"

            result = BytesIO(stdout)
            return [result,'preview',percentage]

async def main(urls):
    async with aiohttp.ClientSession() as cs:
            
        tasks = []
        for url in urls:
            task = asyncio.create_task(get(cs,url))
            tasks.append(task)
        
        results = []
        for task in tasks:
            result = await task
            results.append(result)
        
        return results

loop = asyncio.get_event_loop()
results = loop.run_until_complete(main(urls))