RSPLib Experiments

#Experiments

CITYBENCH CSPARQL EXPERIMENT 1

e = Experiment()

qname = "Q1" experimentName = "/experiment1.json" e.set_duration(5,"minutes") e.add_engine('http://csparql.westeurope.cloudapp.azure.com', 80, Dialects.CSPARQL)

q = e.add_query(qname, "query", Dialects.CSPARQL) q.set_select_clause("?obId1 ?obId2 ?v1 ?v2") q.set_where_clause("{?p1 a http://www.insight-centre.org/citytraffic#CongestionLevel.?p2 a http://www.insight-centre.org/citytraffic#CongestionLevel. {?obId1 http://purl.oclc.org/NET/ssnx/ssn#observedProperty ?p1.?obId1 http://purl.oclc.org/NET/sao/hasValue ?v1.?obId1 http://purl.oclc.org/NET/ssnx/ssn#observedBy http://www.insight-centre.org/dataset/SampleEventService#AarhusTrafficData182955.}{?obId2 http://purl.oclc.org/NET/ssnx/ssn#observedProperty ?p2.?obId2 http://purl.oclc.org/NET/sao/hasValue ?v2.?obId2 http://purl.oclc.org/NET/ssnx/ssn#observedBy http://www.insight-centre.org/dataset/SampleEventService#AarhusTrafficData158505.}}") e.add_windowed_stream(qname,"AarhusTrafficData182955", "http://triplewave1.westeurope.cloudapp.azure.com:4000/sgraph", '3s','1s' ) e.add_windowed_stream(qname,"AarhusTrafficData158505", "http://triplewave1.westeurope.cloudapp.azure.com:4001/sgraph", '3s','1s' )

e.add_graph(qname, "SensorRepository", "https://rsplab.blob.core.windows.net/static/SensorRepository.rdf", serialization="RDF/XML", default='true') #e.add_graph(qname, "AarhusLibraryEvents", "https://rsplab.blob.core.windows.net/static/AarhusLibraryEvents.rdf", serialization="RDF/XML", default='true')