search

lf-edge / ekuiper

Lightweight data stream processing engine for IoT edge
https://ekuiper.org
Apache License 2.0
1.48k stars 414 forks source link

I want to use websocket as an input source #3367

Open Maingol opened 5 days ago

Maingol commented 5 days ago

I want to use websocket as an input source, I have read your documentation, and according to its operation, I can add a websocket type source configuration group through the api, but when I try to edit it, has been prompted by the lack of related plug-ins, but your plug-ins to download the entrance and does not provide a websocket connection, too many related bugs! I'm not sure if you really intend to support websocket input sources, or if I'm not using it in the right way, can you provide me with detailed steps to realize this requirement?

ngjaying commented 5 days ago

Which version do you use? @Maingol

Maingol commented 5 days ago

I've tried both 1.13.4 and the latest 2.0

ngjaying commented 5 days ago

Please add your test case to reproduce? Do you use docker image? What tag do you use?

Maingol commented 5 days ago

docker lfedge/ekuiper:1.13.4-slim

Yisaer commented 5 days ago

Hi @Maingol

How did you create websocket stream and the related rules? Did you create it with manager-ui. If so, the manager-ui isn't maintained now thus it may happened the unexpected bug. Please create stream/rules by rest api according to the documents: https://ekuiper.org/docs/en/latest/api/restapi/streams.html

Maingol commented 5 days ago

The introduction is too vague, what exactly do I have to do, can one api do it? Can an API specify both the stream creation and the websocket address? How do I specify the websocket address? Do I need to add a source configuration group with the api? Can you build a simple demo on your own machine to realize the need to read data from a websocket source, and then tell me the detailed steps?