在FTP服务器上使用Fs.readFile

3

我有一些Node.js脚本,在我的计算机上运行良好,但在服务器上却不行。 我有两台服务器:第一台(服务器1)上运行web应用程序,第二台(服务器2)包含文件。

var fs = require('fs');
var FTPClient = require('ftp');
var c = new FTPClient();

c.connect({
  host: "192.168.200.2",
  user: "*****",
  password: "******"
});

c.on('ready', function() {

  console.log("Connected to datastore !");

  var dateFile = './Dictionnary/lastUpdate.json';
  var csvFile = '//192.168.200.2/Alfa/file4457.csv'
  var lastUpdate;

  fs.stat(csvFile, (err, stat) => {
    if (err) {
      console.error(err);
    };

    var date = { mtime: stat.mtime }

    var lastDate = new Date(jsonfile.readFileSync(dateFile).mtime);

    var newDate = new Date(stat.mtime);

    if (newDate <= lastDate) {
      console.log('Dictionnary up-to-date');
    } else {
      console.log('Update Needed');
      var DeleteQuery = mySqlClient.query('DELETE FROM dictionnary');
      csv = fs.readFile(csvFile, 'utf-8', (err, data) => {
        if (err) {
          throw err
        };
        dictionnary = parseCSV(data);
        for (i = 0; i < dictionnary.length - 1; i++) {
          var insertQuery = ("INSERT INTO Dictionnary VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)");
          var query = mySqlClient.query(insertQuery, [dictionnary[i][0], dictionnary[i][1], dictionnary[i][2], dictionnary[i][3], dictionnary[i][4], dictionnary[i][5], dictionnary[i][6], dictionnary[i][7], dictionnary[i][8], dictionnary[i][9], dictionnary[i][10], , dictionnary[i][11], , dictionnary[i][12]]);
         };
      }
   }
}

当我在我的电脑上运行脚本时,我可以在(服务器2)上找到文件,但是当我在(服务器1)上运行它时,它不再起作用,我遇到了这个错误:

 Error: ENOENT: no such file or directory, open '//192.168.200.2/Alfa/file4457.csv'

我认为这可能是密码的问题,所以我尝试使用//192.168.200.2/Alfa/file4457.csv./Alfa/file4457.csvAlfa/file4457.csv,但都不起作用。我检查了路径,它是正确的。对于fs.stat(),这不是问题,我仍然可以将其替换为c.lastMod(),但我找不到可以替换fs.readFile()的内容。
谢谢您的阅读。
1个回答

7

fs将查找您提供给它的路径//192.168.200.2/Alfa/file4457.csv

从执行脚本的服务器上看,这个路径不存在。我不知道您的网络和服务器架构,所以我不能解释为什么它在您的计算机上能够工作,在服务器上无法工作。但我猜测您的计算机和FTP服务器在同一局域网中(如果我错了,请纠正我)。

在阅读您的代码后,我发现您正在打开一个远程FTP服务器上的FTP连接:

c.connect({
  host: "192.168.200.2",
  user: "*****",
  password: "******"
});

c.on('ready', function() {
    ...
});

但是在.on('ready', function() { ... })回调函数中,您没有对这个新打开的连接做任何事情(看看您的代码,您再也没有使用c了)。

通过阅读ftp节点模块文档,您可以找到get函数,它可以从FTP连接中检索文件。

get(< string >path, [< boolean >useCompression, ]< function >callback) - (void) - 从服务器检索路径下的文件。 useCompression默认为false。 回调函数有2个参数:< Error >err,< ReadableStream >fileStream。

因此,您必须像以下这样使用FTP连接:

c.connect({
   host: "192.168.200.2",
   user: "*****",
   password: "******"
});

c.on('ready', function() {
    c.get('/Alfa/file4457.csv', function(err, stream) {
         var content = '';
         stream.on('data', function(chunk) {
             content += chunk.toString();
         });
         stream.on('end', function() {
             // content variable now contains all file content. 
         });
    })
});

使用流(stream),我可以访问文件的内容吗? - Adrien Voisin
当然,我更新了我的答案,请查看文档:https://nodejs.org/api/stream.html - jbrtrnd
非常感谢。 - Adrien Voisin

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接