RSPLib

What is RSP Lib

Install

pip install rsplib

Build

git clone https://github.com/streamreasoning/rsplib.git cd rsplib && python install.py

Packages

• Experiments
  • Design
  • Execution
  • Report
• Processing
  • TripleWave
  • RSP Engine
  • RSP Sinks

from rsplib.processing.consumer import RSPEngine

engine = RSPEngine(host, port);

engine.register_graph( d.name, d.location, d.serialization, d.default )

engine.register_stream(s.name, s.location )

engine.register_query(q.name, q.query_type, q.query_body())

engine.new_observer(q.name, "default", {host":"","type":"ws","port":9101,"name":"default"})