Angular + Firebase firestore - 文档的内部订阅在初始订阅时返回两个值

如何解决Angular + Firebase firestore - 文档的内部订阅在初始订阅时返回两个值

我在 Angular 11+ 上使用 AngularFire 作为 Firebase 的 API。

我的应用领域是实时拍卖

理想情况下，我想做的是阅读所有文档，然后订阅每个文档以进行更改。

我目前的问题是我在 firestore 上的读取次数。

我的收藏读取将产生 N 次读取。但是订阅每个文档会产生额外的读取，默认情况下需要 2N 次读取，这似乎是不可避免的。

但我想这比订阅该集合并在每次更新集合中的某些内容时接收 N 次读取要好。

因此，使用下面的示例代码，我先查询集合，然后再查询文档。简化只是为了重现。

  this.store.collection("users").valueChanges()
  .pipe(
    take(1),concatMap(() => this.store.doc("user/1").valueChanges())
  )
  .subscribe(console.log(user));

但是，Inner observable 会发出 2 次。

一次使用 added，一次使用 modified 快照更改类型。

所以我的问题是：

为什么我的内部 observable 在初始订阅时连续发射两次，而在我看来它应该只发射一次。

如果这两个发出计数都作为对 firestore 的读取，这将产生 3N 读取。

通过我在 firestore 监控页面上的测试，情况似乎是这样，因为在 400 个文档页面上，我在 firestore 上记录了大约 1200 次读取并计入定价。

1. 我在示例代码中可能做错了什么？

2. 有没有人对我应该如何检索更多数据提出建议 以更少的读取有效地？

3. 我应该改用 RTDB 吗？ 10GB 数据输出，这对我的读取量会更好吗？

编辑：

所以我刚刚用 angularfire API 测试了 firebase RTDB。

上面的示例代码将使内部 observable 按预期仅发出 1 个值，并且每个项目更改发出 1 个值。这是预期的。

我仍然不清楚为什么 firestore 实现会发出 2 个值，这两个值都算作读取并影响定价。

结束代码看起来像这样：

this.db.list<AuctionItem>(`auctions/1/items`)
.valueChanges()
.pipe(
  take(1),tap(items => this.itemsToRender = items),mergeMap(items => [...items]),mergeMap((item: AuctionItem) => this.db.object(`auctions/1/items/${item.id}`).valueChanges() as Observable<AuctionItem>),)
.subscribe(change => {
  // do work when item updates
})

仍然不确定为什么 firestore 没有按预期为我工作。考虑使用部分 firestore + RTDB 以实现最佳使用，因为即使有 50k 免费，我在 firestore 上的读取量也很高。

解决方法

在您的情况下，我会这样做：

1. 做一个onSnapshot()查询，（第一次读操作） --> 但将结果限制为 10 或 20。（便宜！）
2. 在用户滚动时 -> 加载更多。 (Firestore pagination ref)
3. 当文档发生变化时 --> 更新显示的数据

在侦听更改时，您只需为确实更改的文档重新收费，而不是您已查询但未获得任何更新的文档。

有关听众定价的更多详细信息，请观看this video (especially at 3:16)