ElasticSearch根据不同类型的查询结果提高文档分数

Question

我正在制作一个基于ElasticSearch的电子商务产品目录原型。每个产品都作为文档编制索引（包含名称和描述等属性）。

有一件事我不能解决，我想根据用户的购买历史提高某些产品的分数。

我能想到的唯一选择是将购买历史记录存储为产品的子文档。然后使用custom\u filters\u score和过滤器，该过滤器查找具有给定用户ID的子文档。在这种情况下，过滤器确定给定的产品是否已被给定的用户购买，如果是，它将提高分数。

这种方法的问题是，一些产品可能每月被购买数十万次，我不确定弹性搜索在这种情况下会如何运行。

完美的解决方案是，如果我可以将购买历史记录放在一个单独的索引中，或者放在同一个索引中，但作为一个不同的文档类型（比如“userspurchasehistory”）。示例文档：

{userId: 1234, purchesedProducts: [34,112323,1223,32342,31234]}

然后使用查询分数提升，表达如下内容：如果术语34（productId）出现在用户历史记录（类型）文档的“用户ID”等于1234的“购买产品”（字段名）中，则按因子2提升查询。

有什么想法吗？

更新：

我对一个大的产品目录和大量的销售数据进行了一些测试：产品（类型）文档数：50万SalesHistory（类型）文档数：14 000 000索引大小：2.5GB弹性Serach：一个节点，所有默认设置

销售历史文档是产品文档的子文档。销售条目的分布：

~20% of products: 40 entries 
~20% of products: 30 entries 
~20% of products: 20 entries 
~20% of products: 10 entries 
~20% of products: 5 entries 

200 products with 10 000 sales entries (plus previously added 5-40 entries)
200 products with  5 000 sales entries (plus previously added 5-40 entries)
200 products with  2 500 sales entries (plus previously added 5-40 entries)
200 products with  1 000 sales entries (plus previously added 5-40 entries)
200 products with    500 sales entries (plus previously added 5-40 entries)
1 product 18 500 entries

示例查询：

curl -XGET "http://localhost:9200/demoproducts/_search" -d'
{
   "query": {
      "custom_filters_score": {
         "query": {
            "match_all": {}
         }
      },
      "filters": [
         {
            "filter": {
               "has_child": {
                  "type": "saleshistory",
                  "query": {
                     "term": {
                        "userId": {
                           "value": "28875"
                        }
                     }
                  }
               }
            },
            "boost": 2
         }
      ]
   }
}'

结果：

{
  "took": 33,
  "timed_out": false,
  "_shards": {
    "total": 5,
    "successful": 5,
    "failed": 0
  },
  "hits": {
    "total": 500001,
    "max_score": 2
    ...
  }
}

当我在查询中添加一些过滤器（几乎在所有情况下，我们的查询都包含一些过滤器）时，响应时间约为7ms

结论

没有必要将此案例作为子文档以任何其他方式实现。

Answer 1

您可以动态构建包含用户购买历史的条款查询，而不是修改文档。

curl -XGET "http://localhost:9200/demoproducts/_search" -d'
    {
       "query": {
           "terms": {"id":["34","112323","1223","32342","31234"]}
        }
    }
}