AWS Lambda执行未终止排查：S3上传CSV缺ChannelType列

1. Stream异步操作未被等待：existsChannel是async函数，但内部处理Stream的end事件是回调式异步，函数没有返回Promise来等待该事件完成，导致函数提前执行完毕，Lambda认为任务已完成，不会终止流程。
2. 错误未正确向上传递：
   • end事件回调里抛出的错误不在函数的try/catch范围内，无法被捕获；
   • existsChannel的try/catch仅打印错误却不重新抛出，导致外层handler的try/catch接收不到错误信号。
3. CSV解析逻辑不严谨：直接用split(',')分割整段文本，会把CSV单元格内的逗号（如"abc,def"）也当成分隔符，可能导致列名判断错误。

重构existsChannel函数，用Promise封装Stream读取流程，确保异步操作被正确等待，同时规范错误传递：

const { GetObjectCommand, S3Client } = require('@aws-sdk/client-s3');
const region = process.env.REGION;
const clientS3 = new S3Client({ region: region });

exports.handler = async (event, context) => {
    try {
        const key = event.Records[0].s3.object.key;
        const bucket = event.Records[0].s3.bucket.name;

        await existsChannel(bucket, key);

        // 后续业务逻辑
        
    } catch (error) {
        console.error(error.message);
        // 抛出错误终止Lambda执行
        throw error;
    }
};

const existsChannel = async (bucket, key) => {
    const params = {
        Bucket: bucket,
        Key: key,
    };

    const command = new GetObjectCommand(params);
    const response = await clientS3.send(command);
    const stream = response.Body;

    // 用Promise封装Stream读取流程
    return new Promise((resolve, reject) => {
        const chunks = [];
        stream.on('data', (chunk) => chunks.push(chunk));
        stream.on('error', (err) => reject(err));
        stream.on('end', () => {
            try {
                const content = Buffer.concat(chunks).toString('utf8');
                // 仅取第一行作为表头解析，避免整段分割的错误
                const headers = content.split('\n')[0].trim().split(',');
                console.log('CSV表头:', headers);
                if (!headers.includes('ChannelType')) {
                    reject(new Error("ChannelType not found"));
                    return;
                }
                resolve(true);
            } catch (err) {
                reject(err);
            }
        });
    });
};

• Promise封装Stream：让existsChannel函数等待Stream读取完成后再返回，确保外层await能正确等待异步操作。
• 统一错误传递：Stream读取错误和表头检查失败的错误都通过Promise的reject抛出，确保能被外层try/catch捕获。
• 外层抛出错误终止执行：handler的catch块中重新抛出错误，Lambda会将未捕获的错误视为执行失败，直接终止流程。
• 优化表头解析：仅取CSV第一行作为表头分割，避免整段文本split导致的列名判断错误。

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