所以我创建一个类,最终想创建一个方法,该方法需要在SFTP服务器上的文件,并产生可以管道到其他流/函数的读取流。我大部分的方式,除了我的readStream行为奇怪。下面是相关的代码:节点异步从SFTP连接的读取流
const Client = require('ssh2').Client,
Readable = require('stream').Readable,
async = require('async');
/**
* Class Definition stuff
* ......
*/
getStream(get) {
const self = this;
const rs = new Readable;
rs._read = function() {
const read = this;
self.conn.on('ready', function(){
self.conn.sftp(function(err,sftp) {
if(err) return err;
sftp.open(get, 'r', function(err, fd){
sftp.fstat(fd, function(err, stats) {
let bufferSize = stats.size,
chunkSize = 512,//bytes
buffer = new Buffer(bufferSize),
bytesRead = 0;
async.whilst(
function() {
return bytesRead < bufferSize;
},
function (done) {
sftp.read(fd, buffer, bytesRead, chunkSize, bytesRead,
function (err, bytes, buff) {
if (err) return done(err);
// console.log(buff.toString('utf8'));
read.push(buff);
bytesRead += bytes;
done();
});
},
function (err) {
if (err) console.log(err);
read.push(null);
sftp.close(fd);
}
);
});
});
});
}).connect(self.connectionObj);
}
return rs;
}
在其他地方,我会调用这个方法就像这样:
let sftp = new SFTP(credentials);
sftp.getStream('/path/file.csv')
.pipe(toStuff);
.pipe(toOutput);
所以,长话短说。在SFTP.read操作期间,read.push(buff)
一直重复推送相同的文件第一部分。但是,当我console.log(buff)
正确流式传输整个文件?
所以我很想知道我在做什么错误的读取流,它只是推动文件的开始,而不是继续到缓冲区的下一部分。
这里的SSH2 SFTP客户端上的文档:https://github.com/mscdex/ssh2-streams/blob/master/SFTPStream.md
我用这太问题为灵感就是我上面写道:node.js fs.read() example
这类似于/相关:Reading file from SFTP server using Node.js and SSH2