Node.js中如何等待Firebase实时数据库完成所有写入操作？

你的当前实现不会等待所有写入操作完成就执行了登出和应用删除操作，因为update方法是异步的，返回的是Promise，而你只是在forEach里触发了这些异步操作，并没有等待它们全部完成。这会导致部分写入操作可能还没完成，进程就已经退出，数据更新不完整。

正确的实现方式： #

要确保所有批量写入完成后再退出，你需要收集所有update返回的Promise，并用Promise.all等待它们全部完成，之后再执行登出、删除应用和退出进程的操作。

修改后的代码示例：

import { ref, update } from 'firebase/database'
import { deleteApp } from 'firebase/app'
import { getAuth } from 'firebase/auth'

// 填充批量更新数据
let updates = [] 
// ... 向updates中填充类似 { id: 1234, name: "abcd" } 的字典 ...

// 收集所有update操作的Promise
const updatePromises = updates.map((item) => {
  return update(ref(database, "myitemtobeupdated/" + item.id), item)
})

// 等待所有写入操作完成
Promise.all(updatePromises)
  .then(() => {
    console.log("所有批量更新已完成")
    // 完成后执行登出
    return getAuth().signOut()
  })
  .then(() => {
    console.log("已登出")
    // 登出后删除Firebase应用实例
    return deleteApp(app)
  })
  .then(() => {
    console.log("应用实例已删除")
    // 所有操作完成，退出进程
    process.exit(0)
  })
  .catch((error) => {
    console.error("操作过程中出现错误:", error)
    // 出错时强制退出进程
    process.exit(1)
  })

关键说明： #

• 使用map替代forEach，将每个update调用返回的Promise收集到数组中，而不是仅仅触发异步操作。
• Promise.all会等待数组中所有Promise都成功resolve后才会继续执行后续逻辑，如果有任何一个Promise被reject，Promise.all会立即进入catch分支。
• 整个流程采用链式调用，确保前一步操作完成后再执行下一步，最后在所有操作完成后调用process.exit()退出进程。
• 错误处理分支确保无论在写入、登出还是删除应用时出现错误，都会记录错误并退出进程。

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