时间戳

首页 > 解决方案 > 从 C++/boost::process 实时获取 Python 输出

python - 从 C++/boost::process 实时获取 Python 输出

问题描述

在 C++ 程序（在 Windows 10 下运行）中，我使用 boost::process 调用 Python 以解释简单的 Python 脚本。我想将 Python 脚本的输出实时重定向到我的 C++ 程序的控制台。

我的问题是当程序完成时我会立即获得整个 Python 脚本输出，我没有实时获得它。

这是我的 MCVE：

Python脚本（script.py）：

import time
from datetime import datetime

print( "Started Python script at t=" + str(datetime.now().time()) )

time.sleep(1)
print( "Slept 1 sec, t=" + str(datetime.now().time()) )
time.sleep(1)
print( "Slept 1 sec, t=" + str(datetime.now().time()) )

print( "Stopped Python script at t=" + str(datetime.now().time()) )

C++ 程序（main.cpp）：

#include <boost/process.hpp>
#include <ctime>
#include <iostream>
#include <chrono>

namespace bp = boost::process;

std::ostream &operator<<(std::ostream &stream, const std::chrono::system_clock::time_point& time_point) 
{
    const auto time {std::chrono::system_clock::to_time_t (time_point)};
    const auto localtime {*std::localtime (&time)};
    const auto time_since_epoch {time_point.time_since_epoch()};
    const auto milliseconds_count {std::chrono::duration_cast<std::chrono::milliseconds> (time_since_epoch).count() % 1000};
    
    stream << "[" << std::put_time (&localtime, "%T") << "." << std::setw (3) << std::setfill ('0') << milliseconds_count << "] - ";
    return stream;
}

int main( int argc, char* argv[] )
{
    std::cout << std::chrono::system_clock::now() << "Creating child" << std::endl;
    bp::ipstream stream;
    bp::child c("python.exe", "script.py", bp::std_out > stream);
    std::cout << std::chrono::system_clock::now() << "Created child" << std::endl;

    std::cout << std::chrono::system_clock::now() << "Invoking getline" << std::endl;
    std::string line;
    while (getline(stream, line)) {
        std::cout << std::chrono::system_clock::now() << "From Python output: " << line << std::endl;
    }
    std::cout << std::chrono::system_clock::now() << "getline ended" << std::endl;

    c.wait();

    return 0;
}

该程序输出：

[12:50:34.684] - 创建子
[12:50:34.706] - 创建子
[12:50:34.708] - 调用 getline
[12:50:36.743] - 从 Python 输出：在 t=12 开始 Python 脚本： 50:34.742105
[12:50:36.745] - 来自 Python 输出：睡眠 1 秒，t=12:50:35.743111
[12:50:36.745] - 来自 Python 输出：睡眠 1 秒，t=12:50:36.743328
[ 12:50:36.746] - 从 Python 输出：在 t=12:50:36.743328
[12:50:36.747] 停止 Python 脚本 - getline 结束

正如你所看到的，我们在 Python 进程结束后得到了全部 4 个输出（第一次调用getlinefreezes 2 秒 - 而 Python 运行这两个time.sleep(1)- 然后在 3ms 内我们得到了全部 4 行）。我希望得到类似的东西：

[12:50:34.684] - 创建子
[12:50:34.706] - 创建子
[12:50:34.708] - 调用 getline
[12:50:3 4.XXX ] - 从 Python 输出：在 t 开始 Python 脚本=12:50:34.742105
[12:50:3 5.XXX ] - 来自 Python 输出：睡了 1 秒，t=12:50:35.743111
[12:50:36.XXX] - 来自 Python 输出：睡了 1 秒， t=12:50:36.743328
[12:50:36.XXX] - 从 Python 输出：在 t=12:50:36.743328
[12:50:36.XXX] 停止 Python 脚本 - getline 结束

我怀疑这个问题更多boost::process地来自 Python，但我能找到的所有例子boost::process都是以同样的方式阅读std::cout的。在 Python 打印输出时，我应该更改什么以使getline循环实时运行吗？

标签： pythonc++boost-process

解决方案

Python 流（如 C 流或 C++ 流）被缓冲（出于性能原因）。

你可能想在你的 Python 代码中使用一些flush方法。

您的问题可能是特定于操作系统的。对于 Linux，还要注意fsync(2)和termios(3)（以及pipe(7)和fifo(7) ...）。对于其他操作系统，请阅读其文档。

推荐阅读