Skip to content

Yisaer/rstream

Repository files navigation

How to use

Create table

curl --request POST \
  --url http://127.0.0.1:3030/view \
  --data '{
  "sql": "create table t(a int, b int,c int,d int);"
}'

Create view

curl --request POST \
  --url http://127.0.0.1:3030/view \
  --data '{
  "sql": "select a as e from t where b > 30;"
}'

send/recv data by mqtt broker 127.0.0.1:1883

send data topic: /yisa/data

recv data topic: /yisa/data2

Delete the view

curl --request DELETE \
  --url 'http://127.0.0.1:3000/view?id=0'

About

stream toy engine write in rust

Resources

Stars

Watchers

Forks

Packages

No packages published

Languages