INNER CODE UNIT · Python

get_opensearch_endpoint

aws-samples/rag-using-langchain-amazon-bedrock-and-opensearch · utils/opensearch.py:30

def get_opensearch_endpoint(name, region):
    client = boto3.client('es', region_name=region)
    response = client.describe_elasticsearch_domain(
        DomainName=name
    )
    return response['DomainStatus']['Endpoint']


def put_bulk_in_opensearch(list, client):
    logger.info(f"Putting {len(list)} documents in OpenSearch")
    success, failed = bulk(client, list)
    return success, failed

def check_opensearch_index(opensearch_client, index_name):
    return opensearch_client.indices.exists(index=index_name)


def create_index(opensearch_client, index_name):

View source record →