elasticsearch - 类型为top_hits的聚合器不能接受子聚合

Question

我正在尝试执行以下查询，但是获取类型为[top_hits]的Aggregator [recommendationIds]无法接受以下子查询和相应的Java代码，并且我在Java REST高级客户端中使用了 Elasticsearch 客户端，我尝试了多次将顶级汇总放在几个位置，但无法正常工作。

{
    "query": {
        "bool": {
            "must_not": [
                {
                    "terms": {
                        "id.keyword": [
                            ""
                        ],
                        "boost": 1
                    }
                }
            ],
            "should": [
                {
                    "terms": {
                        "shipmentId.keyword": [
                            "123"
                        ],
                        "boost": 1
                    }
                },
                {
                    "term": {
                        "exceptionId.keyword": {
                            "value": [
                                "1",
                                "2"
                            ],
                            "boost": 1
                        }
                    }
                }
            ],
            "adjust_pure_negative": true,
            "minimum_should_match": "1",
            "boost": 1
        }
    },
    "aggregations": {
        "recommendationIds": {
            "top_hits": {
                "from": 0,
                "size": 1,
                "version": false,
                "explain": false,
                "_source": {
                    "includes": [
                        "id"
                    ],
                    "excludes": [
                        ""
                    ]
                }
            },
            "aggregations": {
                "by_item": {
                    "terms": {
                        "field": "item.keyword",
                        "size": 10,
                        "min_doc_count": 1,
                        "shard_min_doc_count": 0,
                        "show_term_doc_count_error": false,
                        "order": [
                            {
                                "_count": "desc"
                            },
                            {
                                "_key": "asc"
                            }
                        ]
                    },
                    "aggregations": {
                        "by_destination": {
                            "terms": {
                                "field": "destinationLocation.keyword",
                                "size": 10,
                                "min_doc_count": 1,
                                "shard_min_doc_count": 0,
                                "show_term_doc_count_error": false,
                                "order": [
                                    {
                                        "_count": "desc"
                                    },
                                    {
                                        "_key": "asc"
                                    }
                                ]
                            },
                            "aggregations": {
                                "by_trans": {
                                    "terms": {
                                        "field": "transportMode.keyword",
                                        "size": 10,
                                        "min_doc_count": 1,
                                        "shard_min_doc_count": 0,
                                        "show_term_doc_count_error": false,
                                        "order": [
                                            {
                                                "_count": "desc"
                                            },
                                            {
                                                "_key": "asc"
                                            }
                                        ]
                                    },
                                    "aggregations": {
                                        "by_sourcelocation": {
                                            "terms": {
                                                "field": "sourceLocation.keyword",
                                                "size": 10,
                                                "min_doc_count": 1,
                                                "shard_min_doc_count": 0,
                                                "show_term_doc_count_error": false,
                                                "order": [
                                                    {
                                                        "_count": "desc"
                                                    },
                                                    {
                                                        "_key": "asc"
                                                    }
                                                ]
                                            },
                                            "aggregations": {
                                                "by_shipdate": {
                                                    "terms": {
                                                        "field": "shipDate",
                                                        "size": 10,
                                                        "min_doc_count": 1,
                                                        "shard_min_doc_count": 0,
                                                        "show_term_doc_count_error": false,
                                                        "order": [
                                                            {
                                                                "_count": "desc"
                                                            },
                                                            {
                                                                "_key": "asc"
                                                            }
                                                        ]
                                                    },
                                                    "aggregations": {
                                                        "by_arrival": {
                                                            "terms": {
                                                                "field": "arrivalDate",
                                                                "size": 10,
                                                                "min_doc_count": 1,
                                                                "shard_min_doc_count": 0,
                                                                "show_term_doc_count_error": false,
                                                                "order": [
                                                                    {
                                                                        "_count": "desc"
                                                                    },
                                                                    {
                                                                        "_key": "asc"
                                                                    }
                                                                ]
                                                            },
                                                            "aggregations": {
                                                                "quantity": {
                                                                    "sum": {
                                                                        "field": "transferQuantity"
                                                                    }
                                                                },
                                                                "transfercost": {
                                                                    "sum": {
                                                                        "field": "transferCost"
                                                                    }
                                                                },
                                                                "revenueRecovered": {
                                                                    "sum": {
                                                                        "field": "revenueRecovered"
                                                                    }
                                                                }
                                                            }
                                                        }
                                                    }
                                                }
                                            }
                                        }
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
    }
}

以下是生成查询的Java代码:

List<String> excludeRecommendationIds = Stream.of("")
                .collect(Collectors.toList());

        BoolQueryBuilder mustNotMatchRecommendationIds =
                QueryBuilders.boolQuery()
                        .should(QueryBuilders.termsQuery("shipmentId.keyword", asList("123")))
                        .should(QueryBuilders.termQuery("exceptionId.keyword", asList("1", "2")))
                        .mustNot(QueryBuilders.termsQuery("id.keyword", excludeRecommendationIds))
                        .minimumShouldMatch(1);

        TopHitsAggregationBuilder topHitsAggregationBuilder = AggregationBuilders
                .topHits("recommendationIds")
                .fetchSource("id", "")
                .size(1);


        AggregationBuilder itemAgg = AggregationBuilders.terms("by_item").field("item.keyword");

        AggregationBuilder destinationAgg = AggregationBuilders.terms("by_destination").field("destinationLocation.keyword");

        AggregationBuilder transportAgg = AggregationBuilders.terms("by_trans").field("transportMode.keyword");

        AggregationBuilder sourceAgg = AggregationBuilders.terms("by_sourcelocation").field("sourceLocation.keyword");

        AggregationBuilder shipDateAgg = AggregationBuilders.terms("by_shipdate").field("shipDate");

        AggregationBuilder arrivalDateAgg = AggregationBuilders.terms("by_arrival").field("arrivalDate");

        AggregationBuilder quantityAgg = AggregationBuilders.sum("quantity").field("transferQuantity");
        AggregationBuilder transferCostAgg = AggregationBuilders.sum("transfercost").field("transferCost");
        AggregationBuilder revenueRecoveredAgg = AggregationBuilders.sum("revenueRecovered").field("revenueRecovered");


        AggregationBuilder aggregation = itemAgg.subAggregation(destinationAgg
                .subAggregation(transportAgg.subAggregation(sourceAgg.subAggregation(shipDateAgg.subAggregation(arrivalDateAgg.subAggregation(
                        quantityAgg).subAggregation(transferCostAgg).subAggregation(revenueRecoveredAgg))))));

        topHitsAggregationBuilder.subAggregation(aggregation);

        //searchSourceBuilder.size(0);
        searchSourceBuilder.query(mustNotMatchRecommendationIds);
        searchSourceBuilder.aggregation(topHitsAggregationBuilder);
        searchRequest.source(searchSourceBuilder);

Answer 1

该错误是不言自明的。由于您的热门歌曲仅用于检索id，而改为使用terms agg怎么样？那个可以接受子agggs:

...
  "aggregations": {
    "recommendationIds": {
      "terms": {
        "field": "id.keyword",
        "size": 10
      },
      "aggregations": {
        "by_item": {
          "terms": {
            "field": "item
...