go - Golang扫描函数中 "ERROR: IOError: closed stream"如何处理？

Question

我在 Golang 代码中使用 knife bootstrap 命令来引导节点。有时食谱中有等待，等待超过 10 分钟。在这种情况下，我收到错误“错误:IOStream 关​​闭”。有什么办法可以增加时间限制吗？我也在不断地从 cmd 的输出和错误流中读取日志。

func executeCMDWorkstation(cmd *exec.Cmd, projectId, cr_id string) bool {

stdout, err3 := cmd.StdoutPipe()
if err3 != nil {
    utils.Info.Println(err3)
    return false
}
defer stdout.Close()
stderr, err4 := cmd.StderrPipe()
if err4 != nil {
    utils.Info.Println(err4)
    return false
}
defer stderr.Close()

//cmd.Stdout = os.Stdout
//cmd.Stderr = os.Stderr
multi := io.MultiReader(stdout, stderr)
inp := bufio.NewScanner(multi)
err := cmd.Start()
if err != nil {
    utils.Info.Println("Error while creating client", err)
    return false
}
fmt.Println("Generating logs**************")
for inp.Scan() {

    line := inp.Text()
    if cr_id == "" {
        lg.SendDebugLogs(line, "projects/logs", projectId, "chef")
    } else {
        lg.SendDebugLogs(line, "changeRequests/logs", cr_id, "chef")
    }
}
exitStatus := cmd.Wait()
if exiterr, ok := exitStatus.(*exec.ExitError); ok {
    utils.Info.Println("************ Exit Status is:", exiterr, "************")
    return false
}

return true

我们将不胜感激任何有助于改进此过程的帮助。

Answer 1

在查看了一些论坛、Go Docs 并尝试了一些代码更改之后，最终将 bufio 中的扫描方法替换为对我有用的 textproto 的 ReadLine。

我替换了下面的代码:

inp := bufio.NewScanner(multi)
err := cmd.Start()
if err != nil {
    utils.Info.Println("Error while creating client", err)
    return false
}
fmt.Println("Generating logs**************")
for inp.Scan() {
    line := inp.Text()
    if cr_id == "" {
        lg.SendDebugLogs(line, "projects/logs", projectId, "chef")
    } else {
        lg.SendDebugLogs(line, "changeRequests/logs", cr_id, "chef")
    }
}

使用以下代码:

    inp1 := bufio.NewReader(multi)

    tp := textproto.NewReader( inp1 )

    err := cmd.Start()
    if err != nil {
        utils.Info.Println("Error while creating client", err)
        return false
    }
    fmt.Println("Generating logs**************")

    /*
    New code for logs starts here
     */


    for {
        line, readErr := tp.ReadLine()

        if readErr != nil {
                break
        }

        if cr_id == "" {
            lg.SendDebugLogs(line, "projects/logs", projectId, "chef")
        } else {
            lg.SendDebugLogs(line, "changeRequests/logs", cr_id, "chef")
        }
    }

最后，通过处理立即重启以及厨师食谱或脚本中的长时间 sleep /等待，此修改对我来说非常有效。基本上我改变了流阅读器我希望这对面临同样问题的其他人有帮助:)