elasticsearch - 找到与我在同一公司中的哪一个的简单方法？

Question

索引有如下所示的字段，它保存谁在哪个公司和哪个职位

{
    "createtime" : 1562844632272,
    "post" : "director",
    "personId" : 30007346088,
    "comId" : 20010774891
 }

现在想找到某人的合伙人，也就是同一个公司中的那个人。现在我的实现是

首先找到该人的关联公司(最多500家)

{
    "query": { "term": { "personId": 30007346088 } },
    "sort": [ { "createtime": "desc" } ],
    "_source": ["comId"],
    "size":500
}

然后找到这些公司的相关人员并排除当前人员，并删除重复的合作伙伴(最多500个合作伙伴)

{
    "query": {
        "bool": {
            "must": [{ "terms": { "comId": [20010774891,...] } } ],
            "must_not": [ {"term":{"personId":30007346088}} ]
        }
    },
    "aggs" : {
        "personId" : {
            "terms" : {
                "field" : "personId",
                "size": 500
            }
        }
    },
    "size":0    
}

显然，这有点复杂，是否可以存在一些更简单的实现方法？

Answer 1

如果数据以以下格式存储，则可以使用。

每个人的唯一文档，文档ID与个人ID相同，公司存储为数组

POST indexperson/_doc/1
{
  "createtime": 1562844632272,
  "personId": 1,
  "company": [
    {
      "id": 100,
      "post": "director"
    },
    {
      "id": 100,
      "post": "director"
    }
  ]
}

数据:

 [
      {
        "_index" : "indexperson",
        "_type" : "_doc",
        "_id" : "1",
        "_score" : 1.0,
        "_source" : {
          "createtime" : 1562844632272,
          "personId" : 1,
          "company" : [
            {
              "id" : 100,
              "post" : "director"
            },
            {
              "id" : 101,
              "post" : "director"
            }
          ]
        }
      },
      {
        "_index" : "indexperson",
        "_type" : "_doc",
        "_id" : "2",
        "_score" : 1.0,
        "_source" : {
          "createtime" : 1562844632272,
          "personId" : 2,
          "company" : [
            {
              "id" : 101,
              "post" : "director"
            }
          ]
        }
      },
      {
        "_index" : "indexperson",
        "_type" : "_doc",
        "_id" : "3",
        "_score" : 1.0,
        "_source" : {
          "createtime" : 1562844632272,
          "personId" : 3,
          "company" : [
            {
              "id" : 100,
              "post" : "director"
            }
          ]
        }
      },
      {
        "_index" : "indexperson",
        "_type" : "_doc",
        "_id" : "4",
        "_score" : 1.0,
        "_source" : {
          "createtime" : 1562844632272,
          "personId" : 4,
          "company" : [
            {
              "id" : 104,
              "post" : "director"
            }
          ]
        }
      }
    ]

查询:
使用(术语查询)[ https://www.elastic.co/guide/en/elasticsearch/reference/current/query-dsl-terms-query.html]。字词查询以doc id为参数

GET indexperson/_search
{
  "query": {
    "bool": {
      "must": [
        {
          "terms": {
            "company.id": {
              "index": "indexperson",  
              "id": "1", --> get all docs in indexperson which match with company id
              "path": "company.id"
            }
          }
        }
      ],
      "must_not": [
        {
          "term": {
            "personId": {
              "value": 2
            }
          }
        }
      ]
    }
  }
}

结果:

"hits" : [
      {
        "_index" : "indexperson",
        "_type" : "_doc",
        "_id" : "1",
        "_score" : 1.0,
        "_source" : {
          "createtime" : 1562844632272,
          "personId" : 1,
          "company" : [
            {
              "id" : 100,
              "post" : "director"
            },
            {
              "id" : 101,
              "post" : "director"
            }
          ]
        }
      },
      {
        "_index" : "indexperson",
        "_type" : "_doc",
        "_id" : "3",
        "_score" : 1.0,
        "_source" : {
          "createtime" : 1562844632272,
          "personId" : 3,
          "company" : [
            {
              "id" : 100,
              "post" : "director"
            }
          ]
        }
      }
    ]