在 SFTP 内部循环承诺不会将文件数据下载到本地文件?
looping inside SFTP promise not download file data to local file?
我的总体问题是,一旦我过滤了在过去 5 分钟内添加的文件,我就会循环遍历返回的对象数组。从那里我将根远程文件名附加到从最近 5 分钟添加的文件返回的名称。 fastget 没有向我的本地文件写入任何内容。
我已经在循环外测试了附加路由并且它有效,我是否由于某种原因在循环内丢失了我的承诺数据?
sftp
.connect({
host: "hostaddress",
port: 22,
username: "USERNAME",
password: "PASSWORD"
})
.then(() => {
return sftp.list(root);
})
.then(data => {
//filters new files in last 5 min
const filteredFile = data.filter(file => {
let currentDate = moment();
let CurrentTimeMinusFive = moment().subtract(5, "minutes");
let allAccessTimes = file.accessTime;
let parsedAccessTimes = moment(allAccessTimes);
let filteredTime = moment(parsedAccessTimes).isBetween(
CurrentTimeMinusFive,
currentDate
);
//returns boolean if the file has been added in the last 5 minutes
return filteredTime;
});
//returns full metadata in array of objects
console.log(filteredFile);
//not writing filedata from remote server to localfile
let localPath = "/Users/me/Desktop/DOWNLOADEDSFTP/data.txt";
filteredFile.forEach(file => {
let name = file.name;
return sftp.fastGet(
`remote-path/${name}`,
localPath
);
});
})
.then(() => {
sftp.end();
})
.catch(err => {
console.error(err.message);
});
您正在使用 forEach
循环,其中的承诺无法按您期望的方式工作。如果可以并行执行操作,则需要使用 for..of
或 Promise.all
。
for(const file of filteredFile) {
let name = file.name;
await sftp.fastGet(
`remote-path/${name}`,
localPath
);
});
确保像这样放置异步
.then(async data => {
我的总体问题是,一旦我过滤了在过去 5 分钟内添加的文件,我就会循环遍历返回的对象数组。从那里我将根远程文件名附加到从最近 5 分钟添加的文件返回的名称。 fastget 没有向我的本地文件写入任何内容。
我已经在循环外测试了附加路由并且它有效,我是否由于某种原因在循环内丢失了我的承诺数据?
sftp
.connect({
host: "hostaddress",
port: 22,
username: "USERNAME",
password: "PASSWORD"
})
.then(() => {
return sftp.list(root);
})
.then(data => {
//filters new files in last 5 min
const filteredFile = data.filter(file => {
let currentDate = moment();
let CurrentTimeMinusFive = moment().subtract(5, "minutes");
let allAccessTimes = file.accessTime;
let parsedAccessTimes = moment(allAccessTimes);
let filteredTime = moment(parsedAccessTimes).isBetween(
CurrentTimeMinusFive,
currentDate
);
//returns boolean if the file has been added in the last 5 minutes
return filteredTime;
});
//returns full metadata in array of objects
console.log(filteredFile);
//not writing filedata from remote server to localfile
let localPath = "/Users/me/Desktop/DOWNLOADEDSFTP/data.txt";
filteredFile.forEach(file => {
let name = file.name;
return sftp.fastGet(
`remote-path/${name}`,
localPath
);
});
})
.then(() => {
sftp.end();
})
.catch(err => {
console.error(err.message);
});
您正在使用 forEach
循环,其中的承诺无法按您期望的方式工作。如果可以并行执行操作,则需要使用 for..of
或 Promise.all
。
for(const file of filteredFile) {
let name = file.name;
await sftp.fastGet(
`remote-path/${name}`,
localPath
);
});
确保像这样放置异步
.then(async data => {