knowledgeGraphCreator.py 文件源码

def getKibiRelationConfig(indexName=".kibi", typeName="config" , elasticPort=9220, elasticHost="localhost"):
    es =  Elasticsearch([{'host': elasticHost, 'port': elasticPort}], http_auth=(elasticUsername, elasticPassword))
    mapping = es.search(
                index=indexName,
                doc_type=typeName,
                size=1000,
                request_timeout=1060,
                body={
                'query': {
                    'filtered': {
                      'query': {
                        'match_all': {}
                      }
                    }
                  }
                }
            )
    return mapping['hits']['hits'][0]
    #return mapping[SourceIndexName]["mappings"][SourceTypeName]