elastic.py 文件源码

def __init__(self, settings):
        kwargs = settings.get('es').get('client')
        es_user = settings.get('es_user')
        es_pass = settings.get('es_pass')

        if es_user and es_pass:
            kwargs.update(**dict(http_auth=(es_user, es_pass)))

        self.client = Elasticsearch(**kwargs)
        self.timeout = settings.get('es').get('client').get('timeout')
        self.doc_type = settings.get('es').get('doc_type')
        self.index_name = settings.get('es').get('index')
        self.id_field = settings.get('id_field')
        self.bulk_size = settings.get('bulk_size', 1000)
        self.path_encoding = settings.get('path_encoding')

        self.actions = []

        log.debug('ESStorer instance created: %s', self.client)