Firebase Cloud Function实现比赛开始1小时后自动更新ended字段

方案1：定时轮询触发（简单易实现） #

适合对时间精度要求不是特别高的场景，允许几分钟误差。

• 创建定时触发器函数，设置固定间隔（比如每5分钟运行一次）
• 函数逻辑：查询所有未结束（ended: false）且比赛开始已超过1小时的文档，批量更新ended为true

代码示例（Node.js）：

const functions = require("firebase-functions");
const admin = require("firebase-admin");
admin.initializeApp();

// 每5分钟运行一次的定时函数
exports.markExpiredBookingsAsEnded = functions.pubsub.schedule("every 5 minutes").onRun(async (context) => {
  const now = Date.now();
  // 计算时间阈值：当前时间减1小时，筛选startTime早于该值的未结束比赛
  const cutoffTime = now - 3600 * 1000;

  const bookingsRef = admin.firestore().collection("bookings");
  const query = bookingsRef.where("ended", "==", false).where("startTime", "<=", cutoffTime);

  const snapshot = await query.get();
  if (snapshot.empty) {
    functions.logger.info("No expired bookings to update.");
    return null;
  }

  // 批量更新文档
  const batch = admin.firestore().batch();
  snapshot.docs.forEach(doc => {
    batch.update(doc.ref, { ended: true });
  });

  await batch.commit();
  functions.logger.info(`Updated ${snapshot.size} expired bookings.`);
  return null;
});

注意事项：

• 调整定时间隔：若需更高精度，可设为every 1 minutes，但会增加调用次数，需注意成本
• 时区配置：若需基于特定时区计算，可在schedule中添加时区参数，比如schedule("every 5 minutes").timeZone("Asia/Shanghai")

方案2：Cloud Tasks 延迟任务（精准触发） #

适合需要精确在比赛开始1小时后执行更新的场景，无需轮询且效率更高。

步骤： #

1. 创建HTTP触发函数：接收任务请求，更新指定文档的ended字段
2. 创建OnCreate/OnUpdate触发器函数：新增或修改比赛文档时，创建延迟1小时的Cloud Tasks任务（若比赛时间修改，需先取消旧任务）

代码示例（Node.js）：

1. HTTP更新函数

exports.updateBookingEnded = functions.https.onRequest(async (req, res) => {
  const { bookingId } = req.body;
  if (!bookingId) {
    res.status(400).send("Missing bookingId");
    return;
  }

  try {
    const docRef = admin.firestore().collection("bookings").doc(bookingId);
    await docRef.update({ ended: true });
    res.status(200).send("Booking updated successfully");
  } catch (error) {
    functions.logger.error("Error updating booking:", error);
    res.status(500).send("Failed to update booking");
  }
});

2. 创建延迟任务的函数

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

// 替换为你的项目ID、部署区域和Cloud Tasks队列ID
const PROJECT_ID = "your-project-id";
const LOCATION = "us-central1";
const QUEUE_ID = "booking-update-queue";

exports.scheduleBookingEndUpdate = functions.firestore.document("bookings/{bookingId}").onWrite(async (change, context) => {
  const bookingId = context.params.bookingId;
  const newData = change.after.data();
  const oldData = change.before.data();

  // 删除文档时无需处理
  if (!newData) return null;

  const startTime = newData.startTime;
  if (!startTime || newData.ended) {
    // 无开始时间或已结束，无需创建任务
    return null;
  }

  // 计算延迟秒数：startTime加1小时，减去当前时间（确保非负）
  const delaySeconds = Math.max(0, (startTime.toDate().getTime() + 3600 * 1000 - Date.now()) / 1000);

  // 更新文档时，取消旧任务（需提前将旧任务名称存入文档）
  if (oldData && oldData.taskName) {
    try {
      await tasksClient.deleteTask({ name: oldData.taskName });
    } catch (error) {
      functions.logger.warn("Failed to delete old task:", error);
    }
  }

  // 构建任务请求
  const task = {
    httpRequest: {
      httpMethod: "POST",
      url: `https://${LOCATION}-${PROJECT_ID}.cloudfunctions.net/updateBookingEnded`,
      body: Buffer.from(JSON.stringify({ bookingId })).toString("base64"),
      headers: {
        "Content-Type": "application/json",
      },
    },
    scheduleTime: {
      seconds: Math.floor(Date.now() / 1000) + delaySeconds,
    },
  };

  const parent = tasksClient.queuePath(PROJECT_ID, LOCATION, QUEUE_ID);
  const [response] = await tasksClient.createTask({ parent, task });

  // 将任务名称存入文档，方便后续更新时取消旧任务
  await change.after.ref.update({ taskName: response.name });

  functions.logger.info(`Scheduled task for booking ${bookingId} at ${response.scheduleTime}`);
  return null;
});

注意事项：

• 需先在Google Cloud Console创建Cloud Tasks队列
• 配置函数服务账号权限，确保能创建Cloud Tasks任务
• 若比赛时间可能被修改，必须处理旧任务的取消，避免重复更新

为什么setTimeout不可行？ #

Cloud Functions是无服务器环境，付费层最大执行时间限制为9分钟，免费层限制更短。使用setTimeout延迟1小时的话，函数会在超时后被强制终止，无法完成后续更新操作。

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