dhcSrSSKJr SSKrSSKrSSKrSSKrSSKJrJ r J r J r J r J r JrJr SSKJr SSKJr SSKJr SSKJr \R0"\5r"S S \5rS r"S S 5rg)z,Module providing Infinispan as a VectorStore) annotationsN)AnyIterableListOptionalTupleTypeUnioncast)Response)Document) Embeddings) VectorStorec\rSrSrSrSSSjjrSSjrSSjrSSjrSSjr S S jr S!S"S jjr S S jr S S jr S#S jrS SjrS SjrSS$SjjrS%S&SjjrS%S'SjjrS%S(SjjrS%S)SjjrS*SjrS+SjrS,Sjr\S-S.Sjj5rSrg)/ InfinispanVSat`Infinispan` VectorStore interface. This class exposes the method to present Infinispan as a VectorStore. It relies on the Infinispan class (below) which takes care of the REST interface with the server. Example: ... code-block:: python from langchain_community.vectorstores import InfinispanVS from mymodels import RGBEmbeddings ... vectorDb = InfinispanVS.from_documents(docs, embedding=RGBEmbeddings(), output_fields=["texture", "color"], lambda_key=lambda text,meta: str(meta["_key"]), lambda_content=lambda item: item["color"]) or an empty InfinispanVS instance can be created if preliminary setup is required before populating the store ... code-block:: python from langchain_community.vectorstores import InfinispanVS from mymodels import RGBEmbeddings ... ispnVS = InfinispanVS() # configure Infinispan here # i.e. create cache and schema # then populate the store vectorDb = InfinispanVS.from_documents(docs, embedding=RGBEmbeddings(), output_fields: ["texture", "color"], lambda_key: lambda text,meta: str(meta["_key"]), lambda_content: lambda item: item["color"]) Nc ^[S0UD6TlUTl[TRR SS55Tl[TRR SS55TlUTlTRR SS5TlTRS:Xa"TRR SS5TlO[R"S[5 TRR S S5Tl TRS:Xa"TRR S S5Tl O[R"S [5 TRR S U4S j5Tl TRR SU4Sj5TlTRR S5TlUTlg)a Parameters ---------- cache_name: str Embeddings cache name. Default "vector" entity_name: str Protobuf entity name for the embeddings. Default "vector" text_field: str Protobuf field name for text. Default "text" vector_field: str Protobuf field name for vector. Default "vector" lambda_content: lambda Lambda returning the content part of an item. Default returns text_field lambda_metadata: lambda Lambda returning the metadata part of an item. Default returns items fields excepts text_field, vector_field, _type output_fields: List[str] List of fields to be returned from item, if None return all fields. Default None kwargs: Any Rest of arguments passed to Infinispan. See docs cache_namevector entity_name textfield text_fieldtextz9`textfield` is deprecated. Please use `text_field` param. vectorfield vector_fieldz=`vectorfield` is deprecated. Please use `vector_field` param.lambda_contentc&>TRU5$N)_default_contentitemselfs e/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/vectorstores/infinispanvs.py'InfinispanVS.__init__..is4+@+@+Flambda_metadatac&>TRU5$r)_default_metadatar!s r$r%r&lsD,B,B4,Hr' output_fieldsN) Infinispanispn_configurationstrget _cache_name _entity_name _embedding _textfieldwarningswarnDeprecationWarning _vectorfield _to_content _to_metadata_output_fields_ids)r# embeddingidskwargss` r$__init__InfinispanVS.__init__8sq6(( $t2266|XNO 3 3 7 7 x PQ#--11+rB ??b "1155lFKDO MMK" !//33M2F    " $ 3 3 7 7 QD  MMO"  ..22 F !//33 H #1155oF r'c[U5nURURS5 URURS5 URSS5 U$N_type)dictpopr9r5)r#r"metas r$r*InfinispanVS._default_metadataqsDDz ""D) $' $ r'c8URUR5$r)r1r5)r#r"s r$r InfinispanVS._default_contentxsxx((r'cSnUURUUR4-nSnUR5GH upg[U[5(aUSU-S-[ U5-S-- nO[U[ 5(aUSU-S-[ U5-S-- nO[U[ 5(aUSU-S-[ U5-S-- nOn[U[5(aUSU-S-[ U5-S-- nO>[U[5(aUS U-S-[ U5-S-- nO[S U-5eUS - nGM US - nU$) NzV /** * @Indexed */ message %s { /** * @Vector(dimension=%d) */ repeated float %s = 1; zoptional string z = z; zoptional int64 zoptional double zoptional bytes zoptional bool zEUnable to build proto schema for metadata. Unhandled type for field: z} ) r3r9items isinstancer0intfloatbytesbool Exception)r#templ dimensionmetadata_proto_tplmetadata_protoidxfvs r$schema_builderInfinispanVS.schema_builder{sp ,       /   KKMDA!S!!"4q"85"@3s8"Ke"SSAs##"3a"7%"?#c("JU"RRAu%%"4q"85"@3s8"Ke"SSAu%%"3a"7%"?#c("JU"RRAt$$"2Q"6">S"IE"QQ1345 1HC!"" %r'cTURRURS-U5$)zDeploy the schema for the vector db Args: proto(str): protobuf schema Returns: An http Response containing the result of the operation .proto)r. schema_postr3)r#protos r$ schema_createInfinispanVS.schema_creates&yy$$T%6%6%A5IIr'cRURRURS-5$)ziDelete the schema for the vector db Returns: An http Response containing the result of the operation r`)r. schema_deleter3r#s r$rfInfinispanVS.schema_deletes$ yy&&t'8'88'CDDr'c~US:XaSUR-S-nURRURU5$)zCreate the cache for the vector db Args: config(str): configuration of the cache. Returns: An http Response containing the result of the operation raZ { "distributed-cache": { "owners": "2", "mode": "SYNC", "statistics": true, "encoding": { "media-type": "application/x-protostream" }, "indexing": { "enabled": true, "storage": "filesystem", "startup-mode": "AUTO", "indexing-mode": "AUTO", "indexed-entities": [ "z" ] } } } )r3r. cache_postr2)r#configs r$ cache_createInfinispanVS.cache_createsN R< ##!$"# 2yy##D$4$4f==r'cLURRUR5$)zhDelete the cache for the vector db Returns: An http Response containing the result of the operation )r. cache_deleter2rgs r$roInfinispanVS.cache_delete yy%%d&6&677r'cLURRUR5$)zgClear the cache for the vector db Returns: An http Response containing the result of the operation )r. cache_clearr2rgs r$rsInfinispanVS.cache_clear yy$$T%5%566r'cLURRUR5$)z7Checks if the cache exists Returns: true if exists )r. cache_existsr2rgs r$rwInfinispanVS.cache_existsrqr'cLURRUR5$)zgClear the index for the vector db Returns: An http Response containing the result of the operation )r. index_clearr2rgs r$cache_index_clearInfinispanVS.cache_index_clearrur'cLURRUR5$)zcRebuild the for the vector db Returns: An http Response containing the result of the operation )r. index_reindexr2rgs r$cache_index_reindex InfinispanVS.cache_index_reindexs yy&&t'7'788r'c /n[U5nU(aUR5 URRU5nU(aUR U5 U(dUVs/sHn0PM nnUR =(d. UVs/sH!n[ [R"55PM# snn [[X'U 55n U H~upn SURURU 0nURU 5 [R"U5nURR!XUR"5 UR U 5 M U$s snfs snfrD)listrGr4embed_documentsappendr=r0uuiduuid4zipr3r9updatejsondumpsr.putr2)r#texts metadatas last_vectorr@resulttexts_lembeds_r? data_inputmetadataembedkeydatadata_strs r$ add_textsInfinispanVS.add_textssu+  KKM009  MM+ &%*+UUI+ii=u=u!C -u=#i56 $. HST..0A0A5ID KK !zz$'H IIMM#)9)9 : MM#  %/  ,=s # E 'Ec XURXS9nUVVs/sHupVUPM snn$s snnf)z"Return docs most similar to query.)queryk)similarity_search_with_score)r#rrr@ documentsdocrs r$similarity_searchInfinispanVS.similarity_searchs155E5G "+,)),,,s &c ZURRU5nURXBS9nU$)zPerform a search on a query string and return results with score. Args: query (str): The text being searched. k (int, optional): The amount of results to return. Defaults to 4. Returns: List[Tuple[Document, float]] )r>r)r4 embed_query&similarity_search_with_score_by_vector)r#rrr@rrs r$r)InfinispanVS.similarity_search_with_scores1++E2??%?U r'c \URX5nUVVs/sHupVUPM snn$s snnfr)r)r#r>rr@resrrs r$similarity_search_by_vector(InfinispanVS.similarity_search_by_vector's.99)G"%&##&&&s (c`URcISUR-S-UR-S-[R"U5-S-[ U5-nOSnURSSHnUS-U-S -nM US-URS-nUS -UR-S-UR-S-[R"U5-S-[ U5-nUR RX0R5n[R"UR5nURU5$) zReturn docs most similar to embedding vector. Args: embedding: Embedding to look up documents similar to. k: Number of Documents to return. Defaults to 4. Returns: List of pair (Documents, score) most similar to the query vector. Nzselect v, score(v) from z v where v.z <-> ~zselect zv.,z, score(v) from ) r<r3r9rrr0r. req_queryr2loadsr_query_result_to_docs)r#r>r query_str query_projfield query_resrs r$r3InfinispanVS.similarity_search_with_score_by_vector-sk    &*##$ ##$  **Y' (  a& #J,,Sb1'$.6< 2#d*T-@-@-DDJ$%##$  ## $   **Y' (a& II'' 3C3CD INN+))&11r'c</nUSHnUS=(d 0nURcUSnO*URVs0sHofURU5_M nn[URU5UR U5S9nUR XtS45 M U$s snf)Nhitshit*) page_contentrzscore())r<r1r r:r;r)r#rrrowrentityrrs r$r"InfinispanVS._query_result_to_docsXs &>Ce*"C""*S7;7J7JK7Jswws|+7JK!--f5**62C   cy>2 3" LsBcURX5nURU5nURURRR :XdS5e[ R"UR5SbeUR5(dWUR5nURURRR :XdS5eUR5 gg)Nz)Unable to create schema. Already exists? errorz(Unable to create cache. Already exists? ) r]rc status_coder.CodesOKrrrrwrlr{)r#rrWschemaoutputs r$ configureInfinispanVS.configureis$$X9##F+!!TYY__%7%77 7 7 (zz&++&w/777  ""&&(F%%););; : ; ,  " " $#r'cDUR5 UR5 gr)rfrorgs r$ config_clearInfinispanVS.config_clearzs  r'c U"SX$S.UD6nU(a[U=(d /5S:amU(aUR5 URU[U5S- 5n [[[ U5nUR US[U 55 O7U(aUR5 URU[U5S- 5n U(aURXU S9 U$)a`Return VectorStore initialized from texts and embeddings. In addition to parameters described by the super method, this implementation provides other configuration params if different configuration from default is needed. Parameters ---------- ids : List[str] Additional list of keys associated to the embedding. If not provided UUIDs will be generated clear_old : bool Whether old data must be deleted. Default True auto_config: bool Whether to do a complete server setup (caches, protobuf definition...). Default True kwargs: Any Rest of arguments passed to InfinispanVS. See docs)r>r?rrN)rr,) lenrrr rrFrrsr) clsrr>rr? clear_old auto_configr@ infinispanvsvecs r$ from_textsInfinispanVS.from_texts~s:BYB6B 3yB/!3))+''c%j1n(=>CT$Z3I  " "9Q<S :((*''c%j1n(=>C   " "5C " @r') r2r/r4r3r=r<r5r:r;r9r.)NN)r>zOptional[Embeddings]r?Optional[List[str]]r@r)r"rFreturnrF)r"dict[str, Any]rr)rVrFrWrQrr0)rbr0rr )rr )r)rkr0rr )rrT) rz Iterable[str]rOptional[List[dict]]rzOptional[List[float]]r@rr List[str]))rr0rrQr@rrList[Document])rr0rrQr@rrList[Tuple[Document, float]])r> List[float]rrQr@rrr)r>rrrQrr)rrrr)rrFrWrQrNone)rr)NNTT)rzType[InfinispanVS]rrr>rrrr?rrOptional[bool]rrr@rrr)__name__ __module__ __qualname____firstlineno____doc__rAr*r r]rcrfrlrorsrwr{rrrrrrrrr classmethodr__static_attributes__r,r'r$rrs"L+/#'7'7!7 7r)#JJE!>F87879+/-1 (+     6$%-- -03- -$% 03 %"01'$'),'#%#5  ::$..||v%AFAQAQ!ZZ$..BRB DNN3 kk++o %DI kk++o%DIC F  s EEclUR(aURXU5$URXU5$)zRequest a query Args: query(str): query requested cache_name(str): name of the target cache local(boolean): whether the query is local to clustered Returns: An http Response containing the result set or errors )r _query_post _query_get)r#rrlocals r$rInfinispan.req_querys1  # ###Eu= =u%88r'cURUR-S-U-S-[U5-nSU0n[R"U5nUR R UUSS0[S9nU$)N/z?action=search&local=r Content-Typeapplication/jsoncontentheaderstimeout)rrr0rrrpost REST_TIMEOUT)r#rrrapi_urlr data_jsonresponses r$rInfinispan._query_posts   oo   &  & %j   #JJt$ 99>> #%78 "  r'cURUR-S-U-S-U-S-[U5-nURR U[ S9nU$)Nr z?action=search&query=z&local=r)rrr0rr1r)r#rrrrrs r$rInfinispan._query_get'sy   oo   &  &      %j  99==,=?r'cURUR-S-U-S-U-nURRUUSS0[S9nU$)zPost an entry Args: key(str): key of the entry data(str): content of the entry in json format cache_name(str): target cache Returns: An http Response containing the result of the operation r r r rrrrrrr#rrrrrs r$rInfinispan.post7s]$$t6> #%78 "  r'cURUR-S-U-S-U-nURRUUSS0[S9nU$)zPut an entry Args: key(str): key of the entry data(str): content of the entry in json format cache_name(str): target cache Returns: An http Response containing the result of the operation r r r r)rrrrrrs r$rInfinispan.putIs]$$t6>',>Or'cURUR-S-U-nURRUUSS0[S9nU$)zCreate a cache Args: name(str): name of the cache. config(str): configuration of the cache. Returns: An http Response containing the result of the operation r r r rr)r#r$rkrrs r$rjInfinispan.cache_postusR$$t6> #%78 "  r'cURUR-S-U-nURRU[S9nU$)z~Delete a schema Args: name(str): name of the schema. Returns: An http Response containing the result of the operation r r)rrrdeleterr#r$rrs r$rfInfinispan.schema_deletesB$$t'7'77#=D99##G\#Br'cURUR-S-U-nURRU[S9nU$)z|Delete a cache Args: name(str): name of the cache. Returns: An http Response containing the result of the operation r r)rrrr)rr*s r$roInfinispan.cache_deletes@$$t6>'<>@r'chURUR-S-U-S-nURU5$)zhCheck if a cache exists Args: cache_name(str): name of the cache. Returns: True if cache exists r r/)rrresource_existsr#rrs r$rwInfinispan.cache_existss=    03 6 Co U ##G,,r'cURRU[S9nURURR :H$)zmCheck if a resource exists Args: api_url(str): url of the resource. Returns: true if resource exists r)rheadrrrr)r#rrs r$r2Infinispan.resource_existss399>>'<>@##tzz}}44r'cURUR-S-U-S-nURRU[S9$)zClear an index on a cache Args: cache_name(str): name of the cache. Returns: An http Response containing the result of the operation r z/search/indexes?action=clearrrr3s r$rzInfinispan.index_clearsS   oo   -  - yy~~g|~<C*-6: ,>C*-6:  $$  "    -5= =r'r-)r __future__rrloggingrr6typingrrrrrr r r rr langchain_core.documentsr langchain_core.embeddingsrlangchain_core.vectorstoresr getLoggerrloggerrrr-r,r'r$rDs^2"  JJJ-03   8 $U;Up  o=o=r'