【腾讯云 Elasticsearch Service】高可用，可伸缩，云端全托管。集成X-Pack高级特性，适用日志分析/企业搜索/BI分析等场景
我们将介绍使用 function_score 的基础知识，并介绍一些 function core 技术非常有用和有效的用例。
介绍
评分的概念是任何搜索引擎（包括 Elasticsearch）的核心。评分可以粗略地定义为：找到符合一组标准的数据并按相关性顺序将其返回。相关性通常是通过类似 TF-IDF 的算法来实现的，该算法试图找出文本上与提交的查询最相似的文档。尽管 TF-IDF 及其相近的算法（例如BM25）非常棒，但有时必须通过其他算法或通过其他评分启发式方法来解决相关性问题。在这里，Elasticsearch 的script_score 和 function_score 功能变得非常有用。本文将介绍这些工具的用法。
文本相似性不是最重要因素的一个域示例是地理搜索。如果正在寻找在给定点附近的好咖啡店，则按与查询在文本上的相似程度对咖啡店进行排名对用户而言不是很有用，但按地理位置在附近的排名对他们。
另一个示例可能是视频共享站点上的视频，其中搜索结果可能应该考虑视频的相对受欢迎程度。如果某个流行歌星上传了具有给定标题的视频，从而获得了数百万的观看次数，那么该视频可能应该比具有相似文字相关性的不受欢迎的视频更胜一筹。
在使用 Elasticsearch 进行全文搜索的时候，默认是使用 BM25 计算的 _score 字段进行降序排序的。当我们需要用其他字段进行降序或者升序排序的时候，可以使用 sort 字段，传入我们想要的排序字段和方式。 当简单的使用几个字段升降序排列组合无法满足我们的需求的时候，我们就需要自定义排序的特性，Elasticsearch 提供了 function_score 的 DSL 来自定义打分，这样就可以根据自定义的 _score 来进行排序。
在实际的使用中，我们必须注意的是：soft_score 和 function_score 是耗资源的。您只需要计算一组经过过滤的文档的分数。
下面我们来用一个例子来具体说明如何来通过 script_core 和 function_core 来定制我们的分数。
准备数据
我们首先来下载我们的测试数据：
代码语言：javascript复制git clone https://github.com/liu-xiao-guo/best_games_json_data然后我们通过 Kibana 把这个数据来导入到我们的 Elasticsearch 中：
在导入的过程中，我们选择Time field为year，并且指定相应的日期格式：
我们指定我们的索引名字为 best_games：
我们可以查看一下一个样本的文档就像是下面的格式一样：
代码语言：javascript复制 "_source" : { "global_sales" : 82.53, "year" : 2006, "image_url" : "https://upload.wikimedia.org/wikipedia/en/thumb/e/e0/Wii_Sports_Europe.jpg/220px-Wii_Sports_Europe.jpg", "platform" : "Wii", "@timestamp" : "2006-01-01T00:00:00.000 08:00", "user_score" : 8, "critic_score" : 76, "name" : "Wii Sports", "genre" : "Sports", "publisher" : "Nintendo", "developer" : "Nintendo", "id" : "wii-sports-wii-2006" }在上面我们可以看出来这个文档里有两个很重要的字段：critic_score 及 user_score。一个是表示这个游戏的难度，另外一个表示游戏的受欢迎的程度。
正常查询
首先我们来看看如果不使用任何的分数定制，那么情况是怎么样的。
代码语言：javascript复制GET best_games/_search{ "_source": [ "name", "critic_score", "user_score" ], "query": { "match": { "name": "Final Fantasy" } }}在上面的查询中，为了说明问题的方便，在返回的结果中，我们只返回 name, critic_score 和 user_score 字段。我们在 name 字段里含有 “Final Fantasy” 的所有游戏，那么显示显示的结果是：
代码语言：javascript复制 "hits" : [ { "_index" : "best_games", "_type" : "_doc", "_id" : "2qccJ28BCSSrjaXdSOnC", "_score" : 8.138414, "_source" : { "user_score" : 9, "critic_score" : 92, "name" : "Final Fantasy VII" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6KccJ28BCSSrjaXdSOnC", "_score" : 8.138414, "_source" : { "user_score" : 8, "critic_score" : 92, "name" : "Final Fantasy X" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6qccJ28BCSSrjaXdSOnC", "_score" : 8.138414, "_source" : { "user_score" : 8, "critic_score" : 90, "name" : "Final Fantasy VIII" } }, ...从上面的结果中，我们可以看出来 Final Fantasy VII 是最匹配的结果。它的分数是最高的。
Soft_score 查询
加入我们我们是游戏的运营商，那么我们也许我们自己想要的排名的方法。比如，虽然所有的结果都很匹配，但是我们也许不只单单是匹配 Final Fantasy，而且我们想把 user_score 和 critic_score 加进来（虽然你可以使用其中的一个）。我们想这样来算我们的分数。
最终 score = score*(user_score*10 critic_score)/2/100
也就是我们把 user_score 乘以10，从而变成100分制。它和 critic_score 加起来，然后除以2，并除以100，这样就得出来最后的分数的加权系数。这个加权系数再乘以先前在上一步得出来的分数才是最终的分数值。经过这样的改造后，我们发现我们的分数其实不光是全文搜索的相关性，同时它也紧紧地关联了我们的用户体验和游戏的难道系数。
那么我们如何使用这个呢？
参照 Elastics 的官方文档 soft_score，我们现在做如下的搜索：
代码语言：javascript复制GET best_games/_search{ "_source": [ "name", "critic_score", "user_score" ], "query": { "script_score": { "query": { "match": { "name": "Final Fantasy" } }, "script": { "source": "_score * (doc['user_score'].value*10 doc['critic_score'].value)/2/100" } } }}在上面的查询中，我们可以看到我们使用了新的公式：
代码语言：javascript复制 "script": { "source": "_score * (doc['user_score'].value*10 doc['critic_score'].value)/2/100" }那么我查询后的结果为：
代码语言：javascript复制 "hits" : [ { "_index" : "best_games", "_type" : "_doc", "_id" : "2qccJ28BCSSrjaXdSOnC", "_score" : 7.405957, "_source" : { "user_score" : 9, "critic_score" : 92, "name" : "Final Fantasy VII" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "K6ccJ28BCSSrjaXdSOrC", "_score" : 7.0804205, "_source" : { "user_score" : 8, "critic_score" : 94, "name" : "Final Fantasy IX" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6KccJ28BCSSrjaXdSOnC", "_score" : 6.9990363, "_source" : { "user_score" : 8, "critic_score" : 92, "name" : "Final Fantasy X" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6qccJ28BCSSrjaXdSOnC", "_score" : 6.917652, "_source" : { "user_score" : 8, "critic_score" : 90, "name" : "Final Fantasy VIII" } }, ...我们从上面可以看出来最终的分数 _score 是完全不一样的值。我们同时也看出来尽管第一名的 Final Fantasy VII 没有发生变化，但是第二名的位置由 Final Fantasy X 变为 Final Fantasy IX 了。
针对 script 的运算，有一些预定义好的函数可以供我们调用，它们可以帮我们加速我们的计算。
- Saturation
- Sigmoid
- Random score function
- Decay functions for numeric fields
- Decay functions for geo fields
- Decay functions for date fields
- Functions for vector fields
我们可以参考 Elastic 的官方文档来帮我们更深入地了解。
Function score 查询
function_score 允许您修改查询检索的文档分数。 例如，如果分数函数在计算上很昂贵，并且足以在过滤后的文档集上计算分数，则此功能很有用。
要使用f unction_score，用户必须定义一个查询和一个或多个函数，这些函数为查询返回的每个文档计算一个新分数。
function_score 可以只与一个函数一起使用，比如：
代码语言：javascript复制GET /_search{ "query": { "function_score": { "query": { "match_all": {} }, "boost": "5", "random_score": {}, "boost_mode": "multiply" } }}这里它把所有的文档的分数由5和一个由 random_score (返回0到1之间的值)相乘而得到。那么这个分数就是一个从0到5之间的一个数值：
代码语言：javascript复制 "hits" : [ { "_index" : "chicago_employees", "_type" : "_doc", "_id" : "Hrz0_W4BDM8YqwyDD06A", "_score" : 4.9999876, "_source" : { "Name" : "ADKINS, WILLIAM J", "Job Titles" : "SUPERVISING FIRE COMMUNICATIONS OPERATOR", "Department" : "OEMC", "Full or Part-Time" : "F", "Salary or Hourly" : "Salary", "Annual Salary" : 121472.04 } }, { "_index" : "kibana_sample_data_logs", "_type" : "_doc", "_id" : "eXNIHm8BjrINWI3xYF0J", "_score" : 4.9999495, "_source" : { "agent" : "Mozilla/5.0 (X11; Linux i686) AppleWebKit/534.24 (KHTML, like Gecko) Chrome/11.0.696.50 Safari/534.24", "bytes" : 6630, "clientip" : "77.5.51.49", "extension" : "", "geo" : { "srcdest" : "CN:ID", ...尽管这个分数没有多大实际的意思，但是它可以让我们每次进入一个网页看到不同的文档，而不是严格按照固定的匹配而得到的固定的结果。
我们也可以配合 soft_score 一起来使用 unction_score：
代码语言：javascript复制GET best_games/_search{ "_source": [ "name", "critic_score", "user_score" ], "query": { "function_score": { "query": { "match": { "name": "Final Fantasy" } }, "script_score": { "script": "_score * (doc['user_score'].value*10 doc['critic_score'].value)/2/100" } } }}那么显示的结果是：
代码语言：javascript复制 "hits" : [ { "_index" : "best_games", "_type" : "_doc", "_id" : "2qccJ28BCSSrjaXdSOnC", "_score" : 60.272747, "_source" : { "user_score" : 9, "critic_score" : 92, "name" : "Final Fantasy VII" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "K6ccJ28BCSSrjaXdSOrC", "_score" : 57.623398, "_source" : { "user_score" : 8, "critic_score" : 94, "name" : "Final Fantasy IX" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6KccJ28BCSSrjaXdSOnC", "_score" : 56.96106, "_source" : { "user_score" : 8, "critic_score" : 92, "name" : "Final Fantasy X" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6qccJ28BCSSrjaXdSOnC", "_score" : 56.29872, "_source" : { "user_score" : 8, "critic_score" : 90, "name" : "Final Fantasy VIII" } }, ...细心的读者可能看出来了。我们的分数和之前的那个 soft_score 结果是不一样的，但是我们搜索的结果的排序是一样的。
在上面的 script 的写法中，我们使用了硬编码，也就是把10硬写入到 script 中了。假如有一种情况，我将来想修改这个值为20或其它的值，重新看看查询的结果。由于 script 的改变，需要重新进行编译，这样的效率并不高。一种较好的办法是如下的写法：
代码语言：javascript复制GET best_games/_search{ "_source": [ "name", "critic_score", "user_score" ], "query": { "script_score": { "query": { "match": { "name": "Final Fantasy" } }, "script": { "params":{ "multiplier": 10 }, "source": "_score * (doc['user_score'].value*params.multiplier doc['critic_score'].value)/2/100" } } }}脚本编译被缓存以加快执行速度。 如果脚本具有需要考虑的参数，则最好重用相同的脚本并为其提供参数。
boost_mode
boost_mode是用来定义最新计算出来的分数如何和查询的分数来相结合的。
mulitply | 查询分数和功能分数相乘（默认） |
|---|---|
replace | 仅使用功能分数，查询分数将被忽略 |
sum | 查询分数和功能分数相加 |
avg | 平均值 |
max | 查询分数和功能分数的最大值 |
min | 查询分数和功能分数的最小值 |
field_value_factor
field_value_factor 函数使您可以使用文档中的字段来影响得分。 与使用 script_score 函数类似，但是它避免了脚本编写的开销。 如果用于多值字段，则在计算中仅使用该字段的第一个值。
例如，假设您有一个用数字 likes 字段索引的文档，并希望通过该字段影响文档的得分，那么这样做的示例如下所示：
代码语言：javascript复制GET /_search{ "query": { "function_score": { "field_value_factor": { "field": "likes", "factor": 1.2, "modifier": "sqrt", "missing": 1 } } }}上面的 function_score 将根据 field_value_factore 按照如下的方式来计算分数：
代码语言：javascript复制sqrt(1.2 * doc['likes'].value)field_value_factor 函数有许多选项：
field | 要从文档中提取的字段。 |
|---|---|
factor | 字段值乘以的可选因子，默认为1。 |
modifier | 应用于字段值的修饰符可以是以下之一：none，log，log1p，log2p，ln，ln1p，ln2p，square，sqrt 或 reciprocal。 默认为无。 |
missing | 如果文档没有该字段，则使用该值。 就像从文档中读取一样，修饰符和因数仍然适用于它。 |
针对我们的例子，我们也可以使用如下的方法来重新计算分数：
代码语言：javascript复制GET best_games/_search{ "_source": [ "name", "critic_score", "user_score" ], "query": { "function_score": { "query": { "match": { "name": "Final Fantasy" } }, "field_value_factor": { "field": "user_score", "factor": 1.2, "modifier": "none", "missing": 1 } } }}在上面的例子里，我们使用 user_score 字段，并把这个字段的 factor 设置为1.2。这样加大这个字段的重要性。重新进行搜索：
代码语言：javascript复制 "hits" : [ { "_index" : "best_games", "_type" : "_doc", "_id" : "2qccJ28BCSSrjaXdSOnC", "_score" : 87.89488, "_source" : { "user_score" : 9, "critic_score" : 92, "name" : "Final Fantasy VII" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6KccJ28BCSSrjaXdSOnC", "_score" : 78.128784, "_source" : { "user_score" : 8, "critic_score" : 92, "name" : "Final Fantasy X" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6qccJ28BCSSrjaXdSOnC", "_score" : 78.128784, "_source" : { "user_score" : 8, "critic_score" : 90, "name" : "Final Fantasy VIII" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "K6ccJ28BCSSrjaXdSOrC", "_score" : 78.128784, "_source" : { "user_score" : 8, "critic_score" : 94, "name" : "Final Fantasy IX" } }, ...我们可以看出来我们的分数又有些变化。而且排序也有变化。
functions
上面的例子中，每一个 doc 都会乘以相同的系数，有时候我们需要对不同的 doc 采用不同的权重。这时，使用 functions 是一种不错的选择。几个 function 可以组合。 在这种情况下，可以选择仅在文档与给定的过滤查询匹配时才应用该 function:
代码语言：javascript复制 GET /_search{ "query": { "function_score": { "query": { "match_all": {} }, "boost": "5", "functions": [ { "filter": { "match": { "test": "bar" } }, "random_score": {}, "weight": 23 }, { "filter": { "match": { "test": "cat" } }, "weight": 42 } ], "max_boost": 42, "score_mode": "max", "boost_mode": "multiply", "min_score": 42 } }}上面的 boost 为5，也即所有的文档的加权都是5。我们同时也看到几个定义的 functions。它们是针对相应的匹配的文档分别进行加权的。如果匹配了，就可以乘以相应的加权。
针对我们的例子，我们也可以做如下的实验。
代码语言：javascript复制GET best_games/_search{ "query": { "function_score": { "query": { "match": { "name": "Final Fantasy" } }, "boost": "1", "functions": [ { "filter": { "match": { "name": " XIII" } }, "weight": 10000000 } ], "boost_mode": "multiply" } }}我们想把 name 含有 XIII 的所有游戏都加一个权。这样它可以排到最前面。我们给它的加权值很大：10000000。
搜索后的结果是：
代码语言：javascript复制 "hits" : [ { "_index" : "best_games", "_type" : "_doc", "_id" : "KqccJ28BCSSrjaXdSOrC", "_score" : 8.1384144E7, "_source" : { "global_sales" : 5.33, "year" : 2009, "image_url" : "https://www.wired.com/images_blogs/gamelife/2009/09/ffxiii-01.jpg", "platform" : "PS3", "@timestamp" : "2009-01-01T00:00:00.000 08:00", "user_score" : 7, "critic_score" : 83, "name" : "Final Fantasy XIII", "genre" : "Role-Playing", "publisher" : "Square Enix", "developer" : "Square Enix", "id" : "final-fantasy-xiii-ps3-2009" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "OKccJ28BCSSrjaXdSOvC", "_score" : 7.2601472E7, "_source" : { "global_sales" : 2.63, "year" : 2011, "image_url" : "https://i.ytimg.com/vi/tSJH_vhaYUk/maxresdefault.jpg", "platform" : "PS3", "@timestamp" : "2011-01-01T00:00:00.000 08:00", "user_score" : 6, "critic_score" : 79, "name" : "Final Fantasy XIII-2", "genre" : "Role-Playing", "publisher" : "Square Enix", "developer" : "Square Enix", "id" : "final-fantasy-xiii-2-ps3-2011" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "2qccJ28BCSSrjaXdSOnC", "_score" : 8.138414, "_source" : { "global_sales" : 9.72, "year" : 1997, "image_url" : "https://r.hswstatic.com/w_907/gif/finalfantasyvii-MAIN.jpg", "platform" : "PS", "@timestamp" : "1997-01-01T00:00:00.000 08:00", "user_score" : 9, "critic_score" : 92, "name" : "Final Fantasy VII", "genre" : "Role-Playing", "publisher" : "Sony Computer Entertainment", "developer" : "SquareSoft", "id" : "final-fantasy-vii-ps-1997" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6KccJ28BCSSrjaXdSOnC", "_score" : 8.138414, "_source" : { "global_sales" : 8.05, "year" : 2001, "image_url" : "https://www.mobygames.com/images/promo/l/192477-final-fantasy-x-screenshot.jpg", "platform" : "PS2", "@timestamp" : "2001-01-01T00:00:00.000 08:00", "user_score" : 8, "critic_score" : 92, "name" : "Final Fantasy X", "genre" : "Role-Playing", "publisher" : "Sony Computer Entertainment", "developer" : "SquareSoft", "id" : "final-fantasy-x-ps2-2001" } },...我们可以看出来，在这一次的搜索中 Final Fantasy XIII 的排名变成第一了。
Elasticsearch中 的衰变函数
在 Elasticsearch 中，常见的 Decay function （衰变函数）有一下的几种：
Function 评分技术不仅可以修改默认的 Elasticsearch 评分算法，还可以用于完全替代它。 一个很好的例子是 “trending” 搜索，显示主题中正在迅速流行的项目。
这样的分数不能基于简单的指标（例如“喜欢”或“观看次数”），而必须根据当前时间不断调整。 与在24小时内获得10000次观看的视频相比，在1小时内获得1000次观看的视频通常被认为“更热”。 Elasticsearch 附带了几个衰减函数，这些函数使解决此类问题变得轻而易举。
我们现在以 gauss 来为例展示如何使用这个衰变函数的。曲线的形状可以通过 orgin，scale，offset 和 decay 来控制。 这三个变量是控制曲线形状的主要工具。 可以将 origin 和 scale 参数视为您的最小值和最大值，它定义了将在其中定义曲线的边界框。 如果我们希望趋势视频列表涵盖一整天，则最好将原点定义为当前时间戳，比例尺定义为24小时。 offset 可用于在开始时将曲线完全平坦，例如将其设置为1h，可消除最近视频的所有惩罚，也即最近1个小时里的所有视频不受影响 。最后，衰减选项会根据文档的位置更改文档降级的严重程度。 默认的衰减值是0.5，较大的值会使曲线更陡峭，其效果也更明显。
我们还是拿我们的 best_games 来为例：
代码语言：javascript复制GET best_games/_search{ "_source": [ "name", "critic_score", "user_score" ], "query": { "function_score": { "query": { "match": { "name": "Final Fantasy" } }, "functions": [ { "gauss": { "@timestamp": { "origin": "2016-01-01T00:00:00", "scale": "365d", "offset": "0h", "decay": 0.1 } } } ], "boost_mode": "multiply" } }}上面的查询是基于2016-010-01这一天开始，在365天之内的文档不收衰减，那么超过这个时间的所有文档，衰减的加权值为0.1。也就是说1年开外的所有文档对我的意义并不是太多。
重新运行我们的查询，结果显示：
代码语言：javascript复制 "hits" : [ { "_index" : "best_games", "_type" : "_doc", "_id" : "OKccJ28BCSSrjaXdSOvC", "_score" : 6.6742494E-25, "_source" : { "user_score" : 6, "critic_score" : 79, "name" : "Final Fantasy XIII-2" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "2qccJ28BCSSrjaXdSOnC", "_score" : 0.0, "_source" : { "user_score" : 9, "critic_score" : 92, "name" : "Final Fantasy VII" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6KccJ28BCSSrjaXdSOnC", "_score" : 0.0, "_source" : { "user_score" : 8, "critic_score" : 92, "name" : "Final Fantasy X" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "6qccJ28BCSSrjaXdSOnC", "_score" : 0.0, "_source" : { "user_score" : 8, "critic_score" : 90, "name" : "Final Fantasy VIII" } }, { "_index" : "best_games", "_type" : "_doc", "_id" : "FqccJ28BCSSrjaXdSOrC", "_score" : 0.0, "_source" : { "user_score" : 7, "critic_score" : 92, "name" : "Final Fantasy XII" } },...这次的搜索结果显示 Final Fantasy XIII-2 是得分最高的文档。
参考：
【1】https://www.elastic.co/blog/found-function-scoring
【2】https://medium.com/horrible-hacks/customizing-scores-in-elasticsearch-for-product-recommendations-9e0d02ce1dbd
【3】https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-function-score-query.html#function-field-value-factor
【4】https://juejin.im/post/5df8f465518825123751c089
【5】https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-script-score-query.html
最新活动
包含文章发布时段最新活动，前往ES产品介绍页，可查找ES当前活动统一入口
Elasticsearch Service自建迁移特惠政策>>
Elasticsearch Service 新用户特惠狂欢，最低4折首购优惠 >>
Elasticsearch Service 企业首购特惠，助力企业复工复产>>
关注“腾讯云大数据”公众号，技术交流、最新活动、服务专享一站Get~
