In [1]:

    

from query import Query

my_query = Query("test","query")

stream = "AarhusPollutionData182955"
my_query.add_windowed_stream(stream,"3s","1s")
my_query.add_windowed_stream(stream,"3s","1s")
my_query.add_windowed_stream(stream,"3s","1s")
my_query.add_windowed_stream(stream,"3s","1s")

my_query.add_dataset("http://127.0.0.1:9000/WebGlCity/SensorRepository.rdf")

my_query.set_select_clause("?obId1 ?obId2 ?v1 ?v2 ")
my_query.set_where_clause("{?p1   a <http://www.insight-centre.org/citytraffic#ParkingVacancy>. ?p2   a <http://www.insight-centre.org/citytraffic#CongestionLevel>. {?obId1 a ?ob. ?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#AarhusParkingDataKALKVAERKSVEJ>. }{?obId2 a ?ob.?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>.}}")

print(my_query.to_string_csparql())


    

    




SELECT ?obId1 ?obId2 ?v1 ?v2  FROM STREAM <AarhusPollutionData182955> [range 3s step 1s]
 FROM STREAM <AarhusPollutionData182955> [range 3s step 1s]
 FROM STREAM <AarhusPollutionData182955> [range 3s step 1s]
 FROM STREAM <AarhusPollutionData182955> [range 3s step 1s]
WHERE {?p1   a <http://www.insight-centre.org/citytraffic#ParkingVacancy>. ?p2   a <http://www.insight-centre.org/citytraffic#CongestionLevel>. {?obId1 a ?ob. ?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#AarhusParkingDataKALKVAERKSVEJ>. }{?obId2 a ?ob.?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>.}}

In [ ]:

    




    

In [ ]:

    




    

In [ ]: