blob: 1ec22820887054dd45e132f2c9e51a49d2bf0584 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
|
from rdflib.parser import Parser
from rdflib.plugins.parsers.ntriples import NTriplesParser
__all__ = ['NTSink', 'NTParser']
class NTSink(object):
def __init__(self, graph):
self.graph = graph
def triple(self, s, p, o):
self.graph.add((s, p, o))
class NTParser(Parser):
"""parser for the ntriples format, often stored with the .nt extension
See http://www.w3.org/TR/rdf-testcases/#ntriples"""
def __init__(self):
super(NTParser, self).__init__()
def parse(self, source, sink, baseURI=None):
f = source.getByteStream() # TODO getCharacterStream?
parser = NTriplesParser(NTSink(sink))
parser.parse(f)
f.close()
|
