o i@sdZddlmZddlmZddlmZmZmZddl m Z ddl m Z ddlmZddlmZmZmZdd lmZd gZeeefZGd d d eZd S) a This is a rdflib plugin for parsing NQuad files into Conjunctive graphs that can be used and queried. The store that backs the graph *must* be able to handle contexts. >>> from rdflib import ConjunctiveGraph, URIRef, Namespace >>> g = ConjunctiveGraph() >>> data = open("test/data/nquads.rdflib/example.nquads", "rb") >>> g.parse(data, format="nquads") # doctest:+ELLIPSIS )> >>> assert len(g.store) == 449 >>> # There should be 16 separate contexts >>> assert len([x for x in g.store.contexts()]) == 16 >>> # is the name of entity E10009 "Arco Publications"? >>> # (in graph http://bibliographica.org/entity/E10009) >>> # Looking for: >>> # >>> # >>> # "Arco Publications" >>> # >>> s = URIRef("http://bibliographica.org/entity/E10009") >>> FOAF = Namespace("http://xmlns.com/foaf/0.1/") >>> assert(g.value(s, FOAF.name).eq("Arco Publications")) ) annotations) getreader)AnyMutableMappingOptional) ParserError)ConjunctiveGraph) InputSource)W3CNTriplesParserr_tailr_wspace)BNode NQuadsParserc@s&eZdZ ddd d ZddddZdS)rN inputsourcer sinkr bnode_contextOptional[_BNodeContextType]kwargsrreturnc Ks|jjsJdt|j|jd|_|}|s!|}td|}t|ds*t d||_ d|_ | |_ }|j durA |jSz||Wnt y\}zt d ||fd}~wwq1) a Parse inputsource as an N-Quads file. :type inputsource: `rdflib.parser.InputSource` :param inputsource: the source of N-Quads-formatted data :type sink: `rdflib.graph.Graph` :param sink: where to send parsed triples :type bnode_context: `dict`, optional :param bnode_context: a dict mapping blank node identifiers to `~rdflib.term.BNode` instances. See `.W3CNTriplesParser.parse` z1NQuadsParser must be given a context aware store.)store identifierzutf-8readz)Item to parse must be a file-like object.TNzInvalid line (%s): %r)r context_awarerrrgetCharacterStream getByteStreamrhasattr ParseErrorfilebufferreadlineline parseline)selfrrrrsource_NQuadsParser__linemsgr'X/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/rdflib/plugins/parsers/nquads.pyparse-s4    zNQuadsParser.parseNonecCs|t|jr|jdrdS||}|t|}|t||}|t|p9||p9|j j }|t |jrFt d|j ||||fdS)N#zTrailing garbage)eatr r! startswithsubject predicateobjecturirefnodeidrrr r get_contextadd)r#rr.r/objcontextr'r'r(r"\s       zNQuadsParser.parseline)N) rr rrrrrrrr)rrrr*)__name__ __module__ __qualname__r)r"r'r'r'r(r+s /N)__doc__ __future__rcodecsrtypingrrrrdflib.exceptionsrr rdflib.graphr rdflib.parserr rdflib.plugins.parsers.ntriplesr r r rdflib.termr __all__str_BNodeContextTyperr'r'r'r(s