如何通过Dockerode在Node.js中向Docker容器传文件并获取输出

调整容器配置并实现流传输与输出捕获 #

先修改容器创建参数，关闭Tty（避免stdout/stderr混流，方便解析JSON），同时指定容器内处理文件的命令（假设容器内处理命令为process-input，从标准输入读取文件内容并输出JSON）：

const Docker = require('dockerode');
const fs = require('fs');
const { pipeline } = require('stream/promises');

const docker = new Docker();

async function processFileInContainer(filePath) {
  // 创建容器
  const container = await docker.createContainer({
    Image: "imageId",
    AttachStdin: true,
    AttachStdout: true,
    AttachStderr: true,
    Tty: false, // 必须关闭Tty，保证流格式正常
    Cmd: ['process-input'] // 替换为容器内实际处理文件的命令
  });

  try {
    // 启动容器
    await container.start();

    // 获取容器的输入输出流
    const streams = await container.attach({
      stream: true,
      stdin: true,
      stdout: true,
      stderr: true
    });

    // 读取本地文件，通过流传输到容器stdin
    const fileStream = fs.createReadStream(filePath);
    // 用pipeline处理流，自动处理错误和资源释放
    await pipeline(fileStream, streams.stdin);
    // 关闭stdin，告诉容器输入已结束
    streams.stdin.end();

    // 收集容器stdout输出
    let output = '';
    streams.stdout.on('data', (chunk) => {
      output += chunk.toString();
    });

    // 收集stderr错误信息
    let errorOutput = '';
    streams.stderr.on('data', (chunk) => {
      errorOutput += chunk.toString();
    });

    // 等待容器处理完成退出
    await container.wait();

    // 解析输出为JSON
    if (errorOutput) {
      throw new Error(`容器处理出错: ${errorOutput}`);
    }
    return JSON.parse(output);
  } finally {
    // 清理容器：停止并删除，避免残留资源
    await container.stop();
    await container.remove();
  }
}

// 调用示例：处理同目录下的test.txt文件
processFileInContainer('./test.txt')
  .then(result => console.log('处理结果:', result))
  .catch(err => console.error('错误:', err));

关键细节说明 #

• 关闭Tty：开启Tty会让Docker把stdout和stderr合并成一个流，还会混入终端控制字符，完全没法正常解析JSON，所以必须关闭。
• 流的处理：用stream/promises的pipeline比手动pipe更安全，能自动处理流的错误和资源释放。
• 关闭stdin：文件传输完一定要调用streams.stdin.end()，不然容器会一直等着输入，永远不会结束处理。
• 容器清理：在finally块里处理容器的停止和删除，防止没用的容器占资源。

替代方案：用docker cp传文件（非流方式） #

如果不需要实时流传输，也可以先把文件复制到容器里再执行命令：

async function processFileWithCp(filePath) {
  const container = await docker.createContainer({
    Image: "imageId",
    Cmd: ['process-file', '/tmp/input-file'] // 命令处理容器内指定路径的文件
  });

  await container.start();
  // 把本地文件复制到容器内的/tmp目录
  await container.putFile(filePath, '/tmp/input-file');
  // 等待容器处理完成
  const { StatusCode } = await container.wait();
  if (StatusCode !== 0) {
    const stderr = await container.logs({ stderr: true });
    throw new Error(`处理失败: ${stderr.toString()}`);
  }
  // 获取处理后的输出
  const stdout = await container.logs({ stdout: true });
  await container.stop();
  await container.remove();
  return JSON.parse(stdout.toString());
}

内容的提问来源于stack exchange，提问作者pranit