eKuiper: Lightweight data stream processing engine for IoT edge

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

eKuiper collaborates with EMQX to achieve data collection, vehicle AI and vehicle rule engine.

Learn More →

Rules Engine for EdgeX Foundry

By integrating with EdgeX Foundry, eKuiper can help users to process data of the connected devices and route the result or control the devices by rule.

Learn More →

Analytic Engine for KubeEdge

The integration of KubeEdge and eKuiper enables the containerized deployment of the eKuiper instance and provides versatile analytic capabilities on the edge components to achieve low latency calculation.

Learn More →