我有一个 shell 命令(例如 journalctl -f -o json),它不断地将行流传输到标准输出。
我想逐行检索此输出并进一步处理。
os/exec 的文档解决了如何读取命令的输出,io 处理流缓冲。
在我看来,处理过程都经过一个固定的缓冲区,该缓冲区被读入、处理和进一步写入。我的问题是该缓冲区的大小是固定的并且与内容无关。
有没有办法逐行读取传入流(在我的例子中是 shell 命令的输出)?可能有比 io 读者更高级的库?
使用 cmd.stdoutpipe() 获取(管道)使用 cmd.start() 启动该进程之前的输出( start() 启动命令但不等待其完成)。
并使用 bufio.scanner 读取输入 (io.reader) 行 -逐行。
例如,我将使用这个 bash 脚本打印当前时间 3 次,并在每次之间睡眠 1 秒:
for i in {1..3}; do date; sleep 1; done
执行此命令并逐行读取其输出的示例:
cmd := exec.command("bash", "-c", "for i in {1..3}; do date; sleep 1; done") out, err := cmd.stdoutpipe() if err != nil { log.fatal(err) } defer out.close() err = cmd.start() if err != nil { log.fatal(err) } scanner := bufio.newscanner(out) for scanner.scan() { line := scanner.text() fmt.println("output:", line) }
示例输出:
2022/11/29 14:38:48 Output: Tue Nov 29 02:38:48 PM CET 2022 2022/11/29 14:38:49 Output: Tue Nov 29 02:38:49 PM CET 2022 2022/11/29 14:38:50 Output: Tue Nov 29 02:38:50 PM CET 2022
(每行开头的第一个日期时间来自 log 包,以验证每行在第二次延迟后打印,另一个时间戳是 date 命令的输出。)
以上就是是否存在将程序的输出作为流逐行读取的概念?的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号