Elasticsearch查询筛选器嵌套数组范围最小

Question

鉴于这些文件：

{
  "id": "1"
  "prices": [
    {
      "param1": "A",
      "param2": "B",
      "total": 100 
    },
    {
      "param1": "A",
      "param2": "C",
      "total": 200 
    }
  ]
},
{
  "id": "2"
  "prices": [
    {
      "param1": "A",
      "param2": "B",
      "total": 200 
    },
    {
      "param1": "A",
      "param2": "C",
      "total": 300 
    }
  ]
},

如何才能用它们的最小总价值来过滤它们的价格范围？

现在我的查询如下所示：

{
  ...
  "query": {
    "bool": {
      "filter": [
        {
          "nested": {
            "path": "prices",
            "query": {
              "bool": {
                "filter": [
                  {
                    "range": {
                      "prices.total": {
                        "gte": 200,
                        "lte": 300
                      }
                    }
                  }
                ]
              }
            }
          }
        }
      ]
    }
  }
}

所以它从逻辑上返回文档1和2，因为它们的价格都在这个范围内，但我只想得到文档2，因为我希望过滤器逻辑只应用于最低价格。

Answer 1

由于您不知道在筛选最小值时您不知道什么，所以从理论上讲，您可以想出一个查询时脚本来为您计算这个值。但这将是繁重和低效的。

相反，我建议在摄取前/摄取时计算局部最小值，这将大大加快查找时间。

1. 使用_update_by_query脚本为所有文档分配顶级MintotalPrice:

POST prices/_update_by_query
{
  "query": {
    "match_all": {}
  },
  "script": {
    "source": """
    def allTotals = ctx._source.prices.stream().map(group -> group.total).collect(Collectors.toList());
    ctx._source.minTotalPrice = Collections.min(allTotals)
    """,
    "lang": "painless"
  }
}

这大大简化了实际的范围查询：

GET prices/_search
{
  "query": {
    "range": {
      "minTotalPrice": {
        "gte": 200,
        "lte": 300
      }
    }
  }
}

在ingest管道中使用相同的脚本。它可以应用于第一次获取文档以及更新单个文档时（无论出于何种原因）。

使用copy_to映射参数，正如我在这里解释的那样。但是您仍然需要一个查询时脚本来计算本地最小值。