kQj}ddlZddlmZddlmZmZddlZddlm Z ddl m Z ddl m Z dd lmZdd lmZed Gd d e Zy)N)cached_property)ListUnion) ConfigDict)attempt_import_or_raise)TextEmbeddingFunction)register)TEXTz bedrock-textc@eZdZUdZdZeed<dZeed<dZe edfed<dZ e edfed<d Z eed <d Z eed <d Z eed<eefZdZdedeeefdZdedeeefdZde eeej0fdeeefdZdedeefdZedZy) BedRockTexta Parameters ---------- name : str, default "amazon.titan-embed-text-v1" The model ID of the bedrock model to use. Supported models for are: - amazon.titan-embed-text-v1 - cohere.embed-english-v3 - cohere.embed-multilingual-v3 region : str, default "us-east-1" Optional name of the AWS Region in which the service should be called. profile_name : str, default None Optional name of the AWS profile to use for calling the Bedrock service. If not specified, the default profile will be used. assumed_role : str, default None Optional ARN of an AWS IAM role to assume for calling the Bedrock service. If not specified, the current active credentials will be used. role_session_name : str, default "lancedb-embeddings" Optional name of the AWS IAM role session to use for calling the Bedrock service. If not specified, "lancedb-embeddings" name will be used. Examples -------- import lancedb import pandas as pd from lancedb.pydantic import LanceModel, Vector model = get_registry().get("bedrock-text").create() class TextModel(LanceModel): text: str = model.SourceField() vector: Vector(model.ndims()) = model.VectorField() df = pd.DataFrame({"text": ["hello world", "goodbye world"]}) db = lancedb.connect("tmp_path") tbl = db.create_table("test", schema=TextModel, mode="overwrite") tbl.add(df) rs = tbl.search("hello").limit(1).to_pandas() amazon.titan-embed-text-v1namez us-east-1regionN assumed_role profile_namezlancedb-embeddingsrole_session_namesearch_documentsource_input_type search_queryquery_input_type) ignored_typescr|jdk(ry|jdvrytd|jd)Nri)zamazon.titan-embed-text-v2:0zcohere.embed-english-v3zcohere.embed-multilingual-v3izModel z not supported)r ValueError)selfs _/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/lancedb/embeddings/bedrock.pyndimszBedRockText.ndimsGsB 994 4 YY  vdii[?@ @queryreturnc<|j||jS)N) input_type)compute_source_embeddingsr)rr argskwargss rcompute_query_embeddingsz$BedRockText.compute_query_embeddingsVs --e@U@U-VVrtextsc|j|}|jdxs |j|d<|j|fi|S)Nr#)sanitize_inputgetrgenerate_embeddings)rr(r%r&s rr$z%BedRockText.compute_source_embeddings[sJ##E*%zz,7Q4;Q;Q|'t''888rcfg}|D])}|j|g|i|}|j|+|S)a Get the embeddings for the given texts Parameters ---------- texts: list[str] or np.ndarray (of str) The texts to embed Returns ------- list[list[float]] The embeddings for the given texts )_generate_embeddingappend)rr(r%r&resultstextresponses rr,zBedRockText.generate_embeddingsdsG  %D/t//FtFvFH NN8 $ %rr1c |jjdd}i|}|dk(r|g|d<n|jdd||d<tj|} |j j ||jdd }tj|jd j}|dk(r|jd dS|jd S#t$r} d } td| d| d} ~ wwxYw)z Get the embeddings for the given texts Parameters ---------- texts: str The texts to embed Returns ------- list[float] The embeddings for the given texts .rcoherer(r#N inputTextzapplication/json)bodymodelIdaccept contentTyper7 embeddings embeddinga boto3 client failed to invoke the bedrock API. In case of AWS credentials error: - Please check your AWS credentials and ensure that you have access. You can set up aws credentials using `aws configure` command and verify by running `aws sts get-caller-identity` in your terminal. zError raised by boto3 client: z. ) rsplitpopjsondumpsclient invoke_modelloadsr+read Exceptionr) rr1r%r&provider input_bodyr7r2 response_bodyehelp_txts rr.zBedRockText._generate_embeddingzs99??3'*Z x #'&Jw  NN< .&*J{ #zz*% R{{// ). 0H!JJx||F';'@'@'BCM8#$((6q99%((55 RH=aShZPQ Q RsA3C!C!! D*C==DcFtd}td}d|ji}i|}|jr|j|d<|jj |jddd}|jr|j di|n|j }|j rb|jd }|jt|j |j }|d d |d <|d d|d<|d d|d<d} |jd| |d|} | S)zCreate a boto3 client for Amazon Bedrock service Returns ------- boto3.client The boto3 client for Amazon Bedrock service botocoreboto3 region_namerrstandard) max_attemptsmode)rNretriessts)RoleArnRoleSessionName Credentials AccessKeyIdaws_access_key_idSecretAccessKeyaws_secret_access_key SessionTokenaws_session_tokenzbedrock-runtime) service_nameconfig) rrrr^ConfigSessionrrA assume_rolestrr) rrLrMsession_kwargs client_kwargs retry_configsessionrSr2r]bedrock_clients rrAzBedRockText.clientsT+:6'0'5*>*   -1->->N> *-- !". 04/@/@MEMM +N +emmo    ..'CD--. $ 6 6'H2:-1H1WM- .5=m5L!6M1 22:-1H1XM- .( ' %l >K r)__name__ __module__ __qualname____doc__rrc__annotations__rrrrrrrrr model_configrrfloatr'r r$npndarrayr,r.rAr_rrrrs'R-D#,FC%)L%T ")%)L%T ")1s1.s.*c*_,>?L AWW d5k W 99 d5k 949bjj01 d5k ,1R1Re1Rf--rr)r? functoolsrtypingrrnumpyrppydanticrutilrbaser registryr utilsr rr_rrrzsF  %*' .H'HHr