实时从命令 exec 中捕获标准输出

Question

我目前正在开发一个可以执行命令的聊天机器人。我希望它做的一件事是能够运行脚本并将脚本的标准输出输出到聊天中。

我遇到的问题是该函数收集脚本的所有标准输出并在最后返回它们，我想尝试修改它以实时编写并且在这样做时遇到了问题。

我认为这个问题可能涉及到它只有一种方法可以将文本返回到聊天频道，那就是通过重启的返回功能。但是，如果可能，我想遍历 exec 命令并输出。

这是我的代码：

func reboot(command *bot.Cmd) (string, error) {
    n := command.Args[0]
    // this return is what all gets sent into chat channel
    return runcommand(n), nil
  }


func runcommand(server string) string {
    cmd := exec.Command("/bin/bash", "-c", "python test.py %s", server)
    cmdOutput := &bytes.Buffer{}
    cmd.Stdout = cmdOutput
    err := cmd.Run()
    if err !=nil {
        os.Stderr.WriteString(err.Error())
    }
        return fmt.Sprintf(string(cmdOutput.Bytes()))
}

Answer 1

redis.log 的实时命令管道。 （您可以拨打bgsave进行测试。）

package main

import (
    "os"
    "os/exec"
    "fmt"
    "bufio"
)

func main() {
    cmd := exec.Command("tail", "-f",  "/usr/local/var/log/redis.log")

    // create a pipe for the output of the script
    cmdReader, err := cmd.StdoutPipe()
    if err != nil {
        fmt.Fprintln(os.Stderr, "Error creating StdoutPipe for Cmd", err)
        return
    }

    scanner := bufio.NewScanner(cmdReader)
    go func() {
        for scanner.Scan() {
            fmt.Printf("\t > %s\n", scanner.Text())
        }
    }()

    err = cmd.Start()
    if err != nil {
        fmt.Fprintln(os.Stderr, "Error starting Cmd", err)
        return
    }

    err = cmd.Wait()
    if err != nil {
        fmt.Fprintln(os.Stderr, "Error waiting for Cmd", err)
        return
    }
}

Answer 2

我还没有找到解决您问题的方法，但我发现了一些奇怪的东西。

我写了三个版本的程序，以一秒的间隔重复输出一个短字符串，一个在 Python 中，一个在 C 中，一个在 Go 中：

talker.py

​​>

import time

while True:
        print("Now!")
        time.sleep(1)

talker.c

#include <unistd.h>

main() {
        for(;;) {
                write(1, "Now!\n", 5);
                sleep(1);
        }
}

talker.go

package main

import (
        "fmt"
        "time"
)

func main() {
        for {
                fmt.Println("Now!")
                time.Sleep(time.Second)
        }
}

当我自己运行它们时（例如python ./talker.py），它们的工作方式似乎完全相同。但是当我将输出传送到cat 时，我看到了不同； C 和 Go 版本立即将其输出显示到屏幕上，但 Python 版本并非如此。它的输出被缓冲并且在收集到足够的数据之前不会显示在屏幕上。

我什至尝试过使用简单的 Go 版本的 cat，但这并没有改变行为：

package main

import (
        "io"
        "os"
)

func main() {
        io.Copy(os.Stdout, os.Stdin)
}