无法通过PubSub实现Cloud Function每15分钟定时执行

你的定时Cloud Function无法重复执行、日志不完整，核心是存在触发配置冲突、Cron表达式错误、异步代码未正确处理三个关键问题，以下是具体分析和修复步骤：

一、核心问题诊断 #

1. 重复触发配置导致冲突
   使用functions.pubsub.schedule()时，Firebase会自动创建对应的Cloud Scheduler任务和PubSub主题，不需要手动创建PubSub主题和Eventarc触发器。手动添加的额外触发器会干扰自动生成的定时任务逻辑，导致函数无法按预期重复执行。

2. Cron表达式错误
   你配置的'15 * * * *'表示每小时的第15分钟执行一次，而非每15分钟执行一次。每15分钟执行的正确表达式是'*/15 * * * *'（表示每小时内每隔15分钟触发）。

3. 异步代码未正确等待
   checkAndSendNotifications函数中，query.get()使用了then链式调用，但没有返回Promise或使用await，导致Cloud Function在异步查询和通知发送完成前就提前终止，不仅任务执行不完整，也会导致日志无法完整记录。

4. 日志查看路径错误
   由functions.pubsub.schedule()触发的函数，日志需要在Cloud Functions控制台的日志标签页查看，而非Eventarc触发器的日志，后者仅记录触发器本身的事件，不包含函数执行的详细日志。

二、修复步骤 #

1. 清理冗余配置 #

删除手动创建的PubSub主题和Eventarc触发器，保留Firebase自动生成的资源即可。

2. 修正Cron表达式 #

将schedule的Cron表达式改为'*/15 * * * *'，确保每15分钟触发一次。

3. 修复异步逻辑 #

重构checkAndSendNotifications函数，使用await替代then链式调用，确保所有异步操作完成后函数才结束：

修正后的完整代码 #

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

firebase.initializeApp();

const db = firebase.firestore();

// 修正Cron表达式为每15分钟执行一次
exports.sendDailyNotifications = functions.pubsub.schedule('*/15 * * * *').onRun(async (_) => {
    functions.log('Daily Notification Cloud Function Started');
    // 等待异步任务完成
    await checkAndSendNotifications();
    functions.log('Daily Notification Cloud Function Completed');
});

async function checkIncompleteTasks(userId) {
  // 你的函数代码
}

async function checkIncompleteHabits(userId) {
  // 你的函数代码
}

async function sendNotification(userId) {
  // 你的函数代码
}

function currentTimeRoundedToNearest15Minutes() {
    // 你的时间处理代码
}

async function checkAndSendNotifications() {
  const currentHHMM = currentTimeRoundedToNearest15Minutes();

  const usersRef = db.collection('usersCollection');
  const query = usersRef.where('dailyNotificationTime', '!=', null)
                       .where('dailyNotificationTime', '!=', '')
                       .where('notificationsAllowed', '==', true);
  
  try {
    // 使用await等待查询完成
    const snapshot = await query.get();
    // 遍历文档时，若sendNotification是异步函数，需用Promise.all等待所有通知发送完成
    await Promise.all(snapshot.docs.map(async doc => {
      const userData = doc.data();
      const notificationTime = userData.dailyNotificationTime;

      if (currentHHMM === notificationTime) {
          await sendNotification(doc.id);
          functions.log(`Sending notification to user: ${doc.id}`);
      }
    }));
  } catch (error) {
    functions.log.error('Error fetching users:', error);
    // 抛出错误让Cloud Functions捕获，便于日志记录
    throw error;
  }
}

4. 正确查看日志 #

在Firebase控制台进入Cloud Functions页面，找到sendDailyNotifications函数，点击「日志」标签即可查看完整的函数执行日志；也可使用gcloud命令行工具：

gcloud functions logs read sendDailyNotifications --region=你的函数部署区域

三、额外注意事项 #

• 确保部署函数时使用最新的Firebase CLI版本，避免版本兼容问题：npm install -g firebase-tools
• 若sendNotification函数涉及异步操作（如调用FCM API），必须使用await等待其完成，否则会导致通知发送不完整。

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