Node.js版AWS Lambda从SQS存IoT数据到S3报错求助

错误根源分析 #

你的代码存在几个核心问题，直接导致了这个报错：

1. S3Client初始化参数错误：S3Client的构造函数接收的是客户端配置（比如AWS区域），而非Bucket和Key。Bucket和Key是PutObjectCommand的请求参数，不该放在Client初始化里。
2. PutObjectCommand参数传递错误：你把S3Client实例传给了PutObjectCommand，正确的做法是传递包含Bucket、Key、Body的请求对象。
3. 异步调用未等待：handler里用forEach循环调用异步函数putInS3时没有加await，Lambda会在S3上传完成前就终止执行，导致上传失败。
4. S3 Key格式不合法：原Key末尾带斜杠且没有具体文件名，S3无法创建有效的对象。

修正后的完整代码 #

import { S3Client, PutObjectCommand } from "@aws-sdk/client-s3";

// 初始化S3Client，替换为你的AWS区域
const s3Client = new S3Client({ region: "us-east-1" });

export const putInS3 = async (deviceName, year, month, day, data) => {
    const bucketName = "my-bucket-name";
    // 生成合法的S3 Key：设备名/年/月/日/时间戳.json
    const key = `${deviceName}/${year}/${month}/${day}/${Date.now()}.json`;
    try {
        // 构造PutObjectCommand的请求参数
        const command = new PutObjectCommand({
            Bucket: bucketName,
            Key: key,
            Body: JSON.stringify(data), // 将IoT数据转为JSON字符串作为对象内容
            ContentType: "application/json" // 指定内容类型，方便后续读取
        });
        const response = await s3Client.send(command);
        console.log(`数据已成功上传到S3，Key: ${key}`, response);
    } catch (err) {
        console.error(`上传S3失败，Key: ${key}`, err);
        throw err; // 抛出错误方便上层处理
    }
};

export const handler = async (event) => {
    const date = new Date();
    const year = date.getFullYear();
    // 月份补前导零，确保格式统一（比如1月变成01）
    const month = String(date.getMonth() + 1).padStart(2, '0');
    const day = String(date.getDate()).padStart(2, '0');

    // 使用Promise.all等待所有上传完成
    await Promise.all(event.Records.map(async (record) => {
        const body = JSON.parse(record.body);
        const deviceName = body.device_name;
        console.log(`处理设备${deviceName}的数据:`, body);
        await putInS3(deviceName, year, month, day, body);
    }));

    return {
        statusCode: 200,
        body: JSON.stringify({ message: "所有数据已成功处理并上传到S3" })
    };
};

关键修改说明 #

• S3Client全局初始化：把S3Client放在函数外初始化，避免每次Lambda调用都创建新的客户端实例，提升性能。
• PutObjectCommand参数修正：正确传递Bucket、Key和Body，同时指定ContentType让S3对象更规范。
• 异步调用等待：用Promise.all配合map替代forEach，确保所有S3上传请求都完成后Lambda才结束。
• Key格式优化：添加时间戳作为文件名，避免同一目录下的文件被覆盖，同时给月份和日期补前导零，保证路径格式统一。
• 错误处理优化：在putInS3中抛出错误，确保上传失败时能被上层捕获，方便排查问题。

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