Elasticsearch Python API查询返回空响应而非429状态码的原因

我在实时应用中使用elasticsearch-py客户端，执行类似“最近10天settledAmount字段求和”的搜索聚合查询。多数查询运行正常，但极少数会静默返回如下空响应：

{"took":0,"timed_out":false,"_shards":{"total":0,"successful":0,"skipped":0,"failed":0},"hits":{"total":{"value":0,"relation":"eq"},"max_score":0.0,"hits":[]}}

重复执行同一查询（需间隔1秒以上延迟）则能得到包含aggregations字段的正确响应：

{"took" : 191,"timed_out" : false,"_shards" : {"total" : 756,"successful" : 756,"skipped" : 632,"failed" : 0},"hits" : {"total" : {"value" : 0,"relation" : "eq"},"max_score" : null,"hits" : []},"aggregations" : {"total_settled_amount" : {"value" : 0.0},"unique_customer_count" : {"value" : 0}}}

我添加了重试机制后发现，该问题与负载相关——无足够延迟的重试会返回相同错误结果。以下是查询示例：

GET cases-*/_search
{"from": 0,"size": 1000,"query": {"bool": {"filter": [{"range": {"transactionAnnouncedEvent.transaction.processedAt": {"from": "2024-08-29T00:00:00.000Z","to": "2024-08-29T13:46:49.000Z","include_lower": true,"include_upper": true,"boost": 1}}},{"bool": {"should": [{"term": {"field1": {"value": "abc","boost": 1}}}]}}]},"_source": {"includes": ["caseId"]},"aggs": {"total_settled_amount": {"sum": {"field": "settledAmount"}}}}}

想请教：Elasticsearch为何返回此类空响应而非429状态码？

这种情况主要和Elasticsearch的请求路由与分片发现逻辑有关，而非直接的限流触发：

• 集群负载过高导致分片路由失败
  当集群负载飙升（比如CPU、内存耗尽，协调节点处理队列打满），协调节点在尝试路由查询到数据分片时，可能无法完成分片发现流程——要么无法获取集群的分片状态，要么所有可用数据节点都无法响应路由请求。此时协调节点会判定没有分片需要处理，因此返回total:0的分片统计结果，而非触发429限流。
• 429触发条件更明确严格
  Elasticsearch返回429是明确触发了限流阈值（比如线程池队列满触发拒绝策略、请求大小超出限制等），但这种分片路由失败属于请求处理的前置阶段异常，还没到触发限流规则的环节，所以不会返回429。
• 重试延迟的核心作用
  延迟1秒后重试能成功，是因为这段时间内集群负载有所缓解，协调节点可以正常完成分片发现和路由流程，查询能被正确分发到数据节点执行，自然能返回包含聚合结果的响应。

内容的提问来源于stack exchange，提问作者room13