Dev环境下Lambda1抢先消费S3事件致Lambda2异常的解决方案咨询

1. 细化S3事件通知的过滤规则 #

给Lambda1和Lambda2分别配置不同的前缀/后缀过滤条件，彻底隔离两者的触发范围：

• 把Lambda2的测试文件上传到S3的专属前缀路径，比如s3://your-bucket/test-lambda2/，给Lambda2的事件通知设置前缀test-lambda2/；同时给Lambda1的事件通知添加排除规则，或者让它只监听原有业务路径的前缀。
• 也可以按文件后缀区分，比如测试文件用.lambda2-test后缀，Lambda2只监听该后缀，Lambda1的过滤规则排除这类后缀。

配置时直接在S3桶的事件通知页面，针对每个Lambda触发器单独设置过滤规则即可。

2. 用S3对象标签做处理逻辑分流 #

上传测试文件时给对象添加专属标签，比如ProcessTarget: lambda2：

• Lambda1在处理前先检查对象标签，只要发现标签值为lambda2就直接跳过，不执行后续处理。
• Lambda2则只处理带有ProcessTarget: lambda2标签的对象。

Lambda1的示例代码片段：

import boto3

s3 = boto3.client('s3')

def lambda_handler(event, context):
    for record in event['Records']:
        bucket = record['s3']['bucket']['name']
        key = record['s3']['object']['key']
        # 获取对象标签
        tag_response = s3.get_object_tagging(Bucket=bucket, Key=key)
        tag_map = {t['Key']: t['Value'] for t in tag_response['TagSet']}
        # 命中lambda2专属标签则跳过
        if tag_map.get('ProcessTarget') == 'lambda2':
            continue
        # 原有业务处理逻辑...

3. 临时调整Lambda的并发/触发优先级（仅临时验证用） #

• 临时把Lambda1的预留并发数设为1，同时给Lambda2设置更高的预留并发，提升Lambda2抢事件的优先级（注意：这个方法不是100%可靠，只能降低冲突概率，适合短时间验证）。
• 或者在Lambda1的代码开头加1-2秒的延迟，给Lambda2留出触发处理的窗口，验证完成后立刻移除延迟。

4. 用独立测试桶做验证 #

创建一个和生产桶结构完全一致的测试S3桶，专门用于Lambda2的验证：

• 把Lambda2的触发器指向这个测试桶，所有测试文件都上传到这里，完全不干扰Lambda1的运行环境。
• 验证通过后，再把Lambda2的触发器切回原桶，同步配置好过滤规则后上线。

5. 引入SQS做事件路由缓冲 #

在S3和Lambda之间加一层SQS队列，实现更灵活的事件分流：

• 给S3配置事件通知，把所有对象事件发送到SQS队列。
• 给Lambda1和Lambda2分别配置SQS触发器，同时利用SQS的消息过滤规则，让各自只处理符合自身规则的消息（比如基于S3对象的前缀、标签）。
• 这种方式不仅能解决当前冲突，还能为后续流程拆分提供更好的扩展能力。

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