Skip to main content

Welcome to Coreflux

Tired of stitching together MQTT brokers, message queues, transformation scripts, and database connectors? Coreflux handles it all in one place. Get data from devices, centralize it in your broker, process it with simple scripts, and send it wherever it needs to go.
“You can do a LoT” - The complete IoT data pipeline for developers who want to ship faster.

Quick Navigation

What is LoT?

Think of LoT as SQL for real-time IoT data.
Just like SQL lets you query databases without writing low-level code, LoT lets you process MQTT messages without deploying external services. Write simple scripts, get instant results.
Instead of deploying separate microservices to process, transform, and route your IoT data, write simple scripts that run inside the broker. No containers to orchestrate. No message queues to manage. Just logic that executes the moment data arrives.

Why Developers Choose Coreflux

No microservices, containers, or orchestration for basic automation. One binary, full functionality.
Logic executes on publish, not on poll. Sub-millisecond response times.
Everything runs inside the MQTT broker. No Redis, no Kafka, no Node.js.
Write automation in plain English-like syntax anyone can understand.

See It In Action

The problem: You have temperature sensors publishing raw data, but you need alerts when values exceed thresholds and clean data forwarded to your dashboard. The solution: One LoT action handles everything:
DEFINE ACTION TemperatureMonitor
ON TOPIC "sensors/+/temperature" DO
    SET "sensor_id" WITH TOPIC POSITION 2
    SET "temp" WITH (GET JSON "value" IN PAYLOAD AS DOUBLE)
    
    IF {temp} > 80 THEN
        PUBLISH TOPIC "alerts/high_temp/" + {sensor_id} WITH "Temperature critical: " + {temp}
    
    PUBLISH TOPIC "processed/" + {sensor_id} + "/temperature" WITH PAYLOAD
This action triggers on every temperature reading, extracts the sensor ID from the topic, checks for high values, and forwards clean data - all without external services.

Resources


Next Steps