您必须通过微服务调用的外部 HTTP 服务分配 GUID,该服务每秒处理数万条消息,并且您担心背压。您应该如何设计管道以最大程度地减少背压?
选择一个答案
点击一个选项来检查您的答案。
正确答案: 将作业分批处理为十秒的增量。.
为什么这是答案
正确答案是“将作业分批处理为十秒的增量”。在处理大量消息且担心背压时,将作业分批处理(例如每十秒一次)可以有效地平滑工作负载,减少对外部服务的瞬时高并发请求,从而降低背压。 其他选项为什么不正确: “通过 HTTP 调用服务”:虽然这是调用外部服务的方式,但它没有解决背压问题,直接调用可能导致高并发请求,加剧背压。 “在类定义中静态创建管道”:管道的创建通常在主函数中完成,静态创建管道与背压管理无关。 “在 DoFn 的 startBundle 方法中创建一个新对象”:在 startBundle 中创建对象可以减少每个元素创建对象的开销,但它本身并不能解决外部服务因高并发请求而产生的背压问题。
通过考试 — 无需无休止地寻找答案
将本次考试的所有验证问题和解释集中在一处,节省数小时的准备时间。1,000+ 认证 · 20+ 语言 · 免费开始。
更快通过考试 → 无需银行卡