ssh2-sftp-client获取多个文件-错误“结束后写入”

Question

我试图从ftp加载多个文件，但我得到错误：“写入后结束”。我找不到问题所在。

connections.js

async function getFtpFileContent(_path) {
  const ftpConfig = {
    host: config.FTPhost.replace('https://', ''),
    username: config.FTPusername,
    password: config.FTPpassword
  };
  let ftpFileContent;
  let sftp = new StfpClient();
  try {
    await sftp.connect(ftpConfig);
    const stream = await sftp.get(_path);
    ftpFileContent = await readStream(sftp, stream);
    stream.close();
    await sftp.end();
  } catch (error) {
    console.log('FTP Error: \n', error);
  }

  return ftpFileContent;
}


function readStream(sftp, stream) {
  return new Promise((resolve, reject) => {
    let body;
    stream.on('data', chunk => {
      body += chunk;
    });
    stream.on('end', () => {
      resolve(body);
    });
    stream.on('error', err => reject(err));
  });
}

调用下一个方法：

async function getFiles(req, res) {
  // first file
  let fileContent = await conn.getFtpFileContent(filePath);

  // second file
  let fileContent2 = await conn.getFtpFileContent(filePath2);
}

当我第二次调用方法getFtpFileContent时，我得到了前面提到的错误(“结束后写入”)。

你能帮帮我吗？我在哪里做错了？

Answer 1

我不知道您的问题出在哪里，但是您是否应该在getFtpFileContent函数中调用stream.close()？我没有看到任何关于流的close方法，只有close事件。

Answer 2

我找到问题了。问题出在我后来使用的CSV转换器中。转换器使用的是可写流，该流在转换后未关闭。