from utils.logger import Logger
from connectors.elasticsearch import elasticsearch_client, ElasticsearchException

from conf import config

try:
    index_name = f'{config.ES_INDEX}-*'
    res = elasticsearch_client.count(index=index_name)

    total = res['count']
    Logger(f'Total Document count in es: {total}').log_info()

except ElasticsearchException as error:
    Logger(index_name).log_exception(error)