Elasticsearch: Get Family - Python

This package returns the parent and its children together. This is compatible with elasticsearch version >=5.0.0,<6.0.0.

from elasticsearch import Elasticsearch  
import esgetfamily

def get_es_object():  
    es = Elasticsearch(elastic_cred)  
    return es  

es_db = get_es_object()  

For single parent:

parents = es_db.get(index=parent_index, doc_type=parent_type, id=parent_id)  
final = esgetfamily.parent_child(es_db, parents, child_type)

For single parent with query for child:

query = {  
    "match": {  
        "id": 1  
    }  
}

parents = es_db.get(index=parent_index, doc_type=parent_type, id=parent_id)  
final = esgetfamily.parent_child(es_db, parents, child_type, query)

For multiple parents:

parents = [es_db.get(index=parent_index, doc_type=parent_type, id=parent_id),  
           es_db.get(index=parent_index, doc_type=parent_type, id=parent_id)]
final = esgetfamily.parent_child(es_db, parents, child_type)

For multiple parents with query for child:

query = {  
    "match": {  
        "id": 1  
    }  
}

parents = [es_db.get(index=parent_index, doc_type=parent_type, id=parent_id),  
           es_db.get(index=parent_index, doc_type=parent_type, id=parent_id)]  
final = esgetfamily.parent_child(es_db, parents, child_type, query)

Sample Example:

Code:

from elasticsearch import Elasticsearch
def get_es_object():  
    es = Elasticsearch(elastic_cred)  
    return es  
es_db = get_es_object()  
import esgetfamily, json

parents = es_db.get(index="parent", doc_type="par", id=3)
final = esgetfamily.parent_child(es_db, parents, "child")
print json.dumps(final, indent=3)

Result:

{
  "3": {
    "parent": {
      "_type": "par",
      "_source": {
        "age": 23,
        "id": 3,
        "name": "ABC"
      },
      "_index": "parent",
      "_version": 1,
      "found": true,
      "_id": "3"
    },
    "child": [
      {
        "_type": "child",
        "_routing": "3",
        "_index": "parent",
        "_score": 1.0,
        "_source": {
          "id": 1,
          "name": "Child1"
        },
        "_parent": "3",
        "_id": "1"
      },
      {
        "_type": "child",
        "_routing": "3",
        "_index": "parent",
        "_score": 1.0,
        "_source": {
          "id": 2,
          "name": "Child2"
        },
        "_parent": "3",
        "_id": "2"
      }
    ]
  }
}