Cosmos 更改源处理器延迟远远超过收集的记录数
温馨提示:
本文最后更新于 2024年04月12日,已超过 48 天没有更新。若文章内的图片失效(无法正常加载),请留言反馈或直接联系我。
我在用着Cosmos 更换饲料处理器在我的应用程序中使用 Java 来消费宇宙改变饲料Cosmos NoSql DB 容器的
根据文档,如果使用交换饲料加工机方法,在我们开始使用更改源时,该点之前的所有插入/更新都将作为单个快照提供。
由于我正在执行的过程是在非生产环境中(在产品中执行之前进行测试),自从我的更改源消耗开始以来,容器没有大量的插入/更新。
从以上两点,我们可以得出结论,更改源处理器返回的概率延迟(运行和使用更新时)不应比容器中的文档总数高很多
然而,我看到估计的容器延迟约为 1.3 亿,而我的中只有约 700 万条记录。
我的容器只有 1 个物理分区(因此只有 1 个更改源处理器实例在运行),下面是我用来计算估计延迟的代码。
AtomicInteger totalLag = new AtomicInteger();
List<ChangeFeedProcessorState> currentState = changeFeedProcessor.getCurrentState().block();
if (CollectionUtils.isEmpty(currentState)) {
System.out.println("Unexpected METRICS :: STATES is empty");
continue;
}
for (ChangeFeedProcessorState changeFeedProcessorState : currentState) {
totalLag.addAndGet(changeFeedProcessorState.getEstimatedLag());
}
System.out.println(totalLag.get());
有人可以提供这方面的专业知识吗?
正文到此结束
- 本文标签: 家庭宠物
- 本文链接: https://www.coder6.net/article/2376
- 版权声明: 本文由蚂蚁原创发布,转载请遵循《署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0)》许可协议授权
热门推荐
-
浏览(195) 评论(0)