
MQTT Stream Processing with EMQX and eKuiper: A Quick Tutorial
This article will demonstrate using eKuiper to stream process MQTT data from EMQX in real-time.
Learn More →LF Edge Sandbox project licensed under Apache 2.0 License.
Make faster decisions on the edge to understand events while they’re happening.
Booting footprint is less than 12MB for core feature set.
Run AI analytics immediately as new events emerged.
Easily deploy to thousands of edge nodes and manage them from the cloud.
Use SQL-based syntax or flow editor to compose your powerful analytic rules.
docker run -p 9081:9081 -d --name ekuiper -e MQTT_SOURCE__DEFAULT__SERVER=tcp://broker.emqx.io:1883 lfedge/ekuiper:latest
git clone https://github.com/lf-edge/ekuiper.git cd ekuiper make # Run the built binary cd _build/kuiper-1.6.0-linux-amd64 bin/kuiperd
Extraordinary low latency on edge by processing data near the producers.
Produce and consume any data from your loved data stack with sources and sinks.
ANSI SQL queries or flow editor for quick IoT data analytics. No Java or python codes are needed.
Create and alter your data analytics jobs in the flight with text-based rules.
Highly extensible for sources, sinks, and UDFs.
Integrate machine learning algorithms and run against streaming data.
eKuiper is deployed on the edge side and acts in the middle between edge and cloud applications for stream processing, rule engine, message routing, and more.
Learn More →Stay connected with the eKuiper community! Ask questions, find answers, explore ideas, and share expertise.
Join Our Community