如何在AWS Lambda中实现锁以避免关键代码段并发运行

方案1：基于S3原生原子写入能力实现分布式锁（最推荐，零新增服务） #

该方案完全复用你当前已使用的S3服务，利用S3全局一致性写入的原子性实现分布式互斥锁，不需要引入任何额外组件：

• 提前在现有触发Lambda的S3桶中创建一个固定前缀的锁目录，例如api-lock/，锁对象的固定key设为third-party-api.lock
• Lambda执行到调用第三方API的代码段前，先发起PutObject请求写入上述锁对象，请求头携带If-None-Match: *参数：该参数是S3原生支持的条件写入规则，仅当锁对象不存在时才会写入成功，否则直接返回412状态码
• 写入成功即代表获取锁成功，立即执行第三方API调用，调用完成后第一时间删除锁对象释放资源
• 如果写入返回412状态码，代表锁已被其他Lambda实例持有，加入指数退避逻辑重试获取锁，最大重试次数可根据业务允许的延迟阈值自定义配置
• 额外增加死锁防护逻辑：写入锁对象时在对象元数据中写入当前时间戳，重试获取锁时如果判断当前锁对象的创建时间已超过预设的超时阈值（建议设置为第三方API最大允许耗时的2倍以上，例如30秒），可直接覆盖写入锁对象获取执行权限，避免Lambda异常中断未释放锁导致的全流程阻塞

方案2：基于Step Functions并发限制实现互斥（适合已接入Step Functions的流程） #

如果你的文件处理流程已经通过Step Functions编排，不需要修改现有逻辑，仅需要做简单的流程拆分即可实现：

• 把调用第三方API的代码段抽成独立的Lambda函数，单独编排为一个Step Functions子流程
• 在该子流程的设置中，将最大并发执行数配置为1，其余处理逻辑仍然保留原有的并行执行能力
• 主流程中所有需要调用第三方API的步骤，统一调用该单并发的子流程即可，Step Functions会自动调度所有请求串行执行，不会出现并行调用的情况

以上两个方案均完全基于你当前的技术栈实现，不需要额外引入数据库、队列等服务，也不会影响非API调用段的文件并发处理性能。

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