java - MongoDB 变更流

Question

我已经开始处理 MongoDB 更改流，并设置了一些流来监视大约 30 个数据库的更改。我只需要观看两个集合，我想知道是否可以编写一些管道或过滤器来观看具有所提供的名称或部分名称的集合。例如，我从 ChangeStreamDocument 的命名空间文档中获取集合名称，并且我想在所有数据库上观看等于“玩家”的集合。我正在观看整个服务器的更改，但现在我收到以下通知每个被更改的集合，我不想要这样，只想要特定的集合。

 final ChangeStreamPublisher<Document> publisher = client.watch(Arrays.asList(
            Aggregates.match(
                    Filters.in("operationType", Arrays.asList("insert", "update", "delete"))
            ))).fullDocument(FullDocument.UPDATE_LOOKUP);

我在想是否可以在那里放置一些过滤器，使流仅观看具有相应名称的集合。

文档:https://docs.mongodb.com/manual/changeStreams/

Answer 1

根据文档，您可以设置对部署、数据库或集合的监视。因此，也许您可​​以监视名为“玩家”的集合。另一种选择是在 Aggregates.Match 中设置额外的过滤器。每个变更流事件都会返回一个名为“ns”的命名空间对象，其中包含参与更改的数据库和集合名称。