_elastic_search.py 文件源码

def __init__(self, name, host, port, doc_type, index):
        self.host = host
        self.port = port
        self.doc_type = doc_type
        self.index = index
        DatabaseInterface.__init__(self,
                                   name=name,
                                   db_type='ElasticSearch',
                                   conn_exception=elasticsearch.ConnectionError,
                                   execution_exception=elasticsearch.ElasticsearchException,
                                   type_converter=self.TYPE_CONVERTER,
                                   deserialize_query=True)