如何限制GCP Cloud Storage存储桶同一时间仅允许单个进程访问

首先明确两个核心问题的结论：

1. GCP不会自动提供Cloud Storage存储桶的全局独占访问能力，也不会默认让Cloud Function串行执行，相关能力需要你额外配置或实现。
2. 自行实现的信号量机制没有自动执行后续请求的能力，你需要配套做任务排队重试逻辑。

针对你的场景的可落地方案 #

方案1：直接限制Cloud Function并发（成本最低，满足你要的"前一次执行完成再触发下一次"需求） #

• 进入Cloud Function的配置页面，将最大并发实例数设置为1即可。
• 该配置生效后，同一时间只会有1个函数实例运行，后续触发的所有请求会被GCP自动放到内部队列排队，上一个执行完成后会自动按顺序处理排队的请求，完全不需要你自己实现锁或信号量。
• 注意事项：Cloud Function的事件队列默认上限是1000条，如果你业务触发频率极高，超出队列上限的请求会被丢弃，该方案更适合触发频率较低的场景。

方案2：不限制函数并发，用分布式锁避免存储桶操作竞态 #

如果你的业务不能接受限制函数并发，可以通过以下GCP原生能力实现独占访问：

• Cloud Storage乐观锁：给存储桶开启对象版本控制，每次更新对象时携带你读取对象时拿到的generation参数，只有当前对象的版本和你读取的版本一致时，更新才会生效，否则会返回冲突错误，你可以在Python代码里增加重试逻辑处理冲突场景。
• 分布式信号量/锁：用Cloud Memorystore（Redis）或者Firestore存储锁标识，Python代码执行存储桶操作前先尝试获取锁，获取成功才执行后续操作，执行完成后释放锁。
• 自行实现锁的情况下，没有抢到锁的请求不会自动延后执行，你需要对接Cloud Tasks这类队列服务，将没抢到锁的任务存入队列，设置延后重试规则，等锁释放后再执行。

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