到目前为止,我没有找到比编写自己的代码以将所有JPA条目索引到应用程序内的ES更好的解决方案了,这个对我来说很好
Pageable page = new PageRequest(0, 100);Page<Instance> curPage = instanceManager.listInstancesByPage(page); //Get data by page from JPA repo.long count = curPage.getTotalElements();while (!curPage.isLast()) { List<Instance> allInstances = curPage.getContent(); for (Instance instance : allInstances) { instanceElasticSearchRepository.index(instance); //Index one by one to ES repo. } page = curPage.nextPageable(); curPage = instanceManager.listInstancesByPage(page);}
逻辑非常简单,仅取决于可能要花费一段时间的数据量,因此分解成批并添加一些消息可能会有所帮助。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)