如何通过Firebase Cloud Function实现UTC适配的定时通知？

一、切换为UTC时间的解决方案 #

当前代码硬编码了Asia/Kolkata时区，导致仅该时区的时间匹配逻辑生效。要实现跨时区兼容，需统一使用UTC时间处理，同时调整Firestore的存储字段格式：

1. 调整时间匹配逻辑（推荐用时间戳，避免字符串歧义） #

字符串格式化的时间存在格式不统一风险，优先使用毫秒级UTC时间戳处理：

• 存储通知时：将预约时间提前5分钟的UTC时间戳（预约时间UTC - 5*60*1000）存入Firestore的triggerTimestamp字段，同时新增sent字段标记是否已发送（默认false）。
• 云函数中获取当前UTC时间戳，查询需要触发的通知：

  const currentUtcTimestamp = Date.now(); // 当前UTC毫秒时间戳
  const query = await database.collection("notification")
    .where("triggerTimestamp", "<=", currentUtcTimestamp)
    .where("sent", "==", false)
    .get();
  

2. 若坚持使用字符串格式（不推荐） #

将时区改为UTC，同时确保Firestore中存储的time字段也是UTC格式化后的字符串：

const options = { 
  day: 'numeric', 
  month: 'long', 
  year: "numeric", 
  hour: '2-digit', 
  minute: '2-digit', 
  timeZone: "UTC" // 替换为UTC时区
};
const currentUtcTime = day.toLocaleDateString("en-IN", options);
const query = await database.collection("notification").where("time", "==", currentUtcTime).get();

二、当前定时实现方式的合理性分析 #

现有方案的优缺点 #

• 优点：实现逻辑简单，依赖Firebase Pub/Sub定时功能即可快速落地，适合中小规模通知场景。
• 缺点：
  • 资源浪费：即使无通知需要发送，每分钟仍会触发一次函数调用，增加不必要的成本。
  • 延迟风险：最多可能延迟1分钟发送（比如触发时间在0分59秒，需等到下一分钟调度执行）。
  • 并发隐患：若同一分钟有大量通知，函数执行时间可能超出云函数默认90秒的超时限制。

更优替代方案 #

如果通知量增长或对发送精度有要求，推荐为每个预约创建一次性定时任务：
当自有服务器API生成预约时，直接调用云函数创建一个触发时间为「预约前5分钟UTC时间」的一次性定时任务，无需轮询Firestore。示例思路：

// 用于创建定时通知的云函数（自有服务器/Flutter端调用）
exports.scheduleNotification = functions.https.onCall(async (data) => {
  const { userId, title, body, triggerTimeUtc } = data;
  // 创建一次性定时任务
  await functions.pubsub.schedule(triggerTimeUtc)
    .timeZone('UTC')
    .onRun(async () => {
      const message = {
        token: userId,
        notification: { title, body },
        data: { click_action: "FLUTTER_NOTIFICATION_CLICK" }
      };
      await admin.messaging().send(message);
    });
  return { success: true };
});

总结 #

• 若通知量小、对延迟不敏感，当前轮询方案可继续使用，但必须切换为UTC时间统一处理。
• 若追求更高效率和精度，建议改用一次性定时任务方案，避免轮询的资源浪费和延迟问题。

修正后的完整代码（UTC时间戳版本） #

const admin = require("firebase-admin");

admin.initializeApp();
const database = admin.firestore();

exports.sendNotification = functions.pubsub.schedule("* * * * *")
  .timeZone("UTC")
  .onRun(async (context) => {
    const currentUtcTimestamp = Date.now();

    // 查询待发送的通知
    const query = await database.collection("notification")
      .where("triggerTimestamp", "<=", currentUtcTimestamp)
      .where("sent", "==", false)
      .get();

    // 批量处理，避免异步阻塞
    const processPromises = [];
    for (const snapshot of query.docs) {
      processPromises.push(handleNotification(snapshot.id, snapshot.data()));
    }

    await Promise.all(processPromises);
    console.log("End Of Function");
    return null;
  });

async function handleNotification(id, notificationData) {
  try {
    const message = {
      condition: notificationData.userid.length === 1 
        ? notificationData.userid[0] 
        : notificationData.userid.join("||"),
      notification: {
        title: notificationData.title,
        body: notificationData.body
      },
      data: {
        id: id,
        click_action: "FLUTTER_NOTIFICATION_CLICK"
      }
    };

    await admin.messaging().send(message);
    // 标记为已发送（也可直接删除文档）
    await database.collection("notification").doc(id).update({ sent: true });
    console.log(`Notification ${id} sent successfully`);
  } catch (error) {
    console.log(`Failed to send notification ${id}:`, error);
  }
}

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