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

Getting Started

Go from zero to your first LoT Action in under 15 minutes.

Installation

Install Coreflux on Windows, Linux, Docker, or ARM.

LoT Language

Learn the Language of Things - Actions, Models, Rules, and Routes.

Downloads

Download Coreflux MQTT Broker - free self-hosted version available.

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.

Introduction to LoT

Learn the fundamentals of the Language of Things and how it works.

Actions

React to events and publish data. “When temperature exceeds 80°, send an alert.”

Models

Transform and structure data. Convert raw bytes to clean JSON with context.

Routes

Connect systems. Stream data to PostgreSQL, MongoDB, REST APIs, and more.

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

GitHub

Explore examples and community projects.

Discord

Join the community for support and discussions.

Website

Download Coreflux and start your free trial.

Next Steps

Getting Started

Follow the 15-minute tutorial to create a working LoT action.

Developing with LoT using AI

A beginner’s guide to building IIoT solutions with LoT, by yourself or with the help of AI.