使用Golang Docker SDK备份容器内PGSQL时命令执行无效问题

代码存在4个核心错误，导致备份逻辑完全不生效：

• 仅调用ContainerExecCreate注册了待执行的命令实例，没有调用启动接口触发命令运行，Docker不会自动执行注册的命令，拿到的ExitCode 0是实例初始化的默认值，不是命令执行成功的返回。
• 命令中的管道符|、重定向符>是Shell专属语法，Docker exec默认不会启动Shell解释这些符号，直接把这些字符串传给pg_dumpall会被识别为普通命令参数，不会触发管道转发和文件写入逻辑。
• 即使命令正常执行，备份文件被写入transactions-db容器内部的backup/tr.sql路径，该路径没有配置卷挂载，容器重启后文件会直接丢失，宿主机和backup-service容器都无法访问到该文件。
• 错误处理逻辑失效，所有接口调用报错后仅打印日志就继续执行，比如ContainerExecCreate调用失败返回空ID时，后续逻辑会直接触发空指针异常。

直接捕获数据库容器内pg_dumpall的标准输出流，在backup-service本地完成压缩和文件写入，不需要依赖数据库容器内预装gzip，也不需要给数据库容器额外挂载备份目录，稳定性更高：

• 移除命令中的管道、重定向逻辑，仅保留pg_dumpall核心备份指令
• 补全exec实例启动逻辑，绑定标准输出、错误流
• 将输出流直接导入本地gzip压缩写入器，存储到已挂载的/app目录，备份文件会直接同步到宿主机当前目录
• 补全全链路错误处理，任意步骤报错直接终止流程返回
• 关闭不必要的TTY配置，避免终端控制字符污染备份文件
• Docker客户端初始化增加API版本自动协商配置，避免客户端与服务端版本不兼容导致调用失败

docker.go #

package main

import (
	"compress/gzip"
	"context"
	"fmt"
	"io"
	"os"

	"github.com/docker/docker/api/types"
	"github.com/docker/docker/client"
	"github.com/docker/docker/pkg/stdcopy"
)

func ConnectToDocker() (*client.Client, error) {
	cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
	if err != nil {
		return nil, err
	}
	return cli, nil
}

func BackupPostgres(ctx context.Context, cli *client.Client, containerID string, backupPath string) error {
	command := []string{"pg_dumpall", "-c", "-U", "user"}
	execConfig := types.ExecConfig{
		Tty:          false,
		AttachStderr: true,
		AttachStdout: true,
		Cmd:          command,
	}
	execCreateResp, err := cli.ContainerExecCreate(ctx, containerID, execConfig)
	if err != nil {
		return fmt.Errorf("创建exec实例失败: %w", err)
	}

	execAttachResp, err := cli.ContainerExecAttach(ctx, execCreateResp.ID, types.ExecStartCheck{Tty: false})
	if err != nil {
		return fmt.Errorf("启动exec实例失败: %w", err)
	}
	defer execAttachResp.Close()

	backupFile, err := os.Create(backupPath)
	if err != nil {
		return fmt.Errorf("创建本地备份文件失败: %w", err)
	}
	defer backupFile.Close()

	gzipWriter := gzip.NewWriter(backupFile)
	defer gzipWriter.Close()

	// 分离标准输出和错误流，输出写入备份文件，错误流打印到控制台
	_, err = stdcopy.StdCopy(gzipWriter, os.Stderr, execAttachResp.Reader)
	if err != nil {
		return fmt.Errorf("读取备份输出流失败: %w", err)
	}

	execInspect, err := cli.ContainerExecInspect(ctx, execCreateResp.ID)
	if err != nil {
		return fmt.Errorf("查询命令执行状态失败: %w", err)
	}
	if execInspect.ExitCode != 0 {
		return fmt.Errorf("备份命令执行失败，退出码: %d", execInspect.ExitCode)
	}
	return nil
}

main.go #

package main

import (
	"context"
	"fmt"
	"os"
)

func main() {
	cli, err := ConnectToDocker()
	if err != nil {
		fmt.Printf("连接Docker失败: %v\n", err)
		os.Exit(1)
	}

	err = BackupPostgres(context.Background(), cli, "transactions-db", "/app/tr.sql.gz")
	if err != nil {
		fmt.Printf("备份失败: %v\n", err)
		os.Exit(1)
	}
	fmt.Println("备份完成，文件已保存到宿主机当前目录的 tr.sql.gz")
}

• 确认transactions-db容器内的数据库用户权限，如果使用PostgreSQL默认的超级用户，将命令中-U user修改为-U postgres，同时可以通过配置环境变量PGPASSWORD传入数据库密码，避免命令等待密码输入卡住。
• 如果一定要在数据库容器内完成压缩和文件写入，需要将命令改为[]string{"sh", "-c", "pg_dumpall -c -U user | gzip > /backup/tr.sql.gz"}显式调用Shell解析语法，同时给transactions-db容器挂载/backup目录到宿主机存储备份，否则文件无法持久化。
• 恢复数据时可以直接执行gunzip -c tr.sql.gz | docker exec -i transactions-db psql -U user即可完成全库恢复。

内容的提问来源于stack exchange，提问作者Moayad Al-sowayegh