tjddlmZmZmZmZddlmZmZddlm Z edZ edZ Gdde e e fZ dS) ) AsyncIteratorCallableIteratorSequence)AnyTypeVar) BaseStoreKVc eZdZdZdeeefdeegefdee 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 eddfdZdddedzdeeeezfdZdddedzdeeeezfdZdS)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>||_||_||_||_dS)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/html/CA-Chatbot/venv/lib/python3.11/site-packages/langchain_classic/storage/encoder_backed.py__init__zEncoderBackedStore.__init__4s) & 0"4keyscpfd|D}j|}fd|DS)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`. c:g|]}|Sr.0keyrs r z+EncoderBackedStore.mget..R'"I"I"IS4#3#3C#8#8"I"I"IrcBg|]}||n|SNrrvaluers rr z+EncoderBackedStore.mget..TA   /4.?D # #E * * *U   r)rmgetrr encoded_keysvaluess` rr(zEncoderBackedStore.mgetHs]#J"I"I"ID"I"I"I ..        rcKfd|D}j|d{V}fd|DS)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`. c:g|]}|Srrrs rr z,EncoderBackedStore.amget..cr!rNcBg|]}||n|Sr#r$r%s rr z,EncoderBackedStore.amget..er'r)ramgetr)s` rr/zEncoderBackedStore.amgetYsu#J"I"I"ID"I"I"I z'' 55555555        rkey_value_pairscXfd|D}j|dS)zvSet the values for the given keys. Args: key_value_pairs: A sequence of key-value pairs. cjg|]/\}}||f0Srrrrrr&rs rr z+EncoderBackedStore.mset..pN   U  c " "D$9$9%$@$@ A   rN)rmsetrr0 encoded_pairss` rr6zEncoderBackedStore.msetjsG     -     &&&&&rchKfd|D}j|d{VdS)z|Async set the values for the given keys. Args: key_value_pairs: A sequence of key-value pairs. cjg|]/\}}||f0Srr3r4s rr z,EncoderBackedStore.amset..|r5rN)ramsetr7s` rr;zEncoderBackedStore.amsetvs_     -   j}-----------rcXfd|D}j|dS)zzDelete the given keys and their associated values. Args: keys: A sequence of keys to delete. c:g|]}|Srrrs rr z.EncoderBackedStore.mdelete..'>>>#((-->>>rN)rmdeleterrr*s` rr?zEncoderBackedStore.mdeletes: ?>>>>>>  <(((((rchKfd|D}j|d{VdS)zAsync delete the given keys and their associated values. Args: keys: A sequence of keys to delete. c:g|]}|Srrrs rr z/EncoderBackedStore.amdelete..r>rN)ramdeleter@s` rrCzEncoderBackedStore.amdeletesP ?>>>>>> j!!,///////////rprefixrEc#LK|j|Ed{VdS)zGet an iterator over keys that match the given prefix. Args: prefix: The prefix to match. Yields: Keys that match the given prefix. rDN)r yield_keys)rrEs rrGzEncoderBackedStore.yield_keyss9:(((77777777777rc\K|j|23d{V}|WV 6dS)zAsync get an iterator over keys that match the given prefix. Args: prefix: The prefix to match. Yields: Keys that match the given prefix. rDN)r ayield_keys)rrErs rrIzEncoderBackedStore.ayield_keyss[//v/>>       #IIIII?>>s+)__name__ __module__ __qualname____doc__r strrrr r bytesrrlistr(r/tupler6r;r?rCrrGrrIrrrr r s%$$L5c"5qc3h'5#A3:. 5 %cUAX. 5  5555( ! a$h    "   QX    " 'HU1a4[$9 'd ' ' ' ' .8E!Q$K+@ .T . . . .)HQK)D))))08A;040000"888d 8 !x} $ 8888("d  q M#. . rr N) collections.abcrrrrtypingrrlangchain_core.storesr r r r rrrrUsGGGGGGGGGGGG ,+++++ GCLL GCLLhhhhh1a4hhhhhr