SFTP内部循环承诺不将文件数据下载到本地文件



我的总体问题是,一旦我过滤了过去5分钟内添加的文件,我就会在返回的对象数组上循环。从那里,我将根远程文件名添加到最后5分钟添加的文件中返回的名称中。fastget不会向我的本地文件写入任何内容。

我已经在循环外测试了附加的路由,它是有效的,我是不是因为某种原因在循环内丢失了promise数据?

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);
});

您使用的是带有promise的forEach循环,但它并没有按您期望的方式工作。如果可以并行执行,则需要使用for..ofPromise.all

for(const file of filteredFile) {
let name = file.name;
await sftp.fastGet(
`remote-path/${name}`,
localPath
);
});

确保你把异步像这个

.then(async data => {

最新更新