Ah:vSSKrSSKrSSKrSSKJrJr SSKJr SSKJ r J r SSK J r SSK Jr "SS\ 5rg) N)IteratorSequence)Path)OptionalUnion) ByteStore)InvalidKeyExceptionc \rSrSrSrSSSS.S\\\4S\\ S\\ S \ S S4 S jjr S \S \4S jr S\S S4Sjr S\\S \\\4SjrS\\\\4S S4SjrS\\S S4SjrSS\\S \\4SjjrSrg)LocalFileStore aBaseStore interface that works on the local file system. Examples: Create a LocalFileStore instance and perform operations on it: .. code-block:: python from langchain.storage import LocalFileStore # Instantiate the LocalFileStore with the root path file_store = LocalFileStore("/path/to/root") # Set values for keys file_store.mset([("key1", b"value1"), ("key2", b"value2")]) # Get values for keys values = file_store.mget(["key1", "key2"]) # Returns [b"value1", b"value2"] # Delete keys file_store.mdelete(["key1"]) # Iterate over keys for key in file_store.yield_keys(): print(key) # noqa: T201 NF) chmod_file chmod_dir update_atime root_pathr rrreturncd[U5R5UlX lX0lX@lg)aImplement the BaseStore interface for the local file system. Args: root_path (Union[str, Path]): The root path of the file store. All keys are interpreted as paths relative to this root. chmod_file: (optional, defaults to `None`) If specified, sets permissions for newly created files, overriding the current `umask` if needed. chmod_dir: (optional, defaults to `None`) If specified, sets permissions for newly created dirs, overriding the current `umask` if needed. update_atime: (optional, defaults to `False`) If `True`, updates the filesystem access time (but not the modified time) when a file is read. This allows MRU/LRU cache policies to be implemented for filesystems where access time updates are disabled. N)rabsoluterr rr)selfrr rrs U/var/www/html/shao/venv/lib/python3.13/site-packages/langchain/storage/file_system.py__init__LocalFileStore.__init__)s(,i113$"(keyc\[R"SU5(dSU3n[U5eURU- R 5nURR 5n[ R RXC/5nU[U5:waSUSUSUSU3n[U5eU$)zGet the full path for a given key relative to the root path. Args: key (str): The key relative to the root path. Returns: Path: The full path for the given key. z^[a-zA-Z0-9_.\-/]+$zInvalid characters in key: z Invalid key: z+. Key should be relative to the full path. z vs. z and full path of ) rematchr rresolveospath commonpathstr)rrmsg full_pathr common_paths r_get_full_pathLocalFileStore._get_full_pathDsxx.44/u5C%c* *^^c)224 NN**, gg(())?@ #i. (u$O+U;-/A)N &c* *rdir_pathcUR5(dTURUR5 URSS9 URbUR UR5 ggg)aMakes a store directory path (including parents) with specified permissions This is needed because `Path.mkdir()` is restricted by the current `umask`, whereas the explicit `os.chmod()` used here is not. Args: dir_path: (Path) The store directory to make Returns: None T)exist_okN)exists_mkdir_for_storeparentmkdirrchmod)rr's rr+LocalFileStore._mkdir_for_store\sU   ! !(// 2 NNDN )~~)t~~.*!rkeysc~/nUHnURU5nUR5(azUR5nURU5 UR(aF[ R "U[R"5UR5R45 MMURS5 M U$)zGet 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) r%r* read_bytesappendrrutimetimestatst_mtime)rr0valuesrr#values rmgetLocalFileStore.mgetns)+C++C0I!!!,,. e$$$HHYinn6F6O6O(PQ% d# rkey_value_pairscUHlup#URU5nURUR5 URU5 URcMQUR UR5 Mn g)zqSet the values for the given keys. Args: key_value_pairs: A sequence of key-value pairs. Returns: None N)r%r+r, write_bytesr r.)rr<rr9r#s rmsetLocalFileStore.msets\*JC++C0I  ! !)"2"2 3  ! !% (*0 *rcUH;nURU5nUR5(dM+UR5 M= g)zDelete the given keys and their associated values. Args: keys (Sequence[str]): A sequence of keys to delete. Returns: None N)r%r*unlink)rr0rr#s rmdeleteLocalFileStore.mdeletes9C++C0I!!  "rprefixc## U(aURU5O URnURS5HBnUR5(dMUR UR5n[ U5v MD g7f)zGet an iterator over keys that match the given prefix. Args: prefix (Optional[str]): The prefix to match. Returns: Iterator[str]: An iterator over keys that match the given prefix. *N)r%rrglobis_file relative_tor!)rrE prefix_pathfile relative_paths r yield_keysLocalFileStore.yield_keyss^6%)#'" )d#)SM ) C= )  ) )6#$0//$/$#4+@.1HU3:->$?1D1 #HSM #d # )# )(3- ) )rr )rrr5collections.abcrrpathlibrtypingrrlangchain_core.storesrlangchain.storage.exceptionsr r r[rrras+ ."+<c)Yc)r