如何获取GCP Cloud Scheduler的唯一事件标识符以防止Cloud Function重复触发？

我来帮你理清这个问题的关键细节，以及可行的解决方案：

首先，针对你的核心疑问：

• 上下文对象的eventId：当Cloud Function被Pub/Sub触发时，这个eventId其实对应Pub/Sub消息的messageId。如果是Pub/Sub自身的重试投递（比如Function第一次执行失败，Pub/Sub自动重试），messageId会保持不变；但如果是Cloud Scheduler因为投递失败而重新生成Pub/Sub消息（比如第一次发送Pub/Sub超时），这时候会生成新的messageId，导致eventId变化。所以单独用eventId不能完全覆盖所有重复场景。

• 真正可靠的唯一标识组合：Cloud Scheduler在发送给Pub/Sub的消息属性中，会自动添加几个关键元数据，其中：

  • scheduler.googleapis.com/job_name：你的调度任务的完整资源名称（比如projects/your-project/locations/us-central1/jobs/your-scheduled-job），标识是哪个任务触发的
  • scheduler.googleapis.com/schedule_time：触发的精确时间戳（RFC3339格式，比如2024-05-20T01:00:00Z），对应你调度任务的原定触发时间

  这两个值的组合是全局唯一的——同一个调度任务在同一个时间点的触发（包括所有重试），job_name和schedule_time完全相同；不同时间的触发或者不同任务的触发，这个组合都会不一样。这是判断是否为同一触发实例的最可靠依据。

另外，消息属性里还有schedule_time的毫秒级时间戳版本scheduler.googleapis.com/schedule_time_epoch，如果你喜欢用数字格式存储，也可以用这个替代schedule_time。

具体实现步骤 #

1. 在Cloud Function中，从Pub/Sub消息的属性里提取job_name和schedule_time（或schedule_time_epoch）
2. 生成一个唯一键（比如将两个值拼接后做哈希，或者直接用job_name + "_" + schedule_time作为Datastore的键名）
3. 检查Datastore中是否存在这个键：
   • 如果存在，说明这个触发实例已经处理过，直接返回成功，跳过业务逻辑
   • 如果不存在，执行你的业务逻辑，完成后将这个键写入Datastore，标记为已处理

这样就能完美避免重复触发带来的重复执行问题，完全适配Cloud Scheduler的“至少一次”投递语义。

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