StdinPipe 命令关闭速度过快

最近发现不少小伙伴都对Golang很感兴趣，所以今天继续给大家介绍Golang相关的知识，本文《StdinPipe 命令关闭速度过快》主要内容涉及到等等知识点，希望能帮到你！当然如果阅读本文时存在不同想法，可以在评论中表达，但是请勿使用过激的措辞~

我一直在尝试使用 exec.command 调用 pg_restore 并使用数据库转储文件中的数据向 stdinpipe 提供数据，它适用于 1mb 以下的小文件，但对于较大的转储会失败，并出现 write |1：损坏的 pipeline 错误。我还尝试逐行扫描并写入管道，但它导致了相同的错误，并且在单独的 goroutine 中像 cmd.run() 一样运行也没有帮助。

去：1.14 操作系统：macos

cmd := exec.Command("pg_restore", "--clean", "-n public", "--dbname=DB_URI")
cmd.Stdout = os.Stdout
cmd.Stderr = os.Stderr
pw, err := cmd.StdinPipe()
defer pw.Close()
...

done := make(chan struct{})
errCh := make(chan error)
file, err := os.Open("dumpfile")
defer file.Close()

if err := cmd.Start(); err != nil {
    return err
}

_, err = io.Copy(pw, file)

我做错了什么或者如何保持管道打开？

解决方案

在我同事的帮助下，我们发现命令参数格式错误，因为 Go 直接使用系统调用，程序的每个参数必须是单独的，所以这里 -n public 导致了该问题

"pg_restore"、"--clean"、"-n public"、"--dbname=DB_URI"

修复也很清楚 - 将它们分开 -n、public

"pg_restore", "--clean", "-n", "public", "--dbname=DB_URI"

当使用 cat 而不是 pg_restore 时，您的代码可以正常工作。 另一方面，当使用 head -10 时，我遇到了与您相同的错误，这实际上是预期的。

由于您在异步模式下启动 cmd，如果 pg_restore 在消耗其所有 STDIN 之前停止，则 io.Copy 在尝试在关闭的管道上写入时将遇到此类错误。

检查 pg_restore 命令的状态（最终返回代码、STDERR 上打印的内容、日志...）以查看是否存在实际错误。

您可以将此错误视为正常指示，表明您不应再向此命令提供输入。

今天带大家了解了的相关知识，希望对你有所帮助；关于Golang的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~