如何对Pub/Sub触发的Google Cloud Function消息执行nack操作以便后续重发

首先明确前提：由Pub/Sub推送触发的云函数，底层默认由Google Cloud托管的订阅负责和Pub/Sub服务交互，云函数本身没有直接调用Pub/Sub NACK接口的原生能力，你可以通过以下两种方案实现类似NACK的重投效果：

• 方案1：抛出未捕获的异常触发重投
  这是最简便的实现方式。当你处理消息失败需要重投时，直接在函数代码中抛出未被捕获的异常即可。托管的Pub/Sub订阅会识别到函数执行失败，自动对该消息执行NACK操作，消息会回到订阅队列，按照你提前配置的重试间隔重新投递。

  注意：你需要提前在云函数的触发器配置中，设置合理的最大重试次数和消息保留时长，避免消息无限重试占用资源。
  Node.js环境示例代码：

  exports.pubsubHandler = async (message, context) => {
    try {
      // 你的业务逻辑
      const data = JSON.parse(Buffer.from(message.data, 'base64').toString());
      await processBusiness(data);
    } catch (err) {
      // 业务处理失败，抛出异常触发NACK重投
      throw new Error(`消息处理失败，触发重投: ${err.message}`);
    }
  };
  

  Python环境示例代码：

  def pubsub_handler(event, context):
      import base64
      import json
      try:
          data = json.loads(base64.b64decode(event['data']).decode('utf-8'))
          process_business(data)
      except Exception as e:
          # 抛出异常触发重投
          raise RuntimeError(f"处理失败触发重投: {str(e)}")
  

• 方案2：手动调用Pub/Sub客户端SDK执行NACK
  如果你需要更精细化的控制（比如部分成功部分失败、自定义NACK时机），可以在代码中引入Pub/Sub官方SDK，手动拿到消息的ack_id和订阅信息，主动调用NACK接口。
  操作步骤：

  1. 提前给云函数的服务账号授予roles/pubsub.subscriber权限，确保有权限调用订阅的NACK接口
  2. 代码中构造Pub/Sub客户端，获取当前消息对应的订阅路径、ack_id，调用modify_ack_deadline方法将确认超时时间设为0，即可实现NACK效果
     Python环境示例代码：

  from google.cloud import pubsub_v1
  
  subscriber = pubsub_v1.SubscriberClient()
  # 替换为你的订阅路径，格式为 projects/{项目ID}/subscriptions/{订阅名}
  SUBSCRIPTION_PATH = "projects/your-project-id/subscriptions/your-subscription-name"
  
  def pubsub_handler(event, context):
      ack_id = event['ackId']
      try:
          # 业务逻辑
          process_business(event)
      except Exception as e:
          # 手动NACK：将ack有效期设为0，消息立即回到队列
          subscriber.modify_ack_deadline(
              request={
                  "subscription": SUBSCRIPTION_PATH,
                  "ack_ids": [ack_id],
                  "ack_deadline_seconds": 0
              }
          )
  

  注意：这种方案需要你提前知道当前触发器对应的订阅名称，适合对重投逻辑有自定义需求的场景。

注意事项 #

• 两种方案都需要你提前在Pub/Sub订阅中配置死信队列（DLQ），避免多次重试失败的消息一直占用队列资源
• 如果云函数执行成功返回了200状态码，托管订阅会自动对消息执行ACK操作，无法再触发重投

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