带你读《Elastic Stack 实战手册》之74:——4.1.6.优化Elasticsearch中的打分(_score)(中)

本文涉及的产品
检索分析服务 Elasticsearch 版,2核4GB开发者规格 1个月
简介: 带你读《Elastic Stack 实战手册》之74:——4.1.6.优化Elasticsearch中的打分(_score)(中)


《Elastic Stack 实战手册》——四、应用实践——4.1 企业搜索应用场景 ——4.1.6.优化Elasticsearch中的打分(_score)(上) https://developer.aliyun.com/article/1226242



使用全局计算打分


我们都知道 Elasticsearch 是一个分布式的搜索引擎,我们的数据分布在不同的分片上,在 _score 的计算过程中,Elasticsearch 默认取当前分片的数据来计算一个文档的相关性打分,也就是说我们搜索相同的内容,在不同分片上的打分是不同的,这样会导致我们搜索出来的内容相关性不那么‘靠谱。Elasticsearch 在这种场景下的解决方案是指定 search_type 为dfs_query_then_fetch,使用这个模式进行搜索,Elasticsearch 会首先从搜索的所有分片收集信息,全局计算分布式词频。然后再进行默认的 query_then_fetch 查询。这样计算的优点就是我们获取的文档的相关性是非常准确的,不会出现排序上的差异。缺点肯定就是增加了一次全局计算的过程,这样可能就会导致我们的搜索速度变慢,对机器的负载肯定是有影响的。所以就要权衡一下利弊,看下是搜索的速度稳定性更重要,还是搜索的准确性更重要。


调整打分公式


对于 _socre 的计算公式,如果我们需要更改,或者调整其中的参数,Elasticsearch 也给了方便的 API 来实现,例如下面这请求,我们认为默认的 BM25 满足不了我们目前的需求,需要定义一个打分公式,这个打分公式使用 DFR 算法,对于里面的一些参数我们自己指定:

PUT /index
{
  "settings": {
    "index": {
      "similarity": {
        "my_similarity": {  // 定义一个名为 my_similarity 的打分公式
          "type": "DFR",
          "basic_model": "g",
          "after_effect": "l",
          "normalization": "h2",
          "normalization.h2.c": "3.0"
        }
      }
    }
  }
}

我们可以在我们的 mapping 中指定我们的打分公式:


PUT /index/_mapping
{
  "properties" : {
    "title" : { "type" : "text", "similarity" : "my_similarity" }
  // 表示我们这个索引下的 title 字段使用我们上面设置的打分公式
  }
}

Elasticsearch目前支持了以下公式的定制:


l BM25 Okapi_BM25 (默认),type:BM25,可以调整的参数:k1、b。

l DFR divergence from randomness,type:DFR,可以调整的参数:basic_model、after_effect、normalization。

l DFI divergence from independence,type:DFI,可以调整的参数:independence_measure。

l IB Information based model,type:IB,可以调整的参数:distribution,lambda,normalization。

l LM Dirichlet LM Dirichlet similarity, type:LMDirichlet,可以调整的参数:mu。

l LM Jelinek Mercer LM Jelinek Mercer similarity,type:LMJelinekMercer,可以调整的参数:Lambda。

l 同时 Elasticsearch 可以使用脚本来定制一个相关性打分,例如我们重新定义TF-IDF:

 

PUT /index
{
  "settings": {
    "number_of_shards": 1,
    "similarity": {
      "scripted_tfidf": {  // 定义一个名为 scripted_tfidf 的打分公式
        "type": "scripted", 
        "script": {
          "source": "double tf = Math.sqrt(doc.freq); 
           // 定义 tf 的计算逻辑为 freq 词频的平方根
           double idf = Math.log((field.docCount+1.0)/(term.docFreq+1.0)) + 1.0; 
           // 定义 idf = log((文档总数 + 1)/(匹配到的文档数 + 1)) + 1
           double norm = 1/Math.sqrt(doc.length);
           return query.boost * tf * idf * norm;"
           // 定义最终打分的逻辑 
        }
      }
    }
  },
  "mappings": {
     "properties": {
      "field": {
        "type": "text",
        "similarity": "scripted_tfidf" // 这个字段使用上面我们定义的打分函数
      }
    }
  }
}

对于企业搜索中的一些特殊打分需求,我们可以通过定制打分公式来实现。对于这种调整,我们要对调整后的公式有充分的了解并对用户的 query 进行大量测试,避免出现一些难以处理的问题。

 

调整 DSL

 

当 _score 的计算方法确定以后,我们的dsl也是有调整空间的,Elasticsearch 也提供了很多查询方式给我们来调整 _score。这里主要说一下Script Score query、 Boolean query(布尔查询,就是利用布尔关系,链接多个子查询)、Boosting query(通过Boosting查询,降低某些文档匹配)、Disjunction max query(最佳字段查询)、Function score query(使用

function_score 来为一个查询定义计算最终打分的方法)。


Script Score query

 

使用 Script Score query 可以方便的在检索中修改文档的 _score,我们可以定义类似脚本语言的语句,灵活的定制打分。例如下面这个例子,我们用 script_score 来标识这是一个ScriptScore query,在 script 节点就可以写语句来表示我们想要将打分变成什么样子。

 

GET /_search
{
    "query" : {
        "script_score" : {
            "query" : {
                "match": { "tag": "Apple" }
            },
            "script" : {
                "source" : "doc['price'].value / 10 " 
        // 这里表示将文档的打分设置为 ’price‘ 字段的十分之一
            }
        }
     }
}

在 script 里面有很多种方式来改变打分,例如:

