cargo run --bin http_server -- --host 127.0.0.1 --port 8080 --storage-dir ./data/storagecurl http://127.0.0.1:8080/healthcurl -X POST http://127.0.0.1:8080/api/queries \
-H 'Content-Type: application/json' \
-d '{
"query_id": "historical_q1",
"janusql": "PREFIX ex: <http://example.org/> SELECT ?s ?p ?o FROM NAMED WINDOW ex:w ON LOG ex:log [START 1700000000000 END 1700086400000] WHERE { WINDOW ex:w { ?s ?p ?o . } }"
}'curl -X POST http://127.0.0.1:8080/api/queries/historical_q1/start
curl http://127.0.0.1:8080/api/queries/historical_q1Connect a WebSocket client to:
ws://127.0.0.1:8080/api/queries/historical_q1/results
curl -X POST http://127.0.0.1:8080/api/queries/historical_q1/stop
curl -X DELETE http://127.0.0.1:8080/api/queries/historical_q1For live streams, first start Mosquitto with docker-compose up -d mosquitto
and use the replay endpoint or stream-bus CLI. See the
HTTP API reference for all endpoints.