Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
- batch-processing
- kafka
- pathway
- python
47,133 repositories indexed
1–24 of 34 · Most stars
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
All-in-one IoT Platform - Device management, data collection, processing and visualization.
The most scalable and reliable MQTT broker for AI, IoT, IIoT and connected vehicles
Eclipse Mosquitto - An open source MQTT broker
Apache Ignite
A distributed MQTT message broker based on Erlang/OTP. Built for high quality & Industrial use cases. The VerneMQ mission is active & the project maintained. Thank you for your support!
IoT Platform Framework
An ultra-lightweight and blazing-fast Messaging Bus/MQTT Broker for Edge & SDV
Project Flogo is an open source ecosystem of opinionated event-driven capabilities to simplify building efficient & modern serverless functions, microservices & edge apps.
Open-source IoT Gateway - integrates devices connected to legacy and third-party systems with ThingsBoard IoT Platform using Modbus, CAN bus, BACnet, BLE, OPC-UA, MQTT, ODBC and REST protocols.
Barebone MQTT broker that can run on any stream server, the node way
The fully compliant, embeddable high-performance Go MQTT v5 server for IoT, smarthome, and pubsub
Lightweight data stream processing engine for IoT edge
HiveMQ CE is a Java-based open source MQTT broker that fully supports MQTT 3.x and MQTT 5. It is the foundation of the HiveMQ Enterprise Connectivity and Messaging Platform
A lightweight, high-performance go mqtt server(v3.0|v3.1.1|v5.0) supporting distributed cluster
The ultimate distributed MQTT broker. Handles 100M+ connections and 10M msg/sec with ease. Built on Kafka to provide industrial-grade persistence and eliminate data loss.
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams.
HStreamDB is an open-source, cloud-native streaming database for IoT and beyond. Modernize your data stack for real-time applications.
JSON-RPC 2.0 implementation over WebSockets for Node.js and JavaScript/TypeScript
The idiomatic asyncio MQTT client
High-performance, time-indexed object storage for robotics and industrial IoT
Distributed C++ services from embedded to enterprise
Highly optimized, extremely modular and very flexible XMPP/Jabber server
Lightweight stream processing engine for IoT