GCP第二代Cloud Function被Pub/Sub重复触发问题及确认方案咨询

我在GCP中开发了第二代Cloud Function，用于向Shopify批量发送POST请求更新库存。函数本身运行正常，已通过time.sleep控制请求频率避免触发限流，但每次运行完成后，10分钟后函数会自动再次启动，不符合每日执行一次的预期。

该函数由Cloud Scheduler触发，每日在欧洲西部3区（法兰克福）夜间执行。我保留了实例默认配置，未开启任何重试机制（调度器也未设置重试），仅将函数超时时间设为3600秒。已在所有函数中添加return 1，且确认函数实际运行时长小于10分钟，但问题仍未解决。

编辑1：问题疑似出自Cloud Scheduler关联的Pub/Sub组件——如何阻止它10分钟后重发消息？在调度器的设置选项里找不到相关配置。
编辑2：核心问题确认：Pub/Sub在10分钟后未收到消息确认，导致重发。是否可以通过代码在消息送达后立即发送确认/应答，彻底解决重复触发问题？

函数代码示例：

import requests
import pandas as pd
from google.cloud import storage
import time
import json
from google.cloud import bigquery

  
def stock_to_shopify():
  client=bigquery.Client()
  query= """
      SELECT * FROM `XXX.YYY.ZZZ` ORDER BY 1,2,3 LIMIT 400
  """
  query_job = client.query(query)

  headers = {
    'X-Shopify-Access-Token': 'XXX',
    'Content-Type': 'application/json',
  }

  for stock_to_shopify in query_job:
    json_data = {
    'location_id': stock_to_shopify[0],
    'inventory_item_id': stock_to_shopify[1],
    'available': stock_to_shopify[2],
    }

    response = requests.post(
      'https://XXX.myshopify.com/admin/api/2024-04/inventory_levels/set.json',
      headers=headers,
      json=json_data,
    )
    time.sleep(1)

    print(response.text)

  return 1


def main(data,context):
  stock_to_shopify()
  print("run ok")
  return 1

问题的核心是Pub/Sub默认的消息确认超时时间为10分钟——即便你的函数运行时长不足10分钟，只要Pub/Sub在超时前未收到确认信号，就会判定消息未被处理，进而重新推送，导致函数重复执行。

要彻底解决这个问题，只需在函数启动时手动向Pub/Sub发送确认信号，修改main函数即可：

def main(data, context):
    # 立即确认Pub/Sub消息，避免后续重发
    context.ack()
    
    # 执行库存更新逻辑
    stock_to_shopify()
    print("run ok")
    return 1

额外说明 #

• 调用context.ack()后，Pub/Sub会立即标记该消息为已处理，不会再重发，无论后续业务逻辑是否成功执行。如果需要确保库存更新完成后再确认，可以将context.ack()移到stock_to_shopify()执行完成之后，但这种情况下若函数运行接近10分钟，仍可能触发Pub/Sub的超时重发机制。
• 若业务要求必须保证逻辑执行成功才确认消息，建议同时在GCP控制台调整Pub/Sub订阅的确认超时时间（最长可设为600秒），匹配你的函数超时设置，但手动提前确认是解决重复触发问题最直接的方式。

内容的提问来源于stack exchange，提问作者lookerstudiobible.com