【问题标题】:How to get Elasticsearch score result detail?如何获取 Elasticsearch 评分结果详细信息?
【发布时间】:2020-08-28 16:37:44
【问题描述】:

我有一个弹性索引来保存一些项目。结构如下。

public class items
{
    public string item_no { get; set; }
    public string category { get; set; }
    public int campaign { get; set; }
    public int in_stock { get; set; }
    // Next properties only include [a-z0-9]. Not any other characters
    public string score_item_no { get; set; }   
    public string score_group_one { get; set; }
    public string score_group_two { get; set; }
    public string score_description { get; set; }
    public string score_all_fields { get; set; } /* score_item_no + score_group_one + score_group_two + score_description and something else */
}

public class ClassForScore
{
        public int id { get; set; }
        public string item_no { get; set; }
}

我必须从结果中过滤掉无用的记录。我决定使用 score 选项并创建一个函数来计算平均分数。所以首先我调用 elasticsearch 来获取分数,然后使用 minscore 参数调用。我找不到任何过滤无用结果的解决方案对此有什么建议吗?这是第一个问题。

第二个: 第一个 score 调用返回 7 条记录。每条记录都有不同的分数。例如,第一条记录有 1100 分。 但是我想知道这个1100是从哪里来的? 1000 来自 score_item_no 和 100 来自 score_group_one,或 500 来自 score_group_one 匹配 5 个部分,其中 500 个 score_group_two 匹配 5 个部分,100 个来自 score_description 匹配 2 个部分。 有没有办法找到分数详情?

    QueryContainer queryContainsAnd = new WildcardQuery() { Field = "score_all_fields", Value = "*" + mykeyword + "*" };
    QueryContainer queryEqualsOr =  new TermQuery() { Field = "category", Value = *something1* };
    queryEqualsOr |=  new TermQuery() { Field = "category", Value = *something2* };
    QueryContainer queryEqualsAnd = new TermQuery() { Field = "campaign", Value = 1 };
    queryEqualsAnd &= new TermQuery() { Field = "in_stock", Value = 1 };
            
            
    QueryContainer mainQuery = queryContainsAnd & queryEqualsAnd & queryEqualsOr;
    
    Func<QueryContainerDescriptor<ClassForScore>, QueryContainer> fo = funcScoreParam(new ClassForScore(), filterItemNo, filterGroupOne, filterGroupTwo, filterDescription, mainQuery);
    ISearchResponse<ClassForScore> srcSkor = elasticClient.Search<ClassForScore>(s => s
        .RequestConfiguration(r => r.DisableDirectStreaming())
        .Query(fo)
        .Size(100)
    );
    IReadOnlyCollection<IHit<ClassForScore>> lstSkor = srcSkor.Hits;
    double? dblSkorAvg = 0;
    // Some calculation..
    //.....
    Func<QueryContainerDescriptor<items>, QueryContainer> fo2 = funcScoreParam(new ClassForScore(), filterItemNo, filterGroupOne, filterGroupTwo, filterDescription, mainQuery);
    ISearchResponse<items> srcResult = elasticClient.Search<items>(s => s
        .RequestConfiguration(r => r.DisableDirectStreaming())
        .From(0)
        .Size(100)
        .Sort(S => S.Descending(SortSpecialField.Score).Ascending(r => r.item_no))
        .MinScore(dblSkorAvg)
        .Query(fo2)
    );
    
    
    private Func<QueryContainerDescriptor<T>, QueryContainer> funcScoreParam<T>(T nesne, QueryContainer filterItemNo, QueryContainer filterGroupOne, QueryContainer filterGroupTwo, QueryContainer filterDescription, QueryContainer mainQuery) where T : class
    {
        return new Func<QueryContainerDescriptor<T>, QueryContainer>(q => q
            .FunctionScore(fsc => fsc
                .BoostMode(FunctionBoostMode.Sum)
                .ScoreMode(FunctionScoreMode.Sum)
                .Functions(fu => fu
                        .Weight(w => w
                            .Weight(1000)
                            .Filter(wf => wf
                            .Bool(bb => bb
                            .Must(filterItemNo))
                            ))
                        .Weight(w => w
                            .Weight(100)
                            .Filter(wf => wf
                            .Bool(bb => bb
                            .Must(filterGroupOne))
                            ))
                        .Weight(w => w
                            .Weight(100)
                            .Filter(wf => wf
                            .Bool(bb => bb
                            .Must(filterGroupTwo)) 
                            ))
                        .Weight(w => w
                            .Weight(50)
                            .Filter(wf => wf
                            .Bool(bb => bb
                            .Must(filterDescription))
                            ))
                    )
                    .Query(q2 => q2
                        .Bool(b => b
                        .Should(mainQuery))
                    )
        ));
    }

【问题讨论】:

    标签: c# elasticsearch nest


    【解决方案1】:

    您可以使用搜索 API 上的 explain 参数返回有关每次点击的分数计算的详细信息

    ISearchResponse<items> srcResult = elasticClient.Search<items>(s => s
        .RequestConfiguration(r => r.DisableDirectStreaming())
        .From(0)
        .Size(100)
        .Sort(S => S.Descending(SortSpecialField.Score).Ascending(r => r.item_no))
        .MinScore(dblSkorAvg)
        .Query(fo2)
        .Explain() // <-- explain score computation for each hit
    );
    
    

    还有一个专门的explain API to understand how a specific document's score is calculated.

    【讨论】:

    • 非常感谢@RussCam。而且我发现,如果您将 null QueryContainer 作为参数发送给函数,则总分包括它的权重。顺便说一句,两次弹性搜索是计算分数和过滤或任何建议的正确方法?
    • > BTW 两次去弹性搜索是计算分数和过滤的正确方法或任何建议?我不确定您为什么要这样做,但 Elasticsearch 会为给定查询的每个文档计算分数。评分是使用BM25 计算的,因此评分与文档中查询输入中术语的频率和跨文档的反频率有关。查看您的查询,您可能想要在 bool 查询中对查询使用提升,而不是对函数中的查询使用权重。
    • Elasticsearch如何在没有字段权重的情况下计算分数?也许,我的结构有问题。我有 5 个评分字段和一个用于搜索的字段,包括每个文档的所有关键字。我正在根据哪个评分字段包含关键字来计算分数。我不确定我是否能用我的英语正确解释。在这种情况下,您有什么建议?
    • 我已将其作为一个新问题提出:stackoverflow.com/questions/63670605/…
    【解决方案2】:

    在 Python elasticsearch_dsl 库中,此语法为

     my_search.extra(explain=True).execute()
    

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2013-11-12
      • 2021-03-11
      • 2016-09-24
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多