一尘不染

Spring搜索排序预处理

elasticsearch

我在ES中有一个索引,除其他字段外,该索引还具有Revenue_amount和Revenue_currency字段。收入以不同的货币存储。在运行时,所有货币都将转换为USD并进行渲染。

现在,我想支持在Revenue_amount字段上进行排序。问题在于ES在转换为USD之前会根据收入对结果进行排序,因此返回顶部的收入可能不是转换为USD后的最高收入。

我想知道,是否有可能在排序之前,ES调用用户定义的函数来更改字段值,然后再应用排序?像这样:

Revenue_converted = convertToUSD(收益)

因此,排序将应用于收入转换后的收入,而不是收入。

我知道我可以在索引时转换货币,但是这需要在每次汇率更新时刷新索引,因此,如果可能的话,我想避免这种情况。


阅读 276

收藏
2020-06-22

共1个答案

一尘不染

您有两种方法可以实现此目的:一种是通过使用基于脚本的排序(如keety所述):

{
    "query" : {
        ....                                    <--- your query goes here
    },
    "sort" : {
        "_script" : {
            "script" : "doc.revenue_amount.value * usd_conversion_rate",
            "type" : "number",
            "params" : {
                "usd_conversion_rate" : 0.4273  <--- the conversion rate to USD
            },
            "order" : "desc"
        }
    }
}

usd_conversion_rate因素是转化率美元。因此,例如,如果1美元价值2.34单位另一种货币,则usd_conversion_rate系数为1 / 2.34(或0.4273)。乘以后,revenue_amount您会得到美元参考货币的金额。

但是,基于脚本的排序不是很有效,建议使用a,function_score以便可以按分数对结果进行排序。这使我们找到了实现您所需要的第二种方式,它就是这样。一种方法是使用script_score函数,但这又涉及脚本。

{
  "query": {
    "function_score": {
      "query": {},
      "functions": [
        {
          "script_score": {
            "script": "doc.revenue_amount.value * usd_conversion_rate",
            "boost_mode": "replace",
            "params": {
              "usd_conversion_rate": 0.4273
            }
          }
        }
      ]
    }
  }
}

由于我们上面的脚本非常简单(即,将某个字段乘以某个系数),因此最简单的方法将涉及使用field_value_factor,它的内容如下:

{
  "query": {
    "function_score": {
      "query": {
        ...                              <--- your query goes here
      },
      "functions": [
        {
          "field_value_factor": {
            "field": "revenue_amount",
            "boost_mode": "replace",
            "factor": 0.4273             <--- insert the conversion rate here
          }
        }
      ]
    }
  }
}

更新

根据您的最新评论,看来适合您的选择script_score毕竟是使用。这里的想法是在查询表中输入所有可用的货币汇率作为script_score脚本的参数,然后根据该revenue_currency字段的值使用适当的汇率。

{
  "query": {
    "function_score": {
      "query": {},
      "functions": [
        {
          "script_score": {
            "script": "doc.revenue_amount.value * (doc.revenue_currency.value == 'EUR' ? EUR : (doc.revenue_currency.value == 'AUD' ? AUD : 1))",
            "boost_mode": "replace",
            "params": {
              "EUR": 0.4945,
              "AUD": 0.5623
            }
          }
        }
      ]
    }
  }
}
2020-06-22