Fs.readFile 在 FTP 服务器上
Fs.readFile on FTP server
我在 Node.js 中有一些脚本,当我 运行 它在我的计算机上时它可以工作,但当我在服务器上时却不能。
我有 2 个服务器:我 运行 第一个(服务器 1)和第二个(服务器 2)上的 webApplication 包含文件。
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'
我以为是 pass 的问题所以我尝试了 //192.168.200.2/Alfa/file4457.csv
, ./Alfa/file4457.csv
, Alfa/file4457.csv
但这不起作用。
我检查了路径,他很好。
对于 fs.stat()
这不是问题,我仍然可以用 c.lastMod()
替换它,但是我找不到可以用来替换 fs.readFile()
的东西
感谢您的阅读。
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
节点模块 documentation,您可以发现有 get
函数,能够从您的 FTP 连接中检索文件。
get(< string >path, [< boolean >useCompression, ]< function >callback)
- (void) - Retrieves a file at path from the server. useCompression defaults to false. callback has 2 parameters: < 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.
});
})
});
我在 Node.js 中有一些脚本,当我 运行 它在我的计算机上时它可以工作,但当我在服务器上时却不能。 我有 2 个服务器:我 运行 第一个(服务器 1)和第二个(服务器 2)上的 webApplication 包含文件。
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'
我以为是 pass 的问题所以我尝试了 //192.168.200.2/Alfa/file4457.csv
, ./Alfa/file4457.csv
, Alfa/file4457.csv
但这不起作用。
我检查了路径,他很好。
对于 fs.stat()
这不是问题,我仍然可以用 c.lastMod()
替换它,但是我找不到可以用来替换 fs.readFile()
感谢您的阅读。
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
节点模块 documentation,您可以发现有 get
函数,能够从您的 FTP 连接中检索文件。
get(< string >path, [< boolean >useCompression, ]< function >callback) - (void) - Retrieves a file at path from the server. useCompression defaults to false. callback has 2 parameters: < 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.
});
})
});