javascript - 管道适用于本地主机但不适用于远程nodejs

Question

我正在尝试使用 ytdl-core 模块将 youtube 音频下载到我的本地磁盘(我计算机上的某个路径)。

我创建了一个 API，我可以使用请求的 youtube url 和我希望保存文件的目标文件夹来调用它。

app.get('/api/downloadYoutubeVideo', function (req, res) {  
var videoUrl = req.query.videoUrl;  
var destDir = req.query.destDir;    

ytdl.getInfo(videoUrl, function(err, info){
        var videoName = info.title.replace('|','').toString('ascii');       

        var stream = ytdl(videoUrl, { filter: 'audioonly'})
                       .pipe(fs.createWriteStream(destDir + '\\' + videoName + '.mp3'));

        stream.on('finish', function() {
            res.writeHead(204);
            res.end();
        });             
    });         
}); 

问题是当我在本地主机上调用 api 时(例如:localhost:11245/api/downloadYoutubeVideo?videoUrl= https://www.youtube.com/watch?v=E5kJDWQSBUk&destDir=C :\test)
它可以工作，文件确实下载到“C:\test”。

但是当我调用 Remote 上的 api 时(例如: http://sometest.cloudno.de/api/downloadYoutubeVideo?videoUrl=https://www.youtube.com/watch?v=02BAlrAkuCE&destDir=C :\test)

它不会在目录中创建文件...

我已经搜索了答案，但没有找到答案...

Answer 1

是否 C:\test已经存在于您的 Remote 上？如果不是你不能使用 fs.createWriteStream()在创建目录之前，它不会为您隐式创建目录。由于您没有在收听 'error'事件，您甚至不会知道这是问题所在，因为您没有捕获它。

下面的代码示例将检查是否存在 destDir如果它不存在，将在继续之前创建它。

const fs = require('fs');
const sep = require('path').sep;

function checkAndMakeDir(dir, cb) {
  fs.access(dir, (err) => {
    if (err)
      fs.mkdir(dir, (err) => {
        if (err)
          return cb(err);

        return cb();
      });
    else
      return cb();
  });
}

app.get('/api/downloadYoutubeVideo', function (req, res) {
  let videoUrl = req.query.videoUrl;
  let destDir = req.query.destDir;

  checkAndMakeDir(destDir, (err) => {
    if (err) {
      res.writeHead(500);
      return res.end();
    }

    ytdl.getInfo(videoUrl, function (err, info) {
      let videoName = info.title.replace('|', '').toString('ascii');
      let saveStream = fs.createWriteStream(`${destDir}${sep}${videoName}.mp3`);

      saveStream.once('error', (err) => {
        console.log(err);
        res.writeHead(500);

        return res.end();
      });

      saveStream.once('finish', () => {
        res.writeHead(204);
        return res.end();
      });

      ytdl(videoUrl, {filter: 'audioonly'})
        .once('error', (err) => {
          console.log('Read Stream Error', err);

          res.writeHead(500);
          return res.end();
        })
        .pipe(saveStream);
    });
  });
});