ElasticSearch の複数レベルの親子集約質問する

Question

これを行うには集計は必要ありません。

並べ替えの基準は次のとおりです。

距離 ASC (会社.所在地)
評価 DESC (company.rating_value)
最も早い将来の可用性 ASC (company.employee.availability.start)

3を無視すれば、比較的単純な会社次のようなクエリを実行します。

GET /companies/company/_search
{
 "query": { "match_all" : {} },
 "sort": {
    "_script": {
        "params": {
            "lat": 51.5186,
            "lon": -0.1347
        },
        "lang": "groovy",
        "type": "number",
        "order": "asc",
        "script": "doc['location'].distanceInMiles(lat,lon)"
    },
    "rating_value": { "order": "desc" }
  }
}

＃3手を伸ばして空き状況を見つける必要があるため、難しいです（会社 > 従業員 > 空き状況）を各企業ごとにリクエストの時間に最も近い期間に設定し、その期間を三番目並べ替え基準。

孫レベルでクエリを使用してfunction_score、リクエスト時間とヒット内の各可用性の間の時間差を取得します。(次に、を3 番目の並べ替え基準として_score使用します)。_score

孫に到達するには、クエリhas_child内でクエリを使用する必要がありますhas_child。

各企業について、最も早く利用可能な従業員（そしてもちろん最も近い空き時間）が必要です。Elasticsearch 2.0は"score_mode": "min"このような場合にを提供しますが、今のところはに制限されているため、"score_mode": "max"孫_scoreをにします。相互時間差の。

          "function_score": {
            "filter": { 
              "range": { 
                "start": {
                  "gt": "2014-12-22T10:34:18+01:00"
                } 
              }
            },
            "functions": [
              {
                "script_score": {
                  "lang": "groovy",
                  "params": {
                      "requested": "2014-12-22T10:34:18+01:00",
                      "millisPerHour": 3600000
                   },
                  "script": "1 / ((doc['availability.start'].value - new DateTime(requested).getMillis()) / millisPerHour)"
                }
              }
            ]
          }

それで、_scoreそれぞれの孫（可用性）は1 / number-of-hours-until-available（最大逆数従業員1人あたりの利用可能までの時間、および最大の逆数(？)利用可能な従業員数（会社あたり）

これらすべてをまとめると、私たちは引き続き質問します会社しかし、使用会社 > 従業員 > 空き状況を生成する_scoreために使用する＃3並べ替え基準:

GET /companies/company/_search
{
 "query": { 
    "has_child" : {
        "type" : "employee",
        "score_mode" : "max",
        "query": {
          "has_child" : {
            "type" : "availability",
            "score_mode" : "max",
            "query": {
              "function_score": {
                "filter": { 
                  "range": { 
                    "start": {
                      "gt": "2014-12-22T10:34:18+01:00"
                    } 
                  }
                },
                "functions": [
                  {
                    "script_score": {
                      "lang": "groovy",
                      "params": {
                          "requested": "2014-12-22T10:34:18+01:00",
                          "millisPerHour": 3600000
                       },
                      "script": "1/((doc['availability.start'].value - new DateTime(requested).getMillis()) / millisPerHour)"
                    }
                  }
                ]
              }
            }
          }
        }
    }
 },
 "sort": {
  "_script": {
    "params": {
        "lat": 51.5186,
        "lon": -0.1347
    },
    "lang": "groovy",
    "type": "number",
    "order": "asc",
    "script": "doc['location'].distanceInMiles(lat,lon)"
  },
  "rating_value": { "order": "desc" },
  "_score": { "order": "asc" }
 }
}

Answer 1