Build Your Own
Data Pipeline

Design with Connectors that gather data from any brand of device, transfer them through On-Prem and Cloud MQTT Brokers and feed them into all sorts of Data Applications.

corefluxlogo

Build Your Own
Data Pipeline

Design with Connectors that gather data from any brand of device, transfer them through On-Prem and Cloud MQTT Brokers
and feed them into all sorts of Data Applications.

Your Integration Journey, Step-by-Step

Connect your devices to MQTT

Centralize all your machine's data in an MQTT Broker: Self-hosted with our free software, or guaranteed performance with a Managed MQTT Broker.
Choose your MQTT Broker
productcoreflux2
dataloading

Build robust data pipelines

Coreflux provides an ever-growing library of dedicated Connectors, that enables Data Collection from devices of any kind, and translates all Industry-Standard Communication Protocols.
Discover the Connectors library

Automate with LoT
(Language of Things)

Write automation rules in human-readable syntax that runs directly inside the Broker. Define triggers, data structures, and integrations with no microservices or external dependencies required.
Explore Language of Things
dataloading
productcoreflux

Integrate Data Applications

Transform data into knowledge, automation and actionable insights by integrating your favorite Data Applications directly into the Coreflux Pipeline.
Explore all the Applications
# BUILDING THE FUTURE

Co-financed by the Portugal's "Recovery and Resilience Plan (RRP)" Program, a part of Europe's "NextGenerationEU" which contributes to ensuring long-term sustainable growth and responding to the challenges of the twin climate and digital transitions. This support has determinately contributed to the development of green-tech solutions with an impact on sustainability, and the internationalization of the products via eCommerce.

COMPLETE & ONGOING PROJECTS (2023 - present):

• Vouchers para Startups - Novos produtos verdes e digitais (Ficha de Projeto)
‍
• Transição digital das empresas medida "Internacionalização via E-commerce" (Ficha de Projeto)
‍
‍

FAQ

Frequently asked questions.
What is Coreflux?
Coreflux is an Industrial IoT platform built around a high-performance MQTT broker with built-in edge computing capabilities. Unlike traditional brokers that only route messages, Coreflux processes data where it is generated using LoT (Language of Things), a human-readable automation language. The platform connects to industrial protocols like Modbus, OPC UA, Siemens S7, and Allen-Bradley, while routing data to databases, REST APIs, cloud services, and other MQTT brokers. Coreflux runs on Windows, Linux, Docker, Raspberry Pi, and cloud environments, making it suitable for edge deployments, factory floors, and enterprise-scale IoT architectures.
What is an MQTT broker and why do I need one?
An MQTT broker is the central hub that enables devices and applications to communicate using the publish-subscribe messaging pattern. When a sensor publishes data to a topic, the broker delivers that message to every application subscribed to it. This decouples your devices from your applications, meaning you can add new sensors, dashboards, or analytics tools without rewiring your entire system. For industrial IoT, an MQTT broker is the foundation of a Unified Namespace (UNS), allowing real-time data flow between PLCs, sensors, databases, and cloud platforms.
What is the Language of Things (LoT)?
LoT is a human-readable language for IoT automation created by Coreflux. It uses near-English syntax to define logic, data structures, and integrations directly within the MQTT broker. Think of LoT as SQL for real-time MQTT data. Just as SQL transforms database records, LoT transforms live MQTT streams without deploying external services. With LoT, you can define Actions (event-driven logic triggered by time or topics), Models (structured JSON schemas), Routes (connections to databases, APIs, and industrial equipment), and Rules (access control for topics and operations).
What industrial protocols does Coreflux support?
Coreflux provides native connectivity to major industrial protocols through its Routes system. Supported protocols include Modbus TCP/RTU for sensors and legacy equipment, OPC UA for modern industrial systems, Siemens S7 for S7-300, S7-400, S7-1200, and S7-1500 PLCs, Allen-Bradley for ControlLogix and CompactLogix controllers, and FINS for Omron PLCs. These protocol connectors run inside the broker, eliminating the need for separate gateway software. Data from PLCs flows directly into your MQTT namespace and can be processed, transformed, or routed to databases in real time.
How is Coreflux different from other MQTT brokers?
Traditional MQTT brokers like Mosquitto act as passive message routers. Coreflux is an active data processing platform. It combines the MQTT broker with edge computing capabilities, so you can transform, filter, validate, and route data without external services. Key differentiators include built-in LoT runtime for automation logic, native industrial protocol support without additional gateways, direct database routes to PostgreSQL, MongoDB, InfluxDB, CrateDB, and OpenSearch, Python integration for complex calculations and external libraries, and a lightweight footprint suitable for edge devices and Raspberry Pi. This means fewer moving parts, lower latency, and simpler architecture compared to assembling separate tools for connectivity, transformation, and storage.
Can I extend Coreflux with Python?
Yes. While LoT handles most IoT automation elegantly, some tasks need the full power of a programming language. Coreflux allows you to call Python functions directly from your LoT actions. Your Python code runs inside the broker alongside your automation logic, with no external services, network calls, or containers required. Use Python for complex calculations like statistics and machine learning, regex and advanced string parsing, data validation with complex rules, and external library calls using numpy, pandas, or custom packages.