Firestore，使用 node.js 进行查询和更新

Question

我需要一个每天自动触发一次的云功能，并在我的“用户”集合中查询“观察”字段为真并将所有这些字段更新为假。在部署我的函数时，我在终端中收到“13:26 错误解析错误：意外的令牌 MyFirstRef”这个错误。 我不熟悉js，所以任何人都可以纠正功能。谢谢。

const functions = require("firebase-functions");
const admin = require("firebase-admin");
const { snapshotConstructor } = require("firebase-functions/lib/providers/firestore");
admin.initializeApp();

exports.changeWatched = functions.pubsub.schedule("every 24 hours").onRun((context) => {
  const MyFirstRef = admin.firestore().collection("users")
  const queryRef = await MyFirstRef.where("watched", "==", true).get().then((snapshot) => {
    snapshot.docs.forEach( doc => {
      console.log("debug");
      const realId = doc.id
      const MyRef = await admin.firestore().collection("users").doc(realId)
      MyRef.update({watched: false})
    })
  })
});

Answer 1

您的代码中有几点需要更正：

• 您需要在所有异步作业完成后返回一个 Promise。有关详细信息，请参阅此doc。
• 如果使用await关键字，需要声明函数async，见here。
• QuerySnapshot 有一个forEach() 方法
• 您只需使用ref 属性即可从QuerySnapshot 获取文档的DocumentReference。

因此，以下内容应该可以解决问题：

exports.changeWatched = functions.pubsub.schedule("every 24 hours").onRun(async (context) => {  // <== See async
    const db = admin.firestore();
    const batch = db.batch();
    const snapshot = await db.collection("users").where("watched", "==", true).get();

    snapshot.forEach(doc => {
        batch.update(doc.ref, { watched: false });
    });

    return batch.commit();  // Here we return the Promise returned by commit()

});

请注意，我们使用 batched write，它最多可以包含 500 个操作。如果您需要在一次 Cloud Function 执行中更新更多文档，请使用 Promise.all() 或分批分批。

---

Promise.all()版本：

exports.changeWatched = functions.pubsub.schedule("every 24 hours").onRun(async (context) => {  // <== See async
    const db = admin.firestore();

    const snapshot = await db.collection("users").where("watched", "==", true).get();

    return Promise.all(snapshot.docs.map(doc => doc.ref.delete());
    
});