nodejs 从 sftp 下载文件

Question

我需要.txt.pgp从sftp. 我试过NPM ssh2，ssh2-sftp-client并node-ssh没有任何成功。

到目前为止，我得到的最接近的是远程文件夹中使用sftp.readdir( ssh2) 或sftp.list( ssh2-sftp-client)的文件列表。

我试过pipe和fs.createWriteStream和sftp.fastGet，但没有救了我的本地计算机上的文件。

const conn = new Client();
conn.on('ready', () => {
    console.log('Client :: ready');

    conn.sftp((err, sftp) => {
        if (err) throw err;

        sftp.readdir('out', (err, list) => {
            if (err) throw err;

            list.forEach(item => {
                console.log(item.filename);

                const fileName = item.filename;

                sftp.fastGet(fileName, fileName, {}, downloadError => {
                    if(downloadError) throw downloadError;

                    console.log("Succesfully uploaded");
                });
            })
            conn.end();
        });
    });
}).connect(config);

或者

const Client = require('ssh2-sftp-client');
const sftp = new Client();

sftp.connect(config).then(() => {
    return sftp.list('out');
})
.then(files => {
    // console.log(files);
    if (files.length > 0) {
        console.log('got list of files!');
    }

    files.map(file => {
        const fileName = file.name;

        sftp.get(fileName)
        .then(() => {
            fs.writeFile(fileName);
        }); 
    })
})
.then(() => {
    sftp.end();
}).catch((err) => {
    console.log(err);
});

Answer 1

关于您的第一次尝试（使用ssh2模块），我可以看到三个问题：

1. 您在conn.end()一系列前面的异步函数之外调用，这几乎肯定会导致 SSH 会话在您完成下载文件之前关闭。
2. 您没有为该sftp.fastGet()函数提供远程文件的正确路径。在代码的前面，您sftp.readdir()使用远程目录参数调用'out'，它返回与远程目录相关的文件列表。（要点是：您需要将远程目录添加到文件名以创建正确限定的路径。）
3. 您没有处理流事件error，所以我怀疑您没有收到有用的错误消息来帮助进行故障排除。

尝试类似：

const Client = require('ssh2').Client;
const conn = new Client();    
const sshOpt = someFunctionThatPopulatesSshOptions();    
const remoteDir = 'out';

conn.on('ready', () => {
  conn.sftp((err, sftp) => {
    if (err) throw err;
    sftp.readdir(remoteDir, (err, list) => {
      if (err) throw err;
      let count = list.length;
      list.forEach(item => {
        let remoteFile = remoteDir + '/' + item.filename;
        let localFile = '/tmp/' + item.filename;
        console.log('Downloading ' + remoteFile);
        sftp.fastGet(remoteFile, localFile, (err) => {
          if (err) throw err;
          console.log('Downloaded to ' + localFile);
          count--;
          if (count <= 0) {
            conn.end();
          }
        });
      });
    });
  });
});
conn.on('error', (err) => {
  console.error('SSH connection stream problem');
  throw err;
});
conn.connect(sshOpt);

这应该解决我提到的所有问题。具体来说：

1. 我们使用一个count变量来确保 SSH 会话仅在所有文件下载后关闭。（我知道它不漂亮。）
2. 我们正在remoteDir准备我们所有的远程文件下载。
3. 我们正在监听流中的error事件conn。