tjy)dZddlmZddlmZmZddlmZmZddl m Z ddl m Z ddl mZmZmZmZGdd Zd S) z%Async Store client for LangGraph SDK.) annotations)MappingSequence)AnyLiteral) HttpClient)_provided_vals)ItemListNamespaceResponseQueryParamTypesSearchItemsResponsec|eZdZdZd0dZ d1d2dZddddd3dZ d4d5dZ d6d7d(Z d8d9d/Z dS): StoreClientaClient for interacting with the graph's shared storage. The Store provides a key-value storage system for persisting data across graph executions, allowing for stateful operations and data sharing across threads. ???+ example "Example" ```python client = get_client(url="http://localhost:2024") await client.store.put_item(["users", "user123"], "mem-123451342", {"name": "Alice", "score": 100}) ``` httprreturnNonec||_dS)N)r)selfrs X/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/langgraph_sdk/_async/store.py__init__zStoreClient.__init__ s  NkeystrvalueMapping[str, Any]index!Literal[False] | list[str] | Nonettl int | NoneheadersMapping[str, str] | NoneparamsQueryParamTypes | None namespace Sequence[str]cK|D]}d|vrtd|d|||||d} |jdt| ||d{VdS)aStore or update an item. Args: namespace: A list of strings representing the namespace path. key: The unique identifier for the item within the namespace. value: A dictionary containing the item's data. index: Controls search indexing - None (use defaults), False (disable), or list of field paths to index. ttl: Optional time-to-live in minutes for the item, or None for no expiration. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: `None` ???+ example "Example Usage" ```python client = get_client(url="http://localhost:2024") await client.store.put_item( ["documents", "user123"], key="item456", value={"title": "My Document", "content": "Hello World"} ) ``` .Invalid namespace label '1'. Namespace labels cannot contain periods ('.').)r$rrrr /store/itemsjsonr r"N) ValueErrorrputr ) rr$rrrrr r"labelpayloads rput_itemzStoreClient.put_item#sH  Ee|| hhhh #   imm !8!8'RX           r) refresh_ttlr r"r2 bool | Noner cK|D]}d|vrtd|dd||d}|||d<|ri|t|}|jd||d{VS) aRetrieve a single item. Args: key: The unique identifier for the item. namespace: Optional list of strings representing the namespace path. refresh_ttl: Whether to refresh the TTL on this read operation. If `None`, uses the store's default behavior. Returns: Item: The retrieved item. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. ???+ example "Example Usage" ```python client = get_client(url="http://localhost:2024") item = await client.store.get_item( ["documents", "user123"], key="item456", ) print(item) ``` ```shell ---------------------------------------------------------------- { 'namespace': ['documents', 'user123'], 'key': 'item456', 'value': {'title': 'My Document', 'content': 'Hello World'}, 'created_at': '2024-07-30T12:00:00Z', 'updated_at': '2024-07-30T12:00:00Z' } ``` r'r(r)r$rNr2r*)r"r )r-joindictrget)rr$rr2r r"r/ get_paramss rget_itemzStoreClient.get_itemWsZ  Ee|| hhhh4788I3F3Fs%S%S  "(3J} %  87J7$v,,7JY]]>*g]VVVVVVVVVrcXK|jd||d||d{VdS)atDelete an item. Args: key: The unique identifier for the item. namespace: Optional list of strings representing the namespace path. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: `None` ???+ example "Example Usage" ```python client = get_client(url="http://localhost:2024") await client.store.delete_item( ["documents", "user123"], key="item456", ) ``` r*r5r+N)rdelete)rr$rr r"s r delete_itemzStoreClient.delete_itemsc:i (55            r rfilterMapping[str, Any] | Nonelimitintoffsetquery str | Nonenamespace_prefixr c zK||||||d} |jdt| ||d{VS)a,Search for items within a namespace prefix. Args: namespace_prefix: List of strings representing the namespace prefix. filter: Optional dictionary of key-value pairs to filter results. limit: Maximum number of items to return (default is 10). offset: Number of items to skip before returning results (default is 0). query: Optional query for natural language search. refresh_ttl: Whether to refresh the TTL on items returned by this search. If `None`, uses the store's default behavior. headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: A list of items matching the search criteria. ???+ example "Example Usage" ```python client = get_client(url="http://localhost:2024") items = await client.store.search_items( ["documents"], filter={"author": "John Doe"}, limit=5, offset=0 ) print(items) ``` ```shell ---------------------------------------------------------------- { "items": [ { "namespace": ["documents", "user123"], "key": "item789", "value": { "title": "Another Document", "author": "John Doe" }, "created_at": "2024-07-30T12:00:00Z", "updated_at": "2024-07-30T12:00:00Z" }, # ... additional items ... ] } ``` )rFr?rArCrDr2z/store/items/searchr+Nrpostr ) rrFr?rArCrDr2r r"r0s r search_itemszStoreClient.search_itemssxz!1&   Y^^ !(( $         rdprefixlist[str] | Nonesuffix max_depthr cxK|||||d}|jdt|||d{VS)a3List namespaces with optional match conditions. Args: prefix: Optional list of strings representing the prefix to filter namespaces. suffix: Optional list of strings representing the suffix to filter namespaces. max_depth: Optional integer specifying the maximum depth of namespaces to return. limit: Maximum number of namespaces to return (default is 100). offset: Number of namespaces to skip before returning results (default is 0). headers: Optional custom headers to include with the request. params: Optional query parameters to include with the request. Returns: A list of namespaces matching the criteria. ???+ example "Example Usage" ```python client = get_client(url="http://localhost:2024") namespaces = await client.store.list_namespaces( prefix=["documents"], max_depth=3, limit=10, offset=0 ) print(namespaces) ---------------------------------------------------------------- [ ["documents", "user123", "reports"], ["documents", "user456", "invoices"], ... ] ``` )rLrNrOrArCz/store/namespacesr+NrH) rrLrNrOrArCr r"r0s rlist_namespaceszStoreClient.list_namespacessu\"   Y^^ (( $         r)rrrr)NNNN)rrrrrrrrr r!r"r#r$r%rr) rrr$r%r2r3r r!r"r#rr )NN) rrr r!r"r#r$r%rr)Nr>rNNNN)r?r@rArBrCrBrDrEr2r3r r!r"r#rFr%rr )NNNrKrNN)rLrMrNrMrOrrArBrCrBr r!r"r#rr ) __name__ __module__ __qualname____doc__rr1r:r=rJrQrrrrs  48,0)-2 2 2 2 2 t$(,0)-7W7W7W7W7W7W|-1)- " " " " " P,0 #',0)-J J J J J \$(#' $,0)-9 9 9 9 9 9 9 rrN)rU __future__rcollections.abcrrtypingrrlanggraph_sdk._async.httprlanggraph_sdk._shared.utilitiesr langgraph_sdk.schemar r r r rrVrrr]s++""""""--------000000::::::g g g g g g g g g g r