如何在Elasticsearch中用首个查询结果作为输入执行嵌套查询？

Elasticsearch本身没有原生支持单请求内将前一个查询结果直接作为后一个查询参数的嵌套查询，以下是几种可行的实现方案：

方案1：客户端脚本分步执行（最通用灵活） #

通过客户端代码分两步完成，先执行第一个查询提取所需参数，再构造第二个查询执行：

Python客户端示例代码 #

from elasticsearch import Elasticsearch

# 初始化Elasticsearch客户端
es = Elasticsearch("http://你的ES地址:9200")

# 第一步：执行第一个查询，获取bucketId和descriptor
first_query = {
  "query": {
    "query_string": {
      "query": "(imageName: xyz.jpg)"
    }
  }
}
first_response = es.search(index="index1", body=first_query)

# 解析结果提取目标字段
target_hit = first_response["hits"]["hits"][0]["_source"]
bucket_ids = target_hit["bucketId"]
target_descriptor = target_hit["descriptor"]

# 第二步：构造并执行第二个查询
second_query = {
  "query": {
    "function_score": {
      "boost_mode": "replace", 
      "query": {
        "constant_score": {
          "filter": {
            "terms": {
              "bucketId": bucket_ids
            }
          }
        }
      },
      "pqcode_score": {
        "descriptors": [
          {
            "descriptor": target_descriptor
          }
        ]
      }
    }
  }
}
final_response = es.search(index="index2", body=second_query)

# 处理并输出最终结果
print(final_response)

方案2：使用Enrich Policy预关联数据（适合高频查询场景） #

如果这类关联查询是高频操作，可以通过Enrich功能将index1的字段预关联到index2，后续查询无需分步执行：

1. 创建Enrich策略：定义从index1提取关联字段的规则

PUT /_enrich/policy/index1_enrich_policy
{
  "match": {
    "indices": "index1",
    "match_field": "imageName",
    "enrich_fields": ["bucketId", "descriptor"]
  }
}

2. 执行策略生成关联索引

POST /_enrich/policy/index1_enrich_policy/_execute

3. 创建Ingest管道关联数据：给index2的文档添加来自index1的关联字段（新增文档时自动关联，已有文档可通过Update By Query批量处理）

PUT /_ingest/pipeline/enrich_index2_pipeline
{
  "processors": [
    {
      "enrich": {
        "policy_name": "index1_enrich_policy",
        "field": "imageName", // 需index2也有该字段用于匹配关联
        "target_field": "index1_related",
        "max_matches": 1
      }
    }
  ]
}

4. 直接查询index2：此时可直接使用预关联的字段

GET index2/_search
{
  "query": {
    "function_score": {
      "boost_mode": "replace", 
      "query": {
        "constant_score": {
          "filter": {
            "terms": {
              "index1_related.bucketId": []
            }
          }
        }
      },
      "pqcode_score": {
        "descriptors": [
          {
            "descriptor": "{{index1_related.descriptor}}"
          }
        ]
      }
    }
  }
}

注：该方案要求index1和index2有共同匹配字段（如imageName），适合数据更新频率较低的场景。

方案3：Terms Lookup（仅适用于bucketId参数场景） #

如果仅需要获取bucketId数组，可使用Terms Lookup直接从index1的指定文档中提取，但descriptor无法通过该方式获取，局限性较大：

GET index2/_search
{
  "query": {
    "function_score": {
      "boost_mode": "replace", 
      "query": {
        "constant_score": {
          "filter": {
            "terms": {
              "bucketId": {
                "index": "index1",
                "id": "1", // 需提前知晓index1中目标文档的ID
                "path": "bucketId"
              }
            }
          }
        }
      },
      "pqcode_score": {
        "descriptors": [
          {
            "descriptor": "需提前获取的descriptor值"
          }
        ]
      }
    }
  }
}

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