j(ddlZddlmZddlmZmZmZmZddlZddl m Z dZ dZ dde e dZ e dd d Gd d Zy)N)SimpleNamespace)AnyDictOptionalSequence) deprecatedzD SELECT DISTINCT ?elem WHERE { ?elem a owl:DatatypeProperty . } zB SELECT DISTINCT ?elem WHERE { ?elem a owl:ObjectProperty . } )classesrelsdtpropsopropsz0.3.15z1.0zlangchain_aws.NeptuneRdfGraph)sinceremovalalternative_importceZdZdZ ddedededededeed eed ed ed dfd Z e d efdZ e d e eeffdZ d e eeffdZded e eeffdZde eefd dfdZded eefdZddZy)NeptuneRdfGraphaNeptune wrapper for RDF graph operations. Args: host: endpoint for the database instance port: port number for the database instance, default is 8182 use_iam_auth: boolean indicating IAM auth is enabled in Neptune cluster use_https: whether to use secure connection, default is True client: optional boto3 Neptune client credentials_profile_name: optional AWS profile name region_name: optional AWS region, e.g., us-west-2 service: optional service name, default is neptunedata sign: optional, whether to sign the request payload, default is True Example: .. code-block:: python graph = NeptuneRdfGraph( host=', port= ) schema = graph.get_schema() OR graph = NeptuneRdfGraph( host=', port= ) schema_elem = graph.get_schema_elements() #... change schema_elements ... graph.load_schema(schema_elem) *Security note*: Make sure that the database connection uses credentials that are narrowly-scoped to only include necessary permissions. Failure to do so may result in data corruption or loss, since the calling code may attempt commands that would result in deletion, mutation of data if appropriately prompted or reading sensitive data if such data is present in the database. The best way to guard against such negative outcomes is to (as appropriate) limit the permissions granted to the credentials used with this tool. See https://python.langchain.com/docs/security for more information. Nhostport use_https use_iam_authclientcredentials_profile_name region_nameservicesignreturnc ||_||_d|d|d|_ |||_nddl} || j ||_n| j |_i} |r|| d<|rdnd} | d |d|| d <| r#|j j|fi| |_n9dd lm} dd l m }|j j|fi| d || i|_d|_i|_|j%y#t$r tdt$r5}t|jdk(r td|td|d}~wwxYw)Nzhttps://:z/sparqlr) profile_namerhttpshttpz:// endpoint_url)UNSIGNED)Configconfig)signature_versionzRCould not import boto3 python package. Please install it with `pip install boto3`.UnknownServiceErrorzgNeptuneGraph requires a boto3 version 1.28.38 or greater.Please install it with `pip install -U boto3`.zCould not load credentials to authenticate with AWS client. Please check that credentials in the specified profile name are valid.)rrquery_endpointrboto3Sessionsessionbotocorer"botocore.configr# ImportError Exceptiontype__name__ ValueErrorschemaschema_elements_refresh_schema)selfrrrrrrrrrr) client_paramsprotocolr"r#es v/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langchain_community/graphs/neptune_rdf_graph.py__init__zNeptuneRdfGraph.__init__Qs)& (avW=0 !$ +7#(==>V=#WDL$)==?DL " 3>M-0&/7V3;*CvQtf0M n-"5$,,"5"5g"O"ODK16"5$,,"5"5#'# &A#DK2 /1 + >  Aw#88!E !.  sB7C44E0EEc|jS)z; Returns the schema of the graph database. )r3r6s r: get_schemazNeptuneRdfGraph.get_schemas {{c|jS)N)r4r=s r:get_schema_elementsz#NeptuneRdfGraph.get_schema_elementss###r?c:|jjdS)z\ Obtain Neptune statistical summary of classes and predicates in the graph. detailed)mode)rget_rdf_graph_summaryr=s r: get_summaryzNeptuneRdfGraph.get_summarys{{00j0AAr?querycXd|i}|}d}|jr|jj}|j}|j}|j }d}|j } d} t||| |j} ddl m } | d|j|| } dd l m }|| ||jj| d | jd <| j}ni}d |d <t!j"d|j|| }t%j&|j(}|S) z$ Run Neptune query. rGNz neptune-db) access_key secret_keytokenregionr) AWSRequestPOST)methodurldataparams) SigV4Authz!application/x-www-form-urlencodedz Content-Type)rOrPheadersrQ)rr+get_credentialsget_frozen_credentialsrIrJrKrrbotocore.awsrequestrMr( botocore.authrSadd_authrTrequestsrequestjsonloadstext)r6rG request_datarQ request_hdr credentialsrIrJr session_tokenrRcredsrMr[rSqueryres json_resps r:rGzNeptuneRdfGraph.querys' '    ,,668K%<<>K$//J$//J"G'--MF#%%#'' E 7 4#6#6T&G 0 eWd&6&6 7 @ @ I.QGOON +!//KK*MK '##t22Kd JJx}}- r?r4c i}tD]F}g}||D]&}|d}|d}d|d|d}|j|(dj|||<Hd|dd |d d |d d |d|_y)z Generates and sets schema from schema_elements. Helpful in cases where introspected schema needs pruning. urilocal ()z, zIn the following, each IRI is followed by the local name and optionally its description in parentheses. The graph supports the following node types: r z1 The graph supports the following relationships: r z9 The graph supports the following OWL object properties: r z7 The graph supports the following OWL data properties: r N) ELEM_TYPESappendjoinr3) r6r4elem_strelemres_listelem_recrgrhres_strs r: load_schemazNeptuneRdfGraph.load_schemas DH+D1uo )cU#eWA.( 2 "YYx0HTN = "#$@ !H "#$F!" $ r?iricd|vr|jd}|dd|dgSd|vr9|jd}dj|dt|dz d|dgStd|d)z1 Split IRI into prefix and local #r/zUnexpected IRI 'z ', contains neither '#' nor '/'.)splitrmlenr2)r6rttokenss r:_get_local_namezNeptuneRdfGraph._get_local_names #:YYs^FaykOVBZ0 0 CZYYs^Fxxq3v;? ;<=Q?L L/u4TUV Vr?ci|jd<|j}g}|dddD]X}|}|j|}||dd}|j||d|jdvsDd|jd|d<Z||jd<g}|ddd D]_}|D]X}|}|j|}||dd}|j||d|jdvsDd|jd|d<Za||jd <tD]} tj | } | s|j | } g}| d d D]^}|d d}|j|}||dd}|j||d|jdvsJd|jd|d<`||j| <|j|jy)z5 Query Neptune to introspect schema. distinct_prefixespayload graphSummaryr ry)rgrhry predicatesr resultsbindingsrovalueN)r4rFr}rlrkgetrGrs) r6summaryreslistcrgr| elem_recordrproqitemss r:r5zNeptuneRdfGraph._refresh_schemas*5701""$#N3I>AC))#.F"%q :K NN; 'ay 4 45H IIGJ$$%89&)D ?+2Y'#N3LAA--c2&)F1I> {+!9D$8$89L$MMKND(()<=fQiH B(/V$Dt$AJJqMEG9%j1i(--c2&)F1I> {+!9D$8$89L$MMKND(()<=fQiH 2*1D  & --.r?)iTFNNN neptunedataT)rN)r1 __module__ __qualname____doc__strintboolrrr;propertyr>rrArFrGrsrr}r5r?r:rr sK )\"26%)$EEE E  E  E#+3-Ec]EEE ENC $T#s(^$$BT#s(^B ++ c3h+Z 4S> d : W3 W8C= W./r?r)r\typesrtypingrrrrrZlangchain_core._api.deprecationr DTPROP_QUERY OPROP_QUERYrkrrr?r:rsd !006       6 I/I/  I/r?