2017-06-29 111 views
0

我正在使用dockerode库,我想创建一个容器,执行一个(单个)命令并返回(单独)标准输出和标准错误该命令。从Node.js中的码头容器获取stdout和stderr流

到目前为止,我能够得到标准输出,但我没有运气标准错误。我发现很多方法在Github的问题,但没有一个工作。

的代码我已经是(我使用的承诺和协同程序,以避免回调):

const Promise = require('bluebird'); 
const coroutine = Promise.coroutine; 
const Docker = require('dockerode'); 

const docker = coroutine.promisifyAll(new Docker()); 

const foo = coroutine(function*(){ 

    let container = Promise.promisifyAll(yield docker.createContainerAsync(/*...*/)); 

    yield container.startAsync(/*...*/); 

    const execOpts = {Cmd: /*...*/, AttachStdout: true, AttachStderr: true, Tty: true}; 
    const exec = Promise.promisifyAll(yield container.execAsync(execOpts));      
    const stream = yield exec.startAsync(); 


    let data = []; 
    stream.on('data', chunk => { 
      data.push(chunk); 
    }); 

    stream.on('end',() => { 
     stdoutData = Buffer.concat(data).toString() 
    }); 


    let executionData = yield exec.inspectAsync(); 
    while (executionData.Running) { executionData = yield exec.inspectAsync(); }               

    return { 
     stdout: stdoutData, 
     stderr: 
    } 

}); 

注意:在dockerode's npm documentation有这个例子中实现我想要的东西,但我无法找出什么全局对象process,以及如何使用它在我的代码:

//tty:true 
docker.createContainer({ /*...*/ Tty: true /*...*/ }, function(err, container) { 

/* ... */ 

container.attach({stream: true, stdout: true, stderr: true}, function (err, stream) { 
    stream.pipe(process.stdout); 
}); 

/* ... */ 
} 

//tty:false 
docker.createContainer({ /*...*/ Tty: false /*...*/ }, function(err, container) { 

/* ... */ 

container.attach({stream: true, stdout: true, stderr: true}, function (err, stream) { 
    //dockerode may demultiplex attach streams for you :) 
    container.modem.demuxStream(stream, process.stdout, process.stderr); 
}); 

/* ... */ 
} 

docker.createImage({fromImage: 'ubuntu'}, function (err, stream) { 
stream.pipe(process.stdout); 
}); 

回答

1

只需使用.demuxStream

demuxStream - demux stdout and stderr 
//demuxStream(stream, stdout, stderr) 
container.attach({ 
    stream: true, 
    stdout: true, 
    stderr: true 
}, function handler(err, stream) { 
    //... 
    container.modem.demuxStream(stream, process.stdout, process.stderr); 
    //... 
}); 

process对象是代表你当前进程的全局变量:

过程对象是一个全球性的,超过提供有关信息和控制,目前Node.js的过程。

process.stderrprocess.stdoutWriteable Streams表示当前的过程STDOUT和STDERR:

的process.stderr属性返回连接到stderr的流(FD 2)。它是一个net.Socket(它是一个Duplex流),除非fd 2指向一个文件,在这种情况下它是一个可写的流。

process.stdout属性返回连接到stdout(fd 1)的流。它是一个net.Socket(它是一个Duplex流),除非fd 1指向一个文件,在这种情况下它是一个Writable流。

I.e.上面的例子只是将容器的流重定向到当前进程的STDERR和STDOUT。但是您可以自由使用任何其他可写入流。