如何通过定时Pub/Sub函数匹配时间并更新Firestore字段？

嘿，我看了你这段用来通过Pub/Sub触发更新Firestore字段的代码，发现几个关键问题需要调整，咱们一步步把它修正到能正常工作：

首先，先给你贴出修正后的完整代码：

const admin = require('firebase-admin');
// 初始化Firebase Admin SDK（Cloud Functions环境下会自动获取凭据）
admin.initializeApp();

exports.updateDraftStatus = async (event, context) => {
  // 如果不需要处理Pub/Sub消息内容，可以注释掉下面两行
  const pubsubMessage = event.data;
  console.log(Buffer.from(pubsubMessage, 'base64').toString());

  const db = admin.firestore();
  // 获取当前时间的Timestamp对象
  const currentTime = admin.firestore.Timestamp.fromMillis(Date.now());
  
  // 修正where查询条件：需要指定操作符"=="
  const snap = await db.collection("leagues").where("startTime", "==", currentTime).get();
  
  // 并行更新所有匹配的文档
  await Promise.all(snap.docs.map(doc => {
    return doc.ref.update({ Started: 'Off' });
  }));

  console.log(`更新了${snap.size}个联赛的状态`);
};

接下来给你解释下主要的修改点：

• 初始化Admin SDK：原代码里直接用了admin.firestore()但没初始化SDK，在Cloud Functions环境下必须先调用admin.initializeApp()才能访问Firestore资源。
• 标记函数为async：因为代码里用到了await关键字，必须把函数声明为异步函数，否则会报错。
• 修正where查询语法：Firestore的where方法需要三个参数：字段名、比较操作符（这里用"=="）、匹配值，原代码直接传时间值是错误的写法。
• 等待查询结果：get()方法是异步的，必须加await才能拿到实际的QuerySnapshot对象，不然snaps.docs会找不到。
• 添加日志反馈：最后加了一行日志，方便你在Cloud Functions控制台查看更新的文档数量，排查问题更方便。

另外要注意：因为你的函数是每分钟触发一次，要确保startTime字段存储的是精确到毫秒的Timestamp，不然可能会因为时间精度问题匹配不到文档。如果你的startTime是按分钟粒度存储的，可以把当前时间处理成整分钟的Timestamp再进行匹配。

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