dhW  SSKJr SSKrSSKrSSKJrJrJrJrJ r J r SSK J r SSK r\R"\5r\(aSSKJr \R*4SSjjr\R*4SSjjr"SS 5rSS jrSS jrSS jrSS jrSSjrg)) annotationsN) TYPE_CHECKINGAnyListOptionalPatterncast)urlparse)Redisch[R"U5RU5R5$N)nparrayastypetobytes)rdtypes [/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/utilities/redis.py_array_to_bufferrs$ 88E? ! !% ( 0 0 22cp[[[[R"XS9R 55$)N)r)r rfloatr frombuffertolist)bufferrs r_buffer_to_arrayrs% U R]]6?FFH IIrc@\rSrSr%SrSrS\S'S S SjjrS SjrS r g) TokenEscaperz, Escape punctuation within an input string. z&[,.<>{}\[\]\\\"\':;!@#$%^&*()\-+=~\/ ]strDEFAULT_ESCAPED_CHARSNcjU(aXlg[R"UR5Ulgr )escaped_chars_rerecompiler )selfescape_chars_res r__init__TokenEscaper.__init__!s" $3 !$&JJt/I/I$JD !rc[U[5(d[S[U535eSSjnURR X!5$)Nz:Value must be a string object for token escaping.Got type c.URS5nSU3$)Nr\)group)matchvalues r escape_symbol*TokenEscaper.escape..escape_symbol.sKKNEw< r)r-zre.Matchreturnr) isinstancer TypeErrortyper"sub)r%r.r/s rescapeTokenEscaper.escape'sM%%% K=*   $$((>>r)r"r )r&zOptional[Pattern])r.rr1r) __name__ __module__ __qualname____firstlineno____doc__r __annotations__r'r6__static_attributes__rrrrs  "K3JK ?rrc(UR5nUVs0sHo3SRS5U_M nnUH3nUSU;dM[X#SS5[US5:dM3 g Sn[R U5 [ U5es snf)z1Check if the correct Redis modules are installed.snamezutf-8namesververNzRedis cannot be used as a vector database without RediSearch >=2.4Please head to https://redis.io/docs/stack/search/quick_start/to know more about installing the RediSearch module within Redis Stack.) module_listdecodeintloggererror ValueError)clientrequired_modulesinstalled_modulesmodule error_messages rcheck_redis_module_existrN5s**,>O>OFww'/>O# &>. .3 Vn -f 54  4   # R  LL ] ##sBc pSSKnURS5(a[U40UD6nU$URS5(aSUS'SU;aS US'[U40UD6nU$UR"U40UD6n[ U5(aUR 5 [U40UD6nU$![a [S5ef=f) aZGet a redis client from the connection url given. This helper accepts urls for Redis server (TCP with/without TLS or UnixSocket) as well as Redis Sentinel connections. Redis Cluster is not supported. Before creating a connection the existence of the database driver is checked an and ValueError raised otherwise To use, you should have the ``redis`` python package installed. Example: .. code-block:: python from langchain_community.utilities.redis import get_client redis_client = get_client( redis_url="redis://username:password@localhost:6379" index_name="my-index", embedding_function=embeddings.embed_query, ) To use a redis replication setup with multiple redis server and redis sentinels set "redis_url" to "redis+sentinel://" scheme. With this url format a path is needed holding the name of the redis service within the sentinels to get the correct redis server connection. The default service name is "mymaster". The optional second part of the path is the redis db number to connect to. An optional username or password is used for both connections to the rediserver and the sentinel, different passwords for server and sentinel are not supported. And as another constraint only one sentinel instance can be given: Example: .. code-block:: python from langchain_community.utilities.redis import get_client redis_client = get_client( redis_url="redis+sentinel://username:password@sentinelhost:26379/mymaster/0" index_name="my-index", embedding_function=embeddings.embed_query, ) rNzYCould not import redis python package. Please install it with `pip install redis>=4.1.0`.zredis+sentinelzrediss+sentinelTssl ssl_cert_reqsnone)redis ImportError startswith_redis_sentinel_clientfrom_url_check_for_clusterclose_redis_cluster_client) redis_urlkwargsrS redis_clients r get_clientr^JsX ,---iB6B     / 0 0u & (&,F? #-iB6B   ~~i:6: l + +    0EfEL )   A   s BB5c SSKn[U5nUR=(d SUR=(d S4/nUR(aAURR S5nUS=(d Sn[ U5S:aUSUS 'OSn0nUR(aURUS 'URUS 'UR(aURUS 'URUS 'UH'nURS 5(dUS :XdM!XXx'M) URR"U4SU0UD6n U RS5 U R%U5$!URRaQn SU RS;a7[ R#S5 URR"U40UD6n Sn A NuU eSn A ff=f)ahelper method to parse an (un-official) redis+sentinel url and create a Sentinel connection to fetch the final redis client connection to a replica-master for read-write operations. If username and/or password for authentication is given the same credentials are used for the Redis Sentinel as well as Redis Server. With this implementation using a redis url only it is not possible to use different data for authentication on both systems. rN localhosti g/mymasterdbpasswordusernamerP client_namesentinel_kwargspingzno password is setzRedis sentinel connection configured with password but Sentinel answered NO PASSWORD NEEDED - Please check Sentinel configuration)rSr hostnameportpathsplitlenrfrgrUsentinelSentinelexecute_command exceptionsAuthenticationErrorargsrFwarning master_for) r[r\rS parsed_url sentinel_list path_parts service_name sentinel_argsargsentinel_clientaes rrVrVs)$J ))8[*//:RUSTM__**3/ !!}2 z?Q %a=F4L! M$.$7$7 j!'00z$.$7$7 j!'00z >>% C=$8!'M  nn--'48>O ''/  % %l 33    / / 2771: - NNC $nn55mNvNOHs<EG 8AGGG c~SSKnURS5nUSS:H$!URRa gf=f)Nrclustercluster_enabledrbF)rSinfors RedisError)r]rS cluster_infos rrXrXsI#((3 -.!33    & &s <<c 4SSKJn UR"U40UD6$)Nr) RedisCluster) redis.clusterrrW)r[r\rs rrZrZs*   5f 55r)r List[float]rrr1bytes)rrrrr1r)rI RedisTyperJz List[dict]r1None)r[rr\rr1r)r]rr1bool) __future__rloggingr#typingrrrrrr urllib.parser numpyr getLoggerr8rF redis.clientr rfloat32rrrrNr^rVrXrZr?rrrss" DD!   8 $/79jj324J??:$*BJ:4z6r