import logging from elasticsearch import Elasticsearch # Setting up logging logging.basicConfig(level=logging.INFO, format='%(asctime)s [%(levelname)s] %(filename)s:%(lineno)d - %(message)s', datefmt='%Y-%m-%d %H:%M:%S') # Elasticsearch client setup es = Elasticsearch(hosts="http://localhost:9200", basic_auth=("elastic", "YourElasticPassword")) # Create an index with a mappings for embeddings def create_index(index_name: str, embedding_dimensions: int): try: es.indices.create( index=index_name, body={ 'mappings': { 'properties': { 'blog_id': {'type': 'long'}, 'title': {'type': 'text'}, 'content': {'type': 'text'}, 'embedding': {'type': 'dense_vector', 'dims': embedding_dimensions} } } } ) except Exception as e: logging.error(f"An error occurred while creating index {index_name} : {e}") # Sample usage create_index("blogs", 1536)