7|hBVddlmZmZmZmZmZmZmZddlm Z ddl m Z Gdde Z y))AnyIteratorListOptionalSequenceTuplecast) ByteStore) get_clientc eZdZdZdddddddedeedeedeedeed df d Z d ed efd Z d e ed e ee fdZde eee fd dfdZd e ed dfdZdddeed eefdZy) RedisStoreaBaseStore implementation using Redis as the underlying store. Examples: Create a RedisStore instance and perform operations on it: .. code-block:: python # Instantiate the RedisStore with a Redis connection from langchain_community.storage import RedisStore from langchain_community.utilities.redis import get_client client = get_client('redis://localhost:6379') redis_store = RedisStore(client=client) # Set values for keys redis_store.mset([("key1", b"value1"), ("key2", b"value2")]) # Get values for keys values = redis_store.mget(["key1", "key2"]) # [b"value1", b"value2"] # Delete keys redis_store.mdelete(["key1"]) # Iterate over keys for key in redis_store.yield_keys(): print(key) # noqa: T201 N)client redis_url client_kwargsttl namespacerrrrrreturnc ddlm}|r|s|r td|s |s td|r1t ||s"t dt |jd|}n|s tdt|fi|xsi}||_ t |ts|t d t |d||_ ||_ y#t$r}td|d}~wwxYw) aInitialize the RedisStore with a Redis connection. Must provide either a Redis client or a redis_url with optional client_kwargs. Args: client: A Redis connection instance redis_url: redis url client_kwargs: Keyword arguments to pass to the Redis client ttl: time to expire keys in seconds if provided, if None keys will never expire namespace: if provided, all keys will be prefixed with this namespace r)RediszLThe RedisStore requires the redis library to be installed. pip install redisNz`Either a Redis client or a redis_url with optional client_kwargs must be provided, but not both.z6Either a Redis client or a redis_url must be provided.zExpected Redis client, got z instead.z$Expected int or None, got type(ttl)=) redisr ImportError ValueError isinstance TypeErrortype__name__r rintrr) selfrrrrrre_clients `/var/www/html/test/engine/venv/lib/python3.12/site-packages/langchain_community/storage/redis.py__init__zRedisStore.__init__&s*  # yM2  iUV V fe,1$v,2G2G1H RG L!D}/BDG #s#Cc INO O"E $  sB88 C C  CkeycFd}|jr|j||S|S)zGet the key with the namespace prefix. Args: key (str): The original key. Returns: str: The key with the namespace prefix. /)r)rr# delimiters r!_get_prefixed_keyzRedisStore._get_prefixed_keyas- >>nn%i[6 6 keysc tttt|jj |Dcgc]}|j |c}Scc}w)z.Get the values associated with the given keys.)r rrbytesrmgetr')rr)r#s r!r,zRedisStore.mgetosF % ! KK  TJcd44S9J K  JsAkey_value_pairsc|jj}|D]2\}}|j|j|||j4|j y)zSet the given key-value pairs.)exN)rpipelinesetr'rexecute)rr-piper#values r!msetzRedisStore.msetvsS{{##%) FJC HHT++C0%DHHH E F r(c||Dcgc]}|j|}}|jj|ycc}w)zDelete the given keys.N)r'rdelete)rr)r#_keyss r!mdeletezRedisStore.mdelete~s98<='',== E">s9)prefixr:c#HK|r|j|}n|jd}ttt|jj |}|D]C}|j d}|jr |t|jdzd}|@|Eyw)zYield keys in the store.*)matchzutf-8N) r'r rr+r scan_iterdecoderlen)rr:patternr?r# decoded_key relative_keys r! yield_keyszRedisStore.yield_keyss ,,V4G,,S1G%$++*?*?g*?*NO  "C**W-K~~*3t~~+>+B+DE ""!!  "sB B")r __module__ __qualname____doc__rrstrdictrr"r'rrr+r,rr5r9rrEr(r!r r s@#'(,!#'9#9#C= 9#  ~ 9# c] 9#C=9# 9#v S S  # 4+@ HU3:->$?D#HSM#d# 59 "HSM "Xc] "r(r N) typingrrrrrrr langchain_core.storesr #langchain_community.utilities.redisr r rKr(r!rOs"GGG+:H"H"r(