如何在Python中后台启动Node.js子进程并实时捕获输出

这个问题的核心在于你之前用的subprocess.run本身是同步阻塞的——哪怕把它放进async函数里，它还是会卡住事件循环，导致其他异步任务没法并行执行。咱们换用asyncio原生的异步子进程API就能解决这个问题：

正确的异步实现方案 #

使用asyncio.create_subprocess_exec替代subprocess.run，它会真正异步启动子进程，同时支持捕获标准输出/错误，还不会阻塞事件循环。下面是完整示例：

import asyncio

async def setupServer():
    # 异步启动Node服务，捕获stdout和stderr
    proc = await asyncio.create_subprocess_exec(
        "node", "/path/to/app.js",
        stdout=asyncio.subprocess.PIPE,
        stderr=asyncio.subprocess.PIPE
    )

    # 实时读取并打印输出（可选，根据需求调整）
    async def read_output(stream, stream_name):
        while True:
            line = await stream.readline()
            if not line:
                break
            print(f"[{stream_name}] {line.decode().strip()}")

    # 同时读取stdout和stderr，避免缓冲区阻塞
    await asyncio.gather(
        read_output(proc.stdout, "STDOUT"),
        read_output(proc.stderr, "STDERR")
    )

    # 等待子进程结束（如果需要的话）
    await proc.wait()
    print('Node服务已停止')

async def setupController():
    print('Running other code...')
    # 模拟其他异步任务，比如等待几秒或者处理业务逻辑
    await asyncio.sleep(2)
    print('Other code finished')

async def mainAsync():
    # 并行启动两个任务
    await asyncio.gather(setupServer(), setupController())

asyncio.run(mainAsync())
print('所有任务都已完成')

代码解释 #

• asyncio.create_subprocess_exec：异步启动子进程，返回一个Process对象，不会阻塞事件循环。
• 单独的read_output协程：异步读取子进程的输出流，实时打印（你也可以把输出存入变量，按需处理）。
• asyncio.gather：并行执行setupServer和setupController，两个任务会同时运行，不会互相等待。

执行顺序预期 #

运行这段代码后，你会看到：

1. 立刻输出Running other code...
2. 同时Node服务的输出会实时打印出来
3. 2秒后输出Other code finished
4. 当Node服务停止时，输出Node服务已停止
5. 最后输出所有任务都已完成

这样就完全符合你“启动Node服务后立即执行后续代码，同时捕获所有输出”的需求了。

内容的提问来源于stack exchange，提问作者Nat