from elasticsearch import Elasticsearch, RequestsHttpConnection, ElasticsearchException
from utils.creds import awsauth

from conf import config

elasticsearch_client = Elasticsearch(
        [config.ES_DOMAIN],
        http_auth=awsauth,
        use_ssl=True,
        verify_certs=True,
        connection_class=RequestsHttpConnection,
        maxsize=config.ES_MAXSIZE,
        timeout=config.ES_TIMEOUT,
        retry_on_timeout=config.ES_RETRY_ON_TIMEOUT,
        max_retries=config.ES_MAX_RETRIES,
    )