Lambda预置并发定时调度方案：EventBridge自动化配置实战

业务场景与技术挑战

在典型的B端SaaS业务场景中，工作日早高峰（如9:00-10:00）往往会出现客户端请求的集中爆发。当Lambda函数的并发扩容速率超出账户级别的Burst Concurrency Limit时，将触发Throttle限流，直接影响用户体验和业务可用性。

针对此类问题，通常有两条优化路径：

• 长期优化：缩短Lambda执行时间（Duration），优化下游服务调用链路
• 短期见效：配置预置并发（Provisioned Concurrency），消除Init阶段的冷启动延迟

从实践角度看，代码层面的优化需要持续迭代，而预置并发可在配置后立即生效。但需注意，预置并发会产生持续性费用，因此需要结合业务流量特征实现按需启停，避免非高峰时段的资源浪费。

前置准备：Lambda版本与别名管理

预置并发仅支持配置到版本或别名，不能直接配置到$LATEST。从运维实践角度，强烈建议使用别名（Alias）而非版本号，原因如下：

• 调用方代码无需随版本发布而变更
• 预置并发配置可绑定固定别名，与版本发布解耦
• 支持流量切换和灰度发布

以下是在CI/CD流水线中实现版本发布与别名切换的参考脚本：

for i in ${FUNCTION_NAME}; do
    # 上传代码并等待更新完成
    aws lambda update-function-code \
        --function-name $i \
        --zip-file fileb://${UPDATE_ZIP_NAME} \
        --output json | jq -r '.FunctionName'
    
    aws lambda wait function-updated --function-name $i
    
    # 发布新版本
    LAMBDA_VERSION=$(aws lambda publish-version \
        --function-name $i \
        --query 'Version' \
        --output text)
    
    # 更新或创建别名指向新版本
    if ! aws lambda update-alias \
        --function-name $i \
        --name provisioned \
        --function-version $LAMBDA_VERSION; then
        aws lambda create-alias \
            --function-name $i \
            --name provisioned \
            --function-version $LAMBDA_VERSION
    fi
    
    # 清理旧版本，保留最近4个
    aws lambda list-versions-by-function --function-name $i \
        --query 'Versions[].Version' --output text | \
        tr '\t' '\n' | grep -E '^[0-9]+$' | \
        grep -v -F -f <(aws lambda list-aliases --function-name $i \
            --query 'Aliases[].FunctionVersion' --output text | tr '\t' '\n') | \
        sort -rn | tail -n +4 | \
        xargs -r -I {} aws lambda delete-function --function-name $i --qualifier {}
done

预置并发配置方式对比

方式一：控制台手动配置

适用于测试验证或临时调整场景。路径：Lambda控制台 → 配置 → 并发 → 预置并发配置 → 添加，选择目标别名并填写并发数值。

方式二：Application Auto Scaling

适用于需要基于指标或时间表进行动态伸缩的场景。需通过AWS CLI配置：

# 注册可扩展目标
aws application-autoscaling register-scalable-target \
    --service-namespace lambda \
    --scalable-dimension lambda:function:ProvisionedConcurrency \
    --resource-id function:my-function:my-alias \
    --min-capacity 10 \
    --max-capacity 100

# 创建定时扩展策略
aws application-autoscaling put-scheduled-action \
    --service-namespace lambda \
    --scalable-dimension lambda:function:ProvisionedConcurrency \
    --resource-id function:my-function:my-alias \
    --scheduled-action-name weekday-morning-scaling \
    --schedule "cron(0 9 ? * MON-FRI *)" \
    --scalable-target-action MinCapacity=50,MaxCapacity=200

方式三：EventBridge + Lambda自动化（推荐）

利用EventBridge Scheduler定时触发管理Lambda，通过boto3 API动态配置目标函数的预置并发。此方案具备以下优势：

• Serverless架构：无需维护底层资源，天然高可用
• 策略灵活：定时规则可随时调整，支持复杂调度逻辑
• 可扩展性强：可集成飞书、钉钉等Webhook实现运维通知

方式四：AWS CLI脚本

适用于一次性操作或集成到现有运维脚本：

# 设置预置并发
aws lambda put-provisioned-concurrency-config \
    --function-name my-lambda-function \
    --qualifier PROD \
    --provisioned-concurrent-executions 1000

# 删除预置并发配置
aws lambda delete-provisioned-concurrency-config \
    --function-name my-lambda-function \
    --qualifier PROD

EventBridge + Lambda方案实施详解

IAM角色权限配置

管理Lambda需要具备预置并发操作权限及CloudWatch Logs写入权限：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": [
                "lambda:PutProvisionedConcurrencyConfig",
                "lambda:DeleteProvisionedConcurrencyConfig",
                "lambda:GetProvisionedConcurrencyConfig"
            ],
            "Resource": [
                "arn:aws-cn:lambda:*:*:function:*:*"
            ]
        },
        {
            "Effect": "Allow",
            "Action": [
                "logs:CreateLogGroup",
                "logs:CreateLogStream",
                "logs:PutLogEvents"
            ],
            "Resource": "*"
        }
    ]
}

信任关系配置，允许Lambda服务承担此角色：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "Service": "lambda.amazonaws.com"
            },
            "Action": "sts:AssumeRole"
        }
    ]
}

架构设计建议

在生产环境实施时，建议遵循以下最佳实践：

• 将预置并发数值配置为环境变量，便于调整而无需修改代码
• 实现幂等性检查，避免重复配置导致的异常
• 集成告警通知（如飞书Webhook），提升配置变更的可见性
• 配置错误重试和死信队列，确保调度任务的可靠执行