ElasticSearch如何从嵌套子数组生成多条独立返回结果

嘿，你的需求完全可以在Elasticsearch里实现！本质上你是要把嵌套多层的数组结构“扁平化”，让每个最内层的shipment都作为一条独立的结果，同时带上它上层的订单、订单项、采购单信息。下面给你两种可行的方案，你可以根据自己的场景选择：

方案一：多层嵌套聚合 + Top Hits #

这种方式适合你想直接在Elasticsearch端拿到拆分后的结构化结果，不需要客户端做太多额外处理。核心思路是通过逐层的nested聚合展开每一层数组，最后用top_hits获取每个发货单的详细信息，同时保留上层的关联数据。

示例查询DSL：

GET /your_index/_search
{
  "size": 0, // 不返回顶层原始文档，只聚焦聚合结果
  "aggs": {
    "group_by_order": {
      "terms": {
        "field": "orderNumber", // 按订单号分组
        "size": 1000 // 根据你的数据量调整这个值，确保能覆盖所有需要的订单
      },
      "aggs": {
        "expand_order_lines": {
          "nested": {
            "path": "orderLines" // 进入订单项的嵌套层级
          },
          "aggs": {
            "group_by_line_number": {
              "terms": {
                "field": "orderLines.lineNumber" // 按订单项号分组
              },
              "aggs": {
                "expand_purchase_orders": {
                  "nested": {
                    "path": "orderLines.purchaseOrders" // 进入采购单的嵌套层级
                  },
                  "aggs": {
                    "group_by_po_number": {
                      "terms": {
                        "field": "orderLines.purchaseOrders.poNumber" // 按采购单号分组
                      },
                      "aggs": {
                        "expand_shipments": {
                          "nested": {
                            "path": "orderLines.purchaseOrders.shipments" // 进入发货单的嵌套层级
                          },
                          "aggs": {
                            "shipment_details": {
                              "top_hits": {
                                "size": 1, // 每个发货单只取一条数据
                                "_source": {
                                  "includes": [
                                    "orderLines.purchaseOrders.shipments.shipmentNumber",
                                    "orderLines.purchaseOrders.shipments.late"
                                  ]
                                }
                              }
                            }
                          }
                        }
                      }
                    }
                  }
                }
              }
            }
          }
        }
      }
    }
  }
}

查询结果里，每个发货单都会对应一个独立的聚合bucket，你可以从这些bucket里提取出orderNumber、lineNumber、poNumber和shipmentNumber，组合成你想要的格式，比如orderNumber1->{orderLine1,{ purchaseOrder1, {shipmentNumber1}}}。

方案二：嵌套查询 + Inner Hits（配合客户端处理） #

如果你只需要筛选特定条件的发货单（比如你提到的延迟发货late="YES"的情况），可以用这种方式。它会先匹配符合条件的顶层订单，然后把所有匹配的发货单作为子结果返回，你只需要在客户端把这些子结果和上层数据组合成独立行即可。

示例查询DSL：

GET /your_index/_search
{
  "query": {
    "nested": {
      "path": "orderLines.purchaseOrders.shipments",
      "query": {
        "match": {
          "orderLines.purchaseOrders.shipments.late": "YES"
        }
      },
      "inner_hits": {
        "_source": ["orderLines.purchaseOrders.shipments.shipmentNumber"] // 只获取需要的发货单字段
      }
    }
  },
  "_source": ["orderNumber", "orderLines.lineNumber", "orderLines.purchaseOrders.poNumber"] // 保留上层需要的字段
}

返回结果里，每个顶层订单文档会附带一个inner_hits数组，里面是所有符合条件的发货单。你只需要遍历每个订单的inner_hits，把每个发货单和对应的orderNumber、lineNumber、poNumber拼接起来，就能得到你想要的每条独立结果。

备注：内容来源于stack exchange，提问作者Ken