3fixddlmZmZmZmZddlmZmZddlm Z edZ edZ Gdde e e fZ y) ) AsyncIteratorCallableIteratorSequence)AnyTypeVar) BaseStoreKVc feZdZdZdeeefdeegefdee ge fdeege fddf dZ d e ede e dzfd Zd e ede e dzfd Zd e eee fddfd Zd e eee fddfdZd e eddfdZd e eddfdZdddedzdeeeezfdZdddedzdeeeezfdZy)EncoderBackedStoreaWraps a store with key and value encoders/decoders. Examples that uses JSON for encoding/decoding: ```python import json def key_encoder(key: int) -> str: return json.dumps(key) def value_serializer(value: float) -> str: return json.dumps(value) def value_deserializer(serialized_value: str) -> float: return json.loads(serialized_value) # Create an instance of the abstract store abstract_store = MyCustomStore() # Create an instance of the encoder-backed store store = EncoderBackedStore( store=abstract_store, key_encoder=key_encoder, value_serializer=value_serializer, value_deserializer=value_deserializer, ) # Use the encoder-backed store methods store.mset([(1, 3.14), (2, 2.718)]) values = store.mget([1, 2]) # Retrieves [3.14, 2.718] store.mdelete([1, 2]) # Deletes the keys 1 and 2 ``` store key_encodervalue_serializervalue_deserializerreturnNc<||_||_||_||_y)aWInitialize an `EncodedStore`. Args: store: The underlying byte store to wrap. key_encoder: Function to encode keys from type `K` to strings. value_serializer: Function to serialize values from type `V` to bytes. value_deserializer: Function to deserialize bytes back to type V. N)rrrr)selfrrrrs f/var/www/auto_recruiter/arenv/lib/python3.12/site-packages/langchain_classic/storage/encoder_backed.py__init__zEncoderBackedStore.__init__4s# & 0"4keysc|Dcgc]}|j|}}|jj|}|Dcgc]}||j|n|c}Scc}wcc}w)a Get the values associated with the given keys. Args: keys: A sequence of keys. Returns: A sequence of optional values associated with the keys. If a key is not found, the corresponding value will be `None`. )rrmgetrrrkey encoded_keysvaluesvalues rrzEncoderBackedStore.mgetHssEI"IS4#3#3C#8"I "I.  /4.?D # #E *U J  #J s AA"cK|Dcgc]}|j|}}|jj|d{}|Dcgc]}||j|n|c}Scc}w7,cc}ww)aAsync get the values associated with the given keys. Args: keys: A sequence of keys. Returns: A sequence of optional values associated with the keys. If a key is not found, the corresponding value will be `None`. N)rramgetrrs rr!zEncoderBackedStore.amgetYsEI"IS4#3#3C#8"I "Izz'' 55  /4.?D # #E *U J  #J5 s,A3A' A3A,A3A.$ A3.A3key_value_pairsc|Dcgc]'\}}|j||j|f)}}}|jj|ycc}}w)zvSet the values for the given keys. Args: key_value_pairs: A sequence of key-value pairs. N)rrrmsetrr"rr encoded_pairss rr$zEncoderBackedStore.msetjsW. U  c "D$9$9%$@ A    &  s,AcK|Dcgc]'\}}|j||j|f)}}}|jj|d{ycc}}w7 w)z|Async set the values for the given keys. Args: key_value_pairs: A sequence of key-value pairs. N)rrramsetr%s rr(zEncoderBackedStore.amsetvsh. U  c "D$9$9%$@ A  jj}---   .sA#,A!A#A! A#c|Dcgc]}|j|}}|jj|ycc}w)zzDelete the given keys and their associated values. Args: keys: A sequence of keys to delete. N)rrmdeleterrrrs rr*zEncoderBackedStore.mdeletes9 :>>#((-> > <(?s;cK|Dcgc]}|j|}}|jj|d{ycc}w7 w)zAsync delete the given keys and their associated values. Args: keys: A sequence of keys to delete. N)rramdeleter+s rr-zEncoderBackedStore.amdeletesF :>>#((-> >jj!!,///?/sA A A A  A prefixr/c#XK|jj|Ed{y7w)zGet an iterator over keys that match the given prefix. Args: prefix: The prefix to match. Yields: Keys that match the given prefix. r.N)r yield_keys)rr/s rr1zEncoderBackedStore.yield_keyss#::(((777s *(*chK|jj|23d{}|7 6yw)zAsync get an iterator over keys that match the given prefix. Args: prefix: The prefix to match. Yields: Keys that match the given prefix. r.N)r ayield_keys)rr/rs rr3zEncoderBackedStore.ayield_keyss7//v/>  #I >s20.0202)__name__ __module__ __qualname____doc__r strrrr r bytesrrlistrr!tupler$r(r*r-rr1rr3rrr r ss$L5c"5qc3h'5#A3:. 5 %cUAX. 5  5( ! a$h "   QX " 'HU1a4[$9 'd ' .8E!Q$K+@ .T .)HQK)D)08A;040"8d 8 !x} $ 8("d  q M#. . rr N) collections.abcrrrrtypingrrlangchain_core.storesr r r r r<rrr@s=GG , CL CLh1a4hr