应用聚合后过滤elasticsearch中的术语聚合桶

Question

以下是数据集的快照：

recordNo    employeeId      employeeStatus   employeeAddr
1           employeeA       Permanent   
2           employeeA                         ABC
3           employeeB       Contract    
4           employeeB                         CDE

我想获得员工名单以及employeeStatus和employeeAddr。

所以我在employeeId上使用术语聚合，然后使用employeeStatus和employeeAddr的子聚合来获得这些详细信息。下面的查询正确返回结果。

{
    "aggregations": {
        "Employee": {
            "terms": {
                "field": "employeeID"
            
            },
            "aggregations": {
                "employeeStatus": {
                    "terms": {"field": "employeeStatus"}
                },
                "employeeAddr": {
                    "terms": {"field": "employeeAddr"}
                }
            }
        }
    }
}
        

现在我只想要永久身份的员工。所以我正在应用过滤器聚合。

{
    "aggregations": {
        "filter_Employee_employeeID": {
            "filter": {
                "bool": {
                    "must": [
                        {
                            "match": {
                                "employeeStatus": {"query": "Permanent"}
                            }
                        }
                    ]
                }
            },
            "aggregations": {
                "Employee": {
                    "terms": {
                        "field": "employeeID"
                    },
                    "aggregations": {
                        "employeeStatus": {
                            "terms": {"field": "employeeStatus"}
                        },
                        "employeeAddr": {
                            "terms": {"field": "employeeAddr"}
                        }
                    }
                }
            }
        }
    }    

}

现在的问题是雇员地址聚合没有为雇员地址返回存储桶，因为记录2在聚合完成之前就被过滤掉了。

假设我无法修改数据集，并且我希望通过单个弹性查询获得结果，那么我该如何做呢？

我检查了Bucket选择器管道聚合，但它只适用于度量聚合。应用聚合后，是否有方法过滤掉术语存储桶？

Answer 1

如果我理解正确，即使使用某种过滤器，您也希望保留聚合。要实现这一点，请尝试使用post\u filter子句。

你可以在这里查看文档

该子句应用于聚合的“外部”。使用您的示例，应该如下所示：

{
  "aggregations": {
    "filter_Employee_employeeID": {
      "aggregations": {
        "Employee": {
          "terms": {
            "field": "employeeID"
          },
          "aggregations": {
            "employeeStatus": {
              "terms": {
                "field": "employeeStatus"
              }
            },
            "employeeAddr": {
              "terms": {
                "field": "employeeAddr"
              }
            }
          }
        }
      }
    }
  },
  "post_filter": {
    "bool": {
      "must": [
        {
          "match": {
            "employeeStatus": {
              "query": "Permanent"
            }
          }
        }
      ]
    }
  }
}