AWS Lambda含Timer逻辑阻塞并发问题求助

你的核心问题在于在Lambda内部做长时间阻塞等待完全违背了Lambda的设计模式——Lambda是为短周期、无状态的任务设计的，长时间的sleep或循环等待会占用实例资源，不仅浪费成本，还会导致并发请求无法及时获得新实例（尤其是当并发数接近限制时），甚至出现请求被丢弃的情况。

正确的解决方案：用EventBridge实现延迟触发 #

放弃在Lambda内部等待，改用AWS EventBridge（原CloudWatch Events）来调度延迟任务，流程如下：

1. 监听DynamoDB更新的Lambda（触发Lambda）：检测到目标条目更新为特定值后，立即向EventBridge提交一个5分钟后触发的一次性事件，然后快速结束执行，释放实例。
2. 专门负责发邮件的Lambda（邮件Lambda）：等待EventBridge的延迟事件触发，执行发邮件逻辑。

这种方式下，每个DynamoDB更新请求都会触发独立的触发Lambda实例，不会互相阻塞，所有延迟逻辑交给EventBridge处理，完全符合Serverless的设计理念。

代码示例 #

触发Lambda（监听DynamoDB Stream）

import boto3
import time
import uuid

def lambda_handler(event, context):
    # 解析DynamoDB Stream事件，判断是否符合触发条件
    record = event['Records'][0]['dynamodb']
    new_image = record['NewImage']
    # 假设我们需要当status字段变为"completed"时触发邮件
    if new_image.get('status', {}).get('S') != 'completed':
        return {'statusCode': 200, 'message': '无需触发邮件'}
    
    # 生成唯一规则名，避免重复
    rule_id = uuid.uuid4().hex
    rule_name = f"delayed-email-trigger-{rule_id}"
    eventbridge = boto3.client('events')
    
    # 设置5分钟后的触发时间
    delay_seconds = 300
    target_timestamp = int(time.time()) + delay_seconds
    schedule_expr = f"at({time.strftime('%Y-%m-%dT%H:%M:%SZ', time.gmtime(target_timestamp))})"
    
    # 创建一次性EventBridge规则
    eventbridge.put_rule(
        Name=rule_name,
        ScheduleExpression=schedule_expr,
        State='ENABLED',
        Description=f"Trigger email for DynamoDB item {record['Keys']['id']['S']}"
    )
    
    # 将邮件Lambda设为规则目标，并传递DynamoDB条目信息
    eventbridge.put_targets(
        Rule=rule_name,
        Targets=[
            {
                'Id': '1',
                'Arn': 'arn:aws:lambda:你的区域:你的账户ID:function:SendEmailLambda',
                'Input': str({
                    'item_id': record['Keys']['id']['S'],
                    'details': new_image
                })
            }
        ]
    )
    
    return {'statusCode': 200, 'message': '延迟邮件任务已调度'}

邮件Lambda（执行发邮件逻辑）

import boto3
import smtplib

def lambda_handler(event, context):
    # 解析EventBridge传递的条目信息
    item_info = event
    # 这里替换为你的发邮件逻辑
    send_email(item_info['item_id'], item_info['details'])
    
    # 清理对应的EventBridge规则（避免残留无用规则）
    eventbridge = boto3.client('events')
    # 从上下文获取规则名（或者你可以在Input里传递规则名）
    rule_name = context.invoked_function_arn.split(':')[-1] + '-' + context.aws_request_id[:8]
    eventbridge.remove_targets(Rule=rule_name, Ids=['1'])
    eventbridge.delete_rule(Name=rule_name)
    
    return {'statusCode': 200, 'message': '邮件发送成功'}

def send_email(item_id, details):
    # 实现你的SMTP发送逻辑，比如用SES
    ses = boto3.client('ses')
    ses.send_email(
        Source='your-email@example.com',
        Destination={'ToAddresses': ['recipient@example.com']},
        Message={
            'Subject': {'Data': f"条目更新通知: {item_id}"},
            'Body': {'Text': {'Data': f"条目详情: {str(details)}"}}
        }
    )

为什么之前的方式不行？ #

1. 资源占用：time.sleep()或循环等待会让Lambda实例一直处于运行状态，无法被复用，并发请求需要等待新实例启动（甚至因为并发限制无法启动）。
2. 成本浪费：Lambda按执行时间收费，5分钟的等待时间会产生不必要的费用。
3. 执行时间限制：Lambda最长执行时间为15分钟，如果你的延迟超过这个时间，函数会被强制终止。

替代方案：AWS Step Functions #

如果你的流程更复杂（比如需要中途检查状态），可以用Step Functions的Wait状态来实现延迟，流程如下：

1. DynamoDB更新触发Step Function
2. Step Function进入Wait状态，等待5分钟
3. 等待结束后调用邮件Lambda执行发送逻辑

这种方式更适合有复杂流程的场景，可视化程度更高。

内容的提问来源于stack exchange，提问作者Pablo Gomez Gracia