我正在尝试使用 mongock 迁移 MongoDB 中的数据,当我需要跨大量数据运行迁移时偶然发现了一个问题。
有没有办法以任何方式对这些数据进行分区?我没有在文档中找到对此的支持。
问题是对这些数据进行查询并一次将所有数据加载到内存中需要花费大量时间,这也会导致问题。
UPD:问题是示例代码可以带来 1 或 1kk 文档,并且可能需要大量时间
mongoTemplate.findAll(User.class).stream()
.map(this::migrateUser)
.forEach(mongoTemplate::save);