如何安排云功能来更新 Firebase 实时数据库中的每个用户？

Question

我已将云调度程序连接到我的项目并准备好每天运行。我有数据附加到我想每天更新的用户。

likesforday
    uid1
       -Amount : 43
    uid2
       -Amount : 567

我需要将所有数量设置为 0。

我可以正确更新一条记录，但我不知道如何更新实时数据库中的每个用户。我还希望它是一个原子更新，所以要么是所有用户，要么没有。

有很多关于使用 onWrite onCreate 等的指南...但我需要 scheduler.onRun 每天更新所有数量。

我尝试过类似的方法

exports.resetdailytaps = functions.pubsub
  .schedule("every day 00:00")
  .onRun(async () => {
  console.log("starting");

let updates = {};
let qu = database.ref(`/likesforday/{uid}`).orderByChild("amount");
const snap = await qu.once("value");
snap.forEach((child) => {
  updates[child.key] = 0;
  console.log("childkey: " + child);
});

return database.ref().update(updates);

和其他变体，但无法使其工作。

谢谢！

Answer 1

您问题的重点是：

我也希望它是一个原子更新，所以要么全部 用户或没有用户。

为此，您需要使用update() 方法，就像您在问题中所做的那样：使用此方法进行的同时更新是原子的。要么全部更新成功，要么全部更新失败。

以下方法可以解决问题：

  exports.resetdailytaps = functions.pubsub
    .schedule('every day 00:00')
    .onRun(async () => {
      console.log('starting');
      const db = firebase.database();
      const updates = {};

      const snapshot = await db.ref('likesforday').once('value');

      snapshot.forEach((childSnapshot) => {
        updates['/likesforday/' + childSnapshot.key + '/Amount'] = 0;
      });
      
      return db.ref().update(updates);
    });

Answer 2

我认为没有必要orderByChild，您只是将所有子节点的数量设置为0。请尝试运行以下代码：

const updates = []

database.ref("likesforday").once("value").then((snapshot) => {
  Object.keys(snapshot).forEach((user) => {
    updates.push(database.ref(`likesforday/${user}`).update({Amount: 0}))
  })
})

await Promise.all(updates)

对于 cron，您也可以尝试 0 0 * * * 在每个午夜运行。