Firestore订单状态更新后，延迟执行Firebase云函数的正确方案

你的实现有两个致命问题：

• Firebase云函数是无服务器环境，函数主线程执行完毕后，整个运行环境会被立即回收，setTimeout的回调根本没机会执行。
• 就算你想办法让主线程挂着，云函数的最大运行时长只有9分钟（540秒），你的15分钟延迟远超这个限制，函数会被强制终止。

Cloud Tasks是Google Cloud提供的任务调度服务，专门用来处理延迟或异步执行的任务，完美适配Firebase云函数场景。具体步骤如下：

1. 准备工作 #

• 在Google Cloud控制台开启Cloud Tasks API。
• 安装Cloud Tasks客户端依赖：

  npm install @google-cloud/tasks
  

2. 修改Firestore触发器函数，创建延迟任务 #

当订单状态变为Delivered时，不再用setTimeout，而是创建一个延迟15分钟的Cloud Task，指向专门处理通知的HTTP云函数。

const { CloudTasksClient } = require('@google-cloud/tasks');
const client = new CloudTasksClient();

// 配置Cloud Tasks参数，替换成你的项目信息
const PROJECT_ID = '你的Firebase项目ID';
const LOCATION = '你的函数部署区域（比如us-central1）';
const QUEUE_NAME = 'rate-notification-queue'; // 可以自定义队列名
const FUNCTION_URL = '你的通知处理函数的HTTP地址'; // 后面会创建这个函数

exports.notificationOnDelivered = functions.firestore
  .document('orders/{orderId}')
  .onUpdate(async (change, context) => {
    const after = change.after.data();
    const before = change.before.data();
    
    // 只在状态从非Delivered变为Delivered时触发，避免重复创建任务
    if (after.status === 'Delivered' && before.status !== 'Delivered') {
      const task = {
        httpRequest: {
          httpMethod: 'POST',
          url: FUNCTION_URL,
          body: Buffer.from(JSON.stringify({
            fcmToken: after.uid.fcm_token,
            orderId: context.params.orderId
          })).toString('base64'),
          headers: {
            'Content-Type': 'application/json',
          },
        },
        scheduleTime: {
          seconds: Date.now() / 1000 + 900, // 延迟15分钟（900秒）
        },
      };

      const parent = client.queuePath(PROJECT_ID, LOCATION, QUEUE_NAME);
      await client.createTask({ parent, task });
    }
  });

3. 创建HTTP触发的云函数，处理通知发送 #

这个函数专门负责接收Cloud Tasks的请求，调用OneSignal发送通知：

exports.sendRateNotification = functions.https.onRequest(async (req, res) => {
  try {
    const { fcmToken } = req.body;
    
    const notification = new OneSignal.Notification();
    notification.app_id = ONESIGNAL_APP_ID;
    notification.include_player_ids = [fcmToken];
    notification.contents = {
      en: "Rate your Order"
    };
    notification.headings = {
      en: "Go to -> My orders -> Rate now to rate your order"
    };
    
    await client.createNotification(notification);
    res.status(200).send('Notification sent');
  } catch (error) {
    console.error('Error sending notification:', error);
    res.status(500).send('Failed to send notification');
  }
});

4. 权限配置 #

确保Cloud Tasks服务账号有调用HTTP云函数的权限：

• 在Google Cloud控制台找到你的Cloud Tasks服务账号（格式：service-<项目号>@gcp-sa-cloudtasks.iam.gserviceaccount.com）。
• 给这个账号添加Cloud Functions Invoker角色，使其能调用你的HTTP函数。

如果不想用Cloud Tasks，也可以用这种方式：

• 当订单变为Delivered时，在Firestore的pendingNotifications集合中添加一条记录，包含orderId、fcmToken、executeAt（当前时间+15分钟）。
• 创建一个每分钟运行一次的定时云函数，查询pendingNotifications中executeAt小于当前时间的记录，发送通知后删除该记录。

这种方式的缺点是通知发送时间可能有1分钟左右的误差，不如Cloud Tasks精确，但实现更简单。

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