0

我正在处理一个项目时遇到问题，我正在使用一个名为 sftp-ssh2-client 的节点模块从我的 FTP 服务器下载文件，然后尝试将流传递回我的 FTP 服务器，但传递到另一个目录。

代码如下所示：

const stream = sftp.get(`path/to/file.csv.gz`).then(() => {

}).catch((err) => {

});

sftp.put(stream, 'path/to/new/file.csv.gz').then(() => {

}).catch((err) => {

})

但是，当我拨入我的 FTP 服务器到文件被放置到的位置时，文件大小为 0，并且下载时已损坏。谁能告诉我我在这里做错了什么？

非常感谢，

G

4

2 回答 2

3

sftp.get()不返回流，它返回解析为流的承诺，因此您的代码应如下所示：

sftp.get('path/to/file.csv.gz').then(stream => {
  return sftp.put(stream, 'path/to/new/file.csv.gz');
}).catch(err => {
  ...
});

但是，在我看来，您可以只使用sftp.rename()，这不需要下载和上传整个文件：

sftp.rename('path/to/file.csv.gz', 'path/to/new/file.csv.gz').then(...);

此外，如果您确实想采用先下载后上传的方式，请务必阅读有关 encoding 的文档。

于 2018-12-16T09:07:30.677 回答
1 
 function uploadFile(req, res) {
    req.pipe(req.busboy);
    req.busboy.on('file', function(fieldname, file, filename) {
        // debug("Uploading: " + filename);
        filename = (new Date()).getTime() + '-' + filename;

        //Path where file will be uploaded
        var fstream = fs.createWriteStream(FILE_STORE + filename);

        file.pipe(fstream);

        fstream.on('close', function() {
            //   debug("Upload Finished of " + filename);
            var newFileName = FILE_STORE + filename;
            if (!fs.existsSync(newFileName)) {

                res.status(404).json({ 'message': 'file not found' })
                return;
            }
            res.status(200).json({ file: filename });
        })
    })

}
于 2020-02-18T14:05:19.107 回答