s3.getObject在开发环境无法执行 本地运行正常问题求助

问题根因 #

• 最核心问题：Promise逻辑写法不规范：你在new Promise的执行器函数内混用async、await和.then()写法，属于典型的Promise反模式，且全程没有调用resolve()/reject()处理Promise的完成/失败状态。本地环境网络快、权限齐全，逻辑可以顺次执行，但开发环境出现异常时，错误只会静默打印不会触发外层流程中断，看起来就像getObject调用被直接跳过。
• 开发环境权限/网络限制：本地使用的个人AWS账号默认有S3相关权限，但开发环境的执行角色（EC2实例角色、Lambda执行角色、ECS任务角色等）大概率没有配置目标桶的s3:GetObject权限，或者开发环境部署在私有子网未配置S3 VPC端点、安全组出方向未放开443端口访问，会直接触发getObject静默失败。
• 错误处理链路断裂：yauzl回调、流处理回调内的throw err无法被外层Promise捕获，只会导致逻辑静默中断，不会向外抛出异常也不会留下有效错误日志。

修复后代码 #

const unzipFromS3 = async (key) => {
    log.info("inside unzipfroms3");  
    const zlib = require('zlib');
    const Stream = require('stream');
    const options = {
        'Bucket': config.bucketName,
        'Key': "Root/" + key,
    }
    log.info("Key:", options);    

    try {
        // 移除混用的on('error')和.then()，直接await获取结果
        const s3Res = await s3.getObject(options).promise();
        log.info("S3 getObject调用成功，文件大小：", s3Res.Body.length);

        // 把yauzl回调逻辑包装成Promise统一管理状态
        return new Promise((resolve, reject) => {
            yauzl.fromBuffer(s3Res.Body, { lazyEntries: true }, function (err, zipfile) {
                log.info("Inside Yauzl");
                if (err) {
                    log.error("yauzl解析压缩包失败：", err);
                    return reject(err);
                }
                
                let processedCount = 0;
                let totalEntries = 0;

                zipfile.on("entry", function (entry) {
                    totalEntries++;
                    if (/\/$/.test(entry.fileName)) {
                        zipfile.readEntry();
                    } else {
                        zipfile.openReadStream(entry, function (err, readStream) {
                            if (err) {
                                log.error("打开压缩包条目流失败：", err);
                                return reject(err);
                            }
                            
                            const pass = new Stream.PassThrough();
                            const uploadParams = {
                                Bucket: config.bucketName,
                                Key: entry.fileName,
                                Body: pass
                            };

                            // 上传完成后再处理下一个条目
                            s3.upload(uploadParams, function (err, data) {
                                if (err) {
                                    log.error("S3上传失败：", err);
                                    return reject(err);
                                }
                                log.info("文件上传成功：", entry.fileName);
                                processedCount++;
                                readStream.on("end", function () {
                                    // 所有条目处理完成后resolve
                                    if (processedCount === totalEntries) {
                                        return resolve({ status: 'success', processedFiles: processedCount });
                                    }
                                    zipfile.readEntry();
                                });
                            });
                            readStream.pipe(pass);
                        });
                    }
                });

                zipfile.on("end", () => {
                    log.info("压缩包所有条目遍历完成");
                });

                zipfile.on("error", (err) => {
                    log.error("压缩包处理出错：", err);
                    reject(err);
                });

                zipfile.readEntry();
            });
        });
    } catch (err) {
        log.error("unzipFromS3整体执行失败：", err);
        throw err;
    }
};

开发环境额外排查项 #

• 确认开发环境执行代码的IAM角色已经配置了目标桶的s3:GetObject、s3:PutObject权限
• 如果服务部署在VPC私有子网，确认已经配置S3网关端点或接口端点，且端点策略允许访问目标桶
• 确认开发环境安全组出方向放开了443端口对S3服务的访问
• 可在调用getObject前先调用s3.listBuckets()测试开发环境的S3连通性和权限是否正常

内容的提问来源于stack exchange，提问作者LUCKY SHARMA