第二个异步等待函数未调用

Question

我正在尝试先解压缩一个文件，然后等待该解压缩文件完成，然后再循环遍历每个文件并将其上传到 S3 存储桶。第一个函数unzipPromise 运行良好，所有内容都在正确的目录中解压缩，但uploadS3Promise 根本没有运行。我在这个过程中没有遇到错误，它只是运行并解压缩文件，从不触及uploadS3Promise 函数。

function unzipInput(file, client, project_number, oldpath, newpath) {
    path = `zips/${client}/${project_number}/${file}/`;
    function unzipPromise() {
        return new Promise((resolve, reject) => {
            fse.mkdirsSync(path);
            fs.rename(oldpath, newpath, err => {
                if (err) {
                    throw err;
                }
            });
            fs.createReadStream(newpath).pipe(unzip.Extract({ path }));
        });
    }
    function uploadS3Promise() {
        console.log("running");
        return new Promise((resolve, reject) => {
            // fs.unlinkSync(newpath);
            fs.readdirSync(newpath).forEach(file => {
                uploadToS3(file, client, project_number, path);
                console.log(file, "test");
            });

            if (err) reject(err);
            else resolve("success");
        });
    }
    // New code with async:
    (async () => {
        try {
            await unzipPromise();
            await uploadS3Promise();
        } catch (e) {
            console.error(e);
        }
    })();
}

Answer 1

uploadS3Promise 未运行，因为代码仍在等待 unzipPromise 完成。除非您 resolve 或 reject 一个承诺，否则代码将不会进一步执行。

所以在你的代码中......

function unzipPromise(){
    ...
    resolve(...)
    ...
}

在不相关的注释中，我认为函数名称不以 promise 结尾会更易读。就像只是称他们为 unzip 和 uploadS3。我们通常不会通过返回类型来命名我们的函数，就像我们从不说 intIndexOf 等等。

Answer 2

你应该在解压路径完成后调用resolve，如果发生错误，你应该调用reject。 而且由于流是 EventEmitter，你可以监听事件并与之交互

const stream = fs.createReadStream(newpath).pipe(unzip.Extract({ path }))
stream
.on('error', (err) => reject(err))
.on('finish', () => resolve())

Answer 3

就我个人而言，我会使用 .then 来稍微分解一下流程。

unzipPromise().then(res => {
    console.log('resolved promise 1');
    uploadS3Promise();
} rej => {
    console.log('rejected promise 1, sorry!');
});

另外——“unzipInput”永远不会被解析或拒绝。