"script" : {
   "source" : "doc['price'].value + _score"  // 打分为当前得分加上’price’值
}
// 取一个随机数
"script" : {
    "source" : "randomScore(100)"
}
// 日期类型字段的衰减函数
"script" : {
    "source" : "decayDateGauss(params.origin, params.scale, params.offset, params.decay, doc['date'].value)",
    "params": {
        "origin": "2008-01-01T01:00:00Z",
        "scale": "1h",
        "offset" : "0",
        "decay" : 0.5
    }
}


《Elastic Stack 实战手册》——四、应用实践——4.1 企业搜索应用场景 ——4.1.6.优化Elasticsearch中的打分(_score)(下) https://developer.aliyun.com/article/1226238  


相关实践学习
使用阿里云Elasticsearch体验信息检索加速
通过创建登录阿里云Elasticsearch集群,使用DataWorks将MySQL数据同步至Elasticsearch,体验多条件检索效果,简单展示数据同步和信息检索加速的过程和操作。
ElasticSearch 入门精讲
ElasticSearch是一个开源的、基于Lucene的、分布式、高扩展、高实时的搜索与数据分析引擎。根据DB-Engines的排名显示,Elasticsearch是最受欢迎的企业搜索引擎,其次是Apache Solr(也是基于Lucene)。 ElasticSearch的实现原理主要分为以下几个步骤: 用户将数据提交到Elastic Search 数据库中 通过分词控制器去将对应的语句分词,将其权重和分词结果一并存入数据 当用户搜索数据时候,再根据权重将结果排名、打分 将返回结果呈现给用户 Elasticsearch可以用于搜索各种文档。它提供可扩展的搜索,具有接近实时的搜索,并支持多租户。
相关文章
|
16天前
|
机器学习/深度学习 算法 搜索推荐
Elasticsearch:崭新的打分机制 - Learning To Rank (LTR)
【6月更文挑战第8天】Elasticsearch 的 Learning To Rank (LTR) 打分机制通过机器学习改进搜索结果排序,以适应复杂需求和用户行为。传统打分基于词频等,而 LTR 利用训练数据学习更合理的排序,考虑文本、用户行为等特征。示例代码展示了如何在 Elasticsearch 中运用 LTR。尽管实施 LTR 需要高质量训练数据和专业选择算法,但它能处理模糊搜索、多因素排序,提升搜索体验,增强应用价值和竞争力。随着技术发展,LTR 将在 Elasticsearch 中发挥更大作用。
55 6
|
16天前
|
搜索推荐 开发者
如何在 Elasticsearch 中选择精确 kNN 搜索和近似 kNN 搜索
【6月更文挑战第8天】Elasticsearch 是一款强大的搜索引擎,支持精确和近似 kNN 搜索。精确 kNN 搜索保证高准确性但计算成本高,适用于对精度要求极高的场景。近似 kNN 搜索则通过牺牲部分精度来提升搜索效率,适合大数据量和实时性要求高的情况。开发者应根据业务需求和数据特性权衡选择。随着技术发展,kNN 搜索将在更多领域发挥关键作用。
29 4
|
3天前
|
存储 数据采集 负载均衡
Elasticsearch系列---搜索执行过程及scroll游标查询
Elasticsearch系列---搜索执行过程及scroll游标查询
|
1月前
|
存储 自然语言处理 搜索推荐
分布式搜索引擎ElasticSearch
Elasticsearch是一款强大的开源搜索引擎,用于快速搜索和数据分析。它在GitHub、电商搜索、百度搜索等场景中广泛应用。Elasticsearch是ELK(Elasticsearch、Logstash、Kibana)技术栈的核心,用于存储、搜索和分析数据。它基于Apache Lucene构建,提供分布式搜索能力。相比其他搜索引擎,如Solr,Elasticsearch更受欢迎。倒排索引是其高效搜索的关键,通过将词条与文档ID关联,实现快速模糊搜索,避免全表扫描。
103 3
|
1月前
|
运维 索引
Elasticsearch 写入优化探索:是什么影响了refresh 耗时?
Elasticsearch 写入优化探索:是什么影响了refresh 耗时?
32 7
|
1月前
|
存储 数据处理 索引
Elasticsearch 8.X 小技巧:使用存储脚本优化数据索引与转换过程
Elasticsearch 8.X 小技巧:使用存储脚本优化数据索引与转换过程
49 6
|
1月前
|
运维 架构师 搜索推荐
7 年+积累、 Elastic 创始人Shay Banon 等 15 位专家推荐的 Elasticsearch 8.X新书已上线...
7 年+积累、 Elastic 创始人Shay Banon 等 15 位专家推荐的 Elasticsearch 8.X新书已上线...
33 4
|
1月前
|
SQL 监控 搜索推荐
Elasticsearch 与 OpenSearch:开源搜索技术的演进与选择
Elasticsearch 与 OpenSearch:开源搜索技术的演进与选择
106 2
|
1月前
|
存储 机器学习/深度学习 API
高维向量搜索:在 Elasticsearch 8.X 中利用 dense_vector 的实战探索
高维向量搜索:在 Elasticsearch 8.X 中利用 dense_vector 的实战探索
126 0
高维向量搜索:在 Elasticsearch 8.X 中利用 dense_vector 的实战探索
|
1月前
|
存储 缓存 搜索推荐
深入理解Elasticsearch倒排索引原理与优化策略
总之,Elasticsearch的倒排索引是其高效全文搜索的核心。为了提高性能和可伸缩性,Elasticsearch采用了多种优化策略,包括压缩、分片、合并、位集合和近实时搜索等。这些策略使Elasticsearch成为处理大规模文本数据的强大工具。
127 0

热门文章

最新文章

相关产品

  • 检索分析服务 Elasticsearch版