NgT!ddlmZddlmZmZmZddlmZddlm Z er ddl m Z ddl m Z ddlmZedd d Gd d eZdS)) annotations) TYPE_CHECKINGListOptional) deprecated) get_from_env ElasticsearchMlClient) Embeddingsz0.1.11z,Use class in langchain-elasticsearch packageT) alternativependingcxeZdZdZdddd Zed d d dd ddZe dd dZd!dZd!dZ d"dZ d S)#ElasticsearchEmbeddingsa Elasticsearch embedding models. This class provides an interface to generate embeddings using a model deployed in an Elasticsearch cluster. It requires an Elasticsearch connection object and the model_id of the model deployed in the cluster. In Elasticsearch you need to have an embedding model loaded and deployed. - https://www.elastic.co/guide/en/elasticsearch/reference/current/infer-trained-model.html - https://www.elastic.co/guide/en/machine-learning/current/ml-nlp-deploy-models.html text_field input_fieldclientr model_idstrrc0||_||_||_dS)a Initialize the ElasticsearchEmbeddings instance. Args: client (MlClient): An Elasticsearch ML client object. model_id (str): The model_id of the model deployed in the Elasticsearch cluster. input_field (str): The name of the key for the input text field in the document. Defaults to 'text_field'. N)rrr)selfrrrs h/var/www/html/ai-engine/env/lib/python3.11/site-packages/langchain_community/embeddings/elasticsearch.py__init__z ElasticsearchEmbeddings.__init__s "   &N) es_cloud_ides_user es_passwordrr Optional[str]rrreturnc ddlm}ddlm}n#t$rt dwxYw|pt dd}|pt dd}|pt d d }||||f }||} || || S) aInstantiate embeddings from Elasticsearch credentials. Args: model_id (str): The model_id of the model deployed in the Elasticsearch cluster. input_field (str): The name of the key for the input text field in the document. Defaults to 'text_field'. es_cloud_id: (str, optional): The Elasticsearch cloud ID to connect to. es_user: (str, optional): Elasticsearch username. es_password: (str, optional): Elasticsearch password. Example: .. code-block:: python from langchain_community.embeddings import ElasticsearchEmbeddings # Define the model ID and input field name (if different from default) model_id = "your_model_id" # Optional, only if different from 'text_field' input_field = "your_input_field" # Credentials can be passed in two ways. Either set the env vars # ES_CLOUD_ID, ES_USER, ES_PASSWORD and they will be automatically # pulled in, or pass them in directly as kwargs. embeddings = ElasticsearchEmbeddings.from_credentials( model_id, input_field=input_field, # es_cloud_id="foo", # es_user="bar", # es_password="baz", ) documents = [ "This is an example document.", "Another example document to generate embeddings for.", ] embeddings_generator.embed_documents(documents) rr r zPelasticsearch package not found, please install with 'pip install elasticsearch'r ES_CLOUD_IDrES_USERr ES_PASSWORD)cloud_id basic_authr) elasticsearchr elasticsearch.clientr ImportErrorr) clsrrrrrr r es_connectionrs rfrom_credentialsz(ElasticsearchEmbeddings.from_credentials3s`  3 3 3 3 3 3 5 5 5 5 5 5 5   !   "O\-%O%O ?\)Y??!O\-%O%O &  g{-C   -((s68====s )r,r c@ddlm}||}||||S)a Instantiate embeddings from an existing Elasticsearch connection. This method provides a way to create an instance of the ElasticsearchEmbeddings class using an existing Elasticsearch connection. The connection object is used to create an MlClient, which is then used to initialize the ElasticsearchEmbeddings instance. Args: model_id (str): The model_id of the model deployed in the Elasticsearch cluster. es_connection (elasticsearch.Elasticsearch): An existing Elasticsearch connection object. input_field (str, optional): The name of the key for the input text field in the document. Defaults to 'text_field'. Returns: ElasticsearchEmbeddings: An instance of the ElasticsearchEmbeddings class. Example: .. code-block:: python from elasticsearch import Elasticsearch from langchain_community.embeddings import ElasticsearchEmbeddings # Define the model ID and input field name (if different from default) model_id = "your_model_id" # Optional, only if different from 'text_field' input_field = "your_input_field" # Create Elasticsearch connection es_connection = Elasticsearch( hosts=["localhost:9200"], http_auth=("user", "password") ) # Instantiate ElasticsearchEmbeddings using the existing connection embeddings = ElasticsearchEmbeddings.from_es_connection( model_id, es_connection, input_field=input_field, ) documents = [ "This is an example document.", "Another example document to generate embeddings for.", ] embeddings_generator.embed_documents(documents) rr r)r)r )r+rr,rr rs rfrom_es_connectionz*ElasticsearchEmbeddings.from_es_connectionwsAp 211111-((s68====rtexts List[str]List[List[float]]cjjfd|D}d|dD}|S)a5 Generate embeddings for the given texts using the Elasticsearch model. Args: texts (List[str]): A list of text strings to generate embeddings for. Returns: List[List[float]]: A list of embeddings, one for each text in the input list. c"g|] }j|i Sr).0textrs r z;ElasticsearchEmbeddings._embedding_func..s!)U)U)Ut4+;T*B)U)U)Ur)rdocscg|] }|d S)predicted_valuer5)r6docs rr8z;ElasticsearchEmbeddings._embedding_func..sVVVc+,VVVrinference_results)rinfer_trained_modelr)rr0response embeddingss` r_embedding_funcz'ElasticsearchEmbeddings._embedding_funcs_;22])U)U)U)Uu)U)U)U3  WVAT8UVVV rc,||S)a8 Generate embeddings for a list of documents. Args: texts (List[str]): A list of document text strings to generate embeddings for. Returns: List[List[float]]: A list of embeddings, one for each document in the input list. rA)rr0s rembed_documentsz'ElasticsearchEmbeddings.embed_documentss##E***rr7 List[float]c:||gdS)z Generate an embedding for a single query text. Args: text (str): The query text to generate an embedding for. Returns: List[float]: The embedding for the input query text. rrC)rr7s r embed_queryz#ElasticsearchEmbeddings.embed_querys##TF++A..r)rr rrrr) rrrr rr rr rrr!r)r)rrr,r rrr!r)r0r1r!r2)r7rr!rE) __name__ __module__ __qualname____doc__r classmethodr-r/rArDrGr5rrrrs   ( ''''''* &*!%%)'A>A>A>A>A>[A>F ( >>>>>>>>[>>@$ + + + + / / / / / /rrN) __future__rtypingrrrlangchain_core._apirlangchain_core.utilsrr(r r)r langchain_core.embeddingsr rr5rrrRs""""""0000000000******------.++++++------000000  HRVP/P/P/P/P/jP/P/P/P/P/r