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 →Why eKuiper
Open Source
LF Edge Sandbox project licensed under Apache 2.0 License.
Real-time Analytics
Make faster decisions on the edge to understand events while they’re happening.
Lightweight
Booting footprint is less than 12MB for core feature set.
Agile Intelligent Decision
Run AI analytics immediately as new events emerged.
Ops-Friendly
Easily deploy to thousands of edge nodes and manage them from the cloud.
Simple yet Powerful
Use SQL-based syntax or flow editor to compose your powerful analytic rules.
Quick Start
Run with Docker
docker run -p 9081:9081 -d --name ekuiper -e MQTT_SOURCE__DEFAULT__SERVER=tcp://broker.emqx.io:1883 lfedge/ekuiper:latest
Build from Source
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
Key Features
Lightening fast processing
Extraordinary low latency on edge by processing data near the producers.
Integrate your data everywhere
Produce and consume any data from your loved data stack with sources and sinks.
SQL or Flow editor
ANSI SQL queries or flow editor for quick IoT data analytics. No Java or python codes are needed.
Agile application DevOps
Create and alter your data analytics jobs in the flight with text-based rules.
Evolvable & Customizable
Highly extensible for sources, sinks, and UDFs.
AI/ML in stream
Integrate machine learning algorithms and run against streaming data.
Integrations
Edge cloud collaboration
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 →Vehicle Cloud Collaboration
Rules Engine for EdgeX Foundry
Analytic Engine for KubeEdge
Community
Stay connected with the eKuiper community! Ask questions, find answers, explore ideas, and share expertise.
Join Our CommunityEcosystem
