elasticsearch – 弹性搜索按嵌套文档的计数过滤

2023年7月6日 185次阅读

我有一个公司的弹性搜索索引,它有一个称为事务的嵌套对象.交易至少有一个日期字段.这是一个示例：

firms: [
  {
    "name": "abc",
    "address" : "xyz",
    "transactions": [
       {
         "date" : "2014-12-20"
         "side" : "buyer"
       },
       ...
     ]
  },
  ...
]

根据这些数据,我想查询过去6或12个月内(例如)3笔交易的所有公司.

以下查询返回过去12个月内至少有一笔交易的公司：

POST firms/firm/_search
    {
    "query": {
        "nested": {
           "path": "transactions",
           "query": {
               "bool": {
                   "must": [
                      {
                          "match": {
                             "transactions.side": "buyer"
                          }
                      },
                      {
                          "range": {
                             "transactions.date": {
                                "from": "2014-10-24",
                                "to": "2015-10-24"
                             }
                          }
                      }
                   ]
               }
           }
        }  
    }
}

我不确定如何扩展此查询以匹配在y个月内具有x个事务的公司.任何帮助将不胜感激.谢谢

最佳答案 我认为你没有其他选择而不是使用脚本.像这样的东西：

{
  "query": {
    "bool": {
      "must": [
        {
          "nested": {
            "path": "transactions",
            "query": {
              "bool": {
                "must": [
                  {
                    "match": {
                      "transactions.side": "buyer"
                    }
                  },
                  {
                    "range": {
                      "transactions.date": {
                        "from": "2014-10-24",
                        "to": "2015-10-24"
                      }
                    }
                  }
                ]
              }
            }
          }
        },
        {
          "filtered": {
            "filter": {
              "script": {
                "script": "if(_source.transactions.size<3) return false;fromDate=Date.parse('yyyy-MM-dd',fromDateParam);toDate=Date.parse('yyyy-MM-dd',toDateParam);count=0;for(d in _source.transactions){docsDate=Date.parse('yyyy-MM-dd',d.get('date'));if(docsDate>=fromDate && docsDate<=toDate){count++};if(count==3){return true;}};return false;",
                "params": {
                  "fromDateParam":"2014-10-24",
                  "toDateParam":"2015-10-24"
                }
              }
            }
          }
        }
      ]
    }
  }
}

实际范围过滤器是那些没有日期匹配的文档的“优化”.因此,此文档(范围内没有日期)将无法访问更昂贵的脚本过滤器.

脚本本身首先检查事务数是否小于3.如果是,则不要打扰进行所有日期检查并返回false.如果它超过3,则取每个日期并与参数进行比较.一旦达到3的计数,请停止查看其余日期并返回true.

点赞