CAN Bus data processing

[loki429]

Hello, I'm a newb to ekuiper and hoping someone can assist me with processing CAN bus data please?
I found this article that makes it sound really simple but I just can't get it to work :-(
https://www.emqx.com/en/blog/bridging-demanded-signals-from-can-bus-to-mqtt-by-ekuiper

From the blog: "eKuiper understands CAN bud data. It eases the CAN frame decoding and transforms it into just some configurations. To consume CAN bus data, you can create a stream using the following SQL statement:"
CREATE STREAM canDemo () WITH (TYPE="can", FORMAT="can", SHARED="TRUE", SCHEMAID="dbc")

Where do I add that? From the management gui there is no CAN type, and from the kuiper cli it doesn't recognise the type.
If I add it as SQL in a rule I receive an error saying the option 'format=can' is invalid.

Many thanks for any assistance or pointers in the right direction.
Jon

[ngjaying]

Hi Jon,
The CAN source is not open source yet. You can send me an email huangjy at emqx.io so that I can redirect you to the right person.
Thank you.

[epvin]

Received your email, thank you very much for your patient help

[KuSunoKiAMe]

hello,I also need a copy of the source code too. Would it be convenient for you to read it for me? My email is [email protected] you very much

[ngjaying]

Please check https://hub.docker.com/r/emqx/ek-can

[KuSunoKiAMe]

I have tried out this Docker image and completed an mqtt message transmission.But if I need to listen to multiple can ports, what should I do

[ngjaying]

Can you create multiple streams?