Firebase/GCP Cloud Functions重复执行问题求解决方案

1. 强化PubSub触发函数的配置与幂等性 #

• 确认重试配置生效：显式设置maxAttempts:1配合retry:false，避免部署时配置歧义：

  exports.bgTask = functions.pubsub.topic('your-topic').onPublish(async (message) => {
    // 业务逻辑
  }, {
    retry: false,
    maxAttempts: 1
  });
  

• 添加消息唯一标识校验：利用PubSub消息的messageId作为唯一键，用Firestore/Redis做幂等校验，确保同一条消息只触发一次webServer调用：

  const firestore = admin.firestore();
  
  exports.bgTask = functions.pubsub.topic('your-topic').onPublish(async (message) => {
    const messageId = message.messageId;
    const processingFlag = firestore.collection('task_tracker').doc(messageId);
  
    // 原子检查：已处理则直接返回
    const snapshot = await processingFlag.get();
    if (snapshot.exists) {
      console.log(`Message ${messageId} already processed`);
      return null;
    }
  
    // 标记为正在处理
    await processingFlag.set({ processed: true, timestamp: admin.firestore.FieldValue.serverTimestamp() });
  
    try {
      // 等待webServer调用完成，避免函数提前结束
      await axios.post('https://your-webserver-url', {
        requestId: messageId,
        payload: message.json
      });
      await processingFlag.update({ status: 'success' });
    } catch (err) {
      console.error(`Call webServer failed: ${err}`);
      await processingFlag.update({ status: 'failed', error: err.message });
      // 不抛出错误，避免触发重试
      return null;
    }
  }, { retry: false, maxAttempts: 1 });
  

2. 给HTTP函数添加幂等防护 #

即使bgTask意外重复调用，webServer自身也要能识别重复请求：

exports.webServer = functions.https.onRequest(async (req, res) => {
  const requestId = req.body.requestId;
  if (!requestId) return res.status(400).send('Missing requestId');

  const firestore = admin.firestore();
  const requestFlag = firestore.collection('webserver_tracker').doc(requestId);
  const snapshot = await requestFlag.get();

  if (snapshot.exists) {
    return res.status(200).send('Request already processed');
  }

  await requestFlag.set({ processed: true });
  try {
    // 执行核心业务逻辑
    await yourCoreBusinessLogic(req.body.payload);
    await requestFlag.update({ status: 'success' });
    res.status(200).send('Success');
  } catch (err) {
    console.error(`WebServer failed: ${err}`);
    await requestFlag.update({ status: 'failed', error: err.message });
    res.status(500).send('Failed');
  }
});

3. 排查GCP环境的特殊配置问题 #

• 调整函数超时与并发：将bgTask的超时时间设为大于webServer的预期执行时间（最大支持9分钟），同时可临时将maxInstances设为1，避免多实例同时处理同一条消息。
• 检查PubSub订阅的ackDeadline：如果bgTask处理时间超过订阅的ackDeadline，PubSub会重新投递消息。手动调整ackDeadline至大于函数执行时间，或在函数中调用API延长ackDeadline。

